Java设计模式——职责链模式

傷城~ 2022-12-16 09:17 225阅读 0赞

### 前言： ###

几个月没动过博客了，就连看都很少看了，工作10个月以来，忙碌于各种繁杂的需求业务，导致每天上班对代码相关的，我都特别的反感。但归咎到底，“打代码”还是我现在最热爱的。这两者并不冲突，我喜欢打代码，但不喜欢为了赚钱而去打自己不喜欢打的代码~好了，不说废话，这篇博客主要是将我在工作这段时间所用到的设计模式做一个简单总结。

### 职责链模式： ###

个人觉得“职责链模式”无论是现在，还是以后，我都会一直使用下去，对我来说一个非常实用的设计模式，把它用在我的项目框架中，能给业务的扩展带来极大的便利。它将业务逻辑或规则，一个一个剥离开来，降低耦合性，无论客户的要求多么“刁钻”和“无理”，还是频繁地更改需求，在我们修改时，都可以减少很多工作量，甚至可以将这些逻辑和规则进行复用。

实现原理：

一个链上有多个处理逻辑，一个请求到来会被所有节点处理，最后返回最终处理的结果，并不是被其中的某一个逻辑处理就结束，并且规则可以动态添加。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70][]

###  实现： ###

1、定义处理链：

package com.chen.filter;
    
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    
    public class FilterChain {
    
    	// 规则处理链列表，实现Filter接口的过滤器将真正执行对事件的处理
    	private List<Filter> filters = new ArrayList<>();
    
    	// 过滤器列表的索引
    	private int index = 0;
    
    	// 向职责链中加入过滤器（单个）
    	public FilterChain addFilter(Filter filter) {
    		this.filters.add(filter);
    		return this;
    	}
    
    	// 向职责链中加入过滤器（多个）
    	public FilterChain addFilters(List<Filter> filters) {
    		this.filters.addAll(filters);
    		return this;
    	}
    
    	// 执行处理链的各个节点，每个节点处理完毕，回调该方法处理下一个节点
    	public void doFilter(HashMap<String, Object> requestMap, FilterChain chain) {
    		if (index == filters.size()) {
    			return;
    		}
    		Filter filter = filters.get(index);
    		index++;
    		filter.execute(requestMap, chain);
    	}
    
    	// 将处理节点进行增加
    	public FilterChain addFilter(FilterChain newInstance) {
    
    		return null;
    	}
    }

2、定义处理链接口，链上的任何节点都实现该接口

package com.chen.filter;
    
    import java.util.HashMap;
    
    public interface Filter {
    	void execute(HashMap<String, Object> requestMap, FilterChain chain);
    }

3、前两个步骤，那么我们的链就基本设置完毕了，接下来就是设置节点，我这里就写两个简单的节点，一个节点用来获取用户的姓名，一个节点用来获取用户的性别。看，每个节点的功能是不是不一样，一个拿姓名，一个拿性别。在真实的业务中，就可以将这些逻辑规则抽离出来，变成一个一个节点，每个节点都去实现各自的功能，甚至这些节点可以进行复用，以后客户想修改某个功能，那么我们只需修改相应功能的节点就可以了。

节点1：

package com.chen.rule;
    
    import java.util.HashMap;
    
    import com.chen.filter.Filter;
    import com.chen.filter.FilterChain;
    
    public class Action1 implements Filter {
    	@Override
    	public void execute(HashMap<String, Object> requestMap, FilterChain chain) {
    
    		System.out.println("执行功能规则1>>>>>");
    		System.out.println("获取姓名：" + requestMap.get("name"));
    
    		chain.doFilter(requestMap, chain);
    	}
    }

节点2：

package com.chen.rule;
    
    import java.util.HashMap;
    
    import com.chen.filter.Filter;
    import com.chen.filter.FilterChain;
    
    public class Action2 implements Filter {
    	@Override
    	public void execute(HashMap<String, Object> requestMap, FilterChain chain) {
    		System.out.println("执行功能规则2>>>>>");
    		System.out.println("获取性别：" + requestMap.get("sex"));
    
    		chain.doFilter(requestMap, chain);
    	}
    }

4、最后一步，就是模拟请求进行测试了。

package com.chen;
    
    import java.util.HashMap;
    
    import com.chen.filter.Filter;
    import com.chen.filter.FilterChain;
    import com.chen.rule.Action1;
    import com.chen.rule.Action2;
    
    
    public class Client
    {
    	public static void main(String[] args) throws InstantiationException, IllegalAccessException
        {
        	
        	HashMap<String, Object> requestMap=new HashMap<String, Object>();
        	requestMap.put("name", "chen");
        	requestMap.put("sex", "男");
    
            //将节点加入职责链
            FilterChain filterChain = new FilterChain();
            filterChain.addFilter(new Action1()).addFilter(new Action2());
    
            //执行职责链
            filterChain.doFilter(requestMap, filterChain);
        }
    }

当然，在实际应用中，应该设置成可动态添加的状态，可以将这些节点保存在数据库，当客户需求改变的时候，只需要修改数据库中的节点便可以，接下来是一个可以通过包名+类名获取节点类实例的参考：

package com.chen;
    
    import java.util.HashMap;
    
    import com.chen.filter.Filter;
    import com.chen.filter.FilterChain;
    import com.chen.rule.Action2;
    
    public class Client {
    	public static void main(String[] args) throws InstantiationException, IllegalAccessException {
    		Class<?> c = null;
    		try {
    			c = Class.forName("com.chen.rule.Action1");
    
    		} catch (ClassNotFoundException e) {
    			e.printStackTrace();
    		}
    		Filter filter = (Filter) c.newInstance();
    		HashMap<String, Object> requestMap = new HashMap<String, Object>();
    		requestMap.put("name", "chen");
    		requestMap.put("sex", "男");
    
    		// 将规则加入职责链
    		FilterChain filterChain = new FilterChain();
    		filterChain.addFilter(filter).addFilter(new Action2());
    
    		// 执行职责链
    		filterChain.doFilter(requestMap, filterChain);
    	}
    }

输出结果：

![20201020230152528.png][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA5NzQ2_size_16_color_FFFFFF_t_70]: /images/20221123/2cfc57cf3ad443e98505b10f43c69d42.png
[20201020230152528.png]: /images/20221123/376b5d917ca041c5a96b5e20679cfe81.png