行为型模式--责任链模式（Chain of Responsibility）

接下来我们将要谈谈责任链模式，有多个对象，每个对象持有对下一个对象的引用，这样就会形成一条链，请求在这条链上传递，直到某一对象决定处理该请求。但是发出者并不清楚到底最终那个对象会处理该请求，所以，责任链模式可以实现，在隐瞒客户端的情况下，对系统进行动态的调整。先看看关系图：

 

 

Abstracthandler类提供了get和set方法，方便MyHandle类设置和修改引用对象，MyHandle类是核心，实例化后生成一系列相互持有的对象，构成一条链。

[java] view plaincopy

1. public interface Handler {  
2.     public void operator();  
3. }  

[java] view plaincopy

1. public abstract class AbstractHandler {  
2.       
3.     private Handler handler;  
4.   
5.     public Handler getHandler() {  
6.         return handler;  
7.     }  
8.   
9.     public void setHandler(Handler handler) {  
10.         this.handler = handler;  
11.     }  
12.       
13. }  

[java] view plaincopy

1. public class MyHandler extends AbstractHandler implements Handler {  
2.   
3.     private String name;  
4.   
5.     public MyHandler(String name) {  
6.         this.name = name;  
7.     }  
8.   
9.     @Override  
10.     public void operator() {  
11.         System.out.println(name+"deal!");  
12.         if(getHandler()!=null){  
13.             getHandler().operator();  
14.         }  
15.     }  
16. }  

[java] view plaincopy

1. public class Test {  
2.   
3.     public static void main(String[] args) {  
4.         MyHandler h1 = new MyHandler("h1");  
5.         MyHandler h2 = new MyHandler("h2");  
6.         MyHandler h3 = new MyHandler("h3");  
7.   
8.         h1.setHandler(h2);  
9.         h2.setHandler(h3);  
10.   
11.         h1.operator();  
12.     }  
13. }  

输出：

h1deal!
h2deal!
h3deal!

此处强调一点就是，链接上的请求可以是一条链，可以是一个树，还可以是一个环，模式本身不约束这个，需要我们自己去实现，同时，在一个时刻，命令只允许由一个对象传给另一个对象，而不允许传给多个对象。

====================================================================

下面是另外一个例子：

public class Test {

	public static void main(String[] args) {

		String pass1 = "123456";

		String pass2 = "123456";

		String personId = "123456227890125678";

		String email = "[e-mail]";

		register(pass1, pass2, personId, email);

	}

	public static void register(String pass1, String pass2, String personId, String email) {

		Filter f1 = new PasswordFilter1();

		Filter f2 = new PasswordFilter2();

		Filter f3 = new PersonIdFilter();

		Filter f4 = new EmailFilter();

		f1.setNext(f2);

		f2.setNext(f3);

		f3.setNext(f4);

		System.out.println(f1.doFilter(pass1, pass2, personId, email));

	}

}

abstract class Filter {

	Filter next = null;

	public Filter getNext() {

		return next;

	}

	public void setNext(Filter next) {

		this.next = next;

	}

	public String doFilter(String pass1, String pass2, String personId, String email) {

		if (next == null)
			return "成功";

		else
			return next.doFilter(pass1, pass2, personId, email);

	}

}

class PasswordFilter1 extends Filter {

	public String doFilter(String pass1, String pass2, String personId, String email) {

		if (!(pass1.equals(pass2)))

			return "两次密码输入不一致";

		else
			return super.doFilter(pass1, pass2, personId, email);

	}

}

class PasswordFilter2 extends Filter {

	public String doFilter(String pass1, String pass2, String personId, String email) {

		if (pass1.length() != 6)

			return "密码长度必须为6";

		else
			return super.doFilter(pass1, pass2, personId, email);

	}

}

class PersonIdFilter extends Filter {

	public String doFilter(String pass1, String pass2, String personId, String email) {

		if (personId.length() != 15 && personId.length() != 18)

			return "身份证号码非法";

		else
			return super.doFilter(pass1, pass2, personId, email);

	}

}

class EmailFilter extends Filter {

	public String doFilter(String pass1, String pass2, String personId, String email) {

		int i1 = email.indexOf("@");

		int i2 = email.indexOf(".");

		if (i1 == -1 || i2 == -1 || i2 - i1 <= 1 || i1 == 0 || i2 == email.length() - 1)

			return "email非法";

		else
			return super.doFilter(pass1, pass2, personId, email);

	}

}

 下面使用了一个责任链模式的最简单的实现。

　　责任链模式涉及到的角色如下所示：

　　●　　抽象处理者(Handler)角色：定义出一个处理请求的接口。如果需要，接口可以定义 出一个方法以设定和返回对下家的引用。这个角色通常由一个Java抽象类或者Java接口实现。上图中Handler类的聚合关系给出了具体子类对下家的引用，抽象方法handleRequest()规范了子类处理请求的操作。

　　●　　具体处理者(ConcreteHandler)角色：具体处理者接到请求后，可以选择将请求处理掉，或者将请求传给下家。由于具体处理者持有对下家的引用，因此，如果需要，具体处理者可以访问下家。

源代码

　　抽象处理者角色

public abstract class Handler {
    
    /**
     * 持有后继的责任对象
     */
    protected Handler successor;
    /**
     * 示意处理请求的方法，虽然这个示意方法是没有传入参数的
     * 但实际是可以传入参数的，根据具体需要来选择是否传递参数
     */
    public abstract void handleRequest();
    /**
     * 取值方法
     */
    public Handler getSuccessor() {
        return successor;
    }
    /**
     * 赋值方法，设置后继的责任对象
     */
    public void setSuccessor(Handler successor) {
        this.successor = successor;
    }
    
}

　　具体处理者角色

public class ConcreteHandler extends Handler {
    /**
     * 处理方法，调用此方法处理请求
     */
    @Override
    public void handleRequest() {
        /**
         * 判断是否有后继的责任对象
         * 如果有，就转发请求给后继的责任对象
         * 如果没有，则处理请求
         */
        if(getSuccessor() != null)
        {            
            System.out.println("放过请求");
            getSuccessor().handleRequest();            
        }else
        {            
            System.out.println("处理请求");
        }
    }

}

　　客户端类

public class Client {

    public static void main(String[] args) {
        //组装责任链
        Handler handler1 = new ConcreteHandler();
        Handler handler2 = new ConcreteHandler();
        handler1.setSuccessor(handler2);
        //提交请求
        handler1.handleRequest();
    }

}

　地组合职责链，实现不同的功能要求了。

　　

public abstract class Handler {
    /**
     * 持有下一个处理请求的对象
     */
    protected Handler successor = null;
    /**
     * 取值方法
     */
    public Handler getSuccessor() {
        return successor;
    }
    /**
     * 设置下一个处理请求的对象
     */
    public void setSuccessor(Handler successor) {
        this.successor = successor;
    }
    /**
     * 处理聚餐费用的申请
     * @param user    申请人
     * @param fee    申请的钱数
     * @return        成功或失败的具体通知
     */
    public abstract String handleFeeRequest(String user , double fee);
}

public class ProjectManager extends Handler {

    @Override
    public String handleFeeRequest(String user, double fee) {
        
        String str = "";
        //项目经理权限比较小，只能在500以内
        if(fee < 500)
        {
            //为了测试，简单点，只同意张三的请求
            if("张三".equals(user))
            {
                str = "成功：项目经理同意【" + user + "】的聚餐费用，金额为" + fee + "元";    
            }else
            {
                //其他人一律不同意
                str = "失败：项目经理不同意【" + user + "】的聚餐费用，金额为" + fee + "元";
            }
        }else
        {
            //超过500，继续传递给级别更高的人处理
            if(getSuccessor() != null)
            {
                return getSuccessor().handleFeeRequest(user, fee);
            }
        }
        return str;
    }
}
public class DeptManager extends Handler {

    @Override
    public String handleFeeRequest(String user, double fee) {
        
        String str = "";
        //部门经理的权限只能在1000以内
        if(fee < 1000)
        {
            //为了测试，简单点，只同意张三的请求
            if("张三".equals(user))
            {
                str = "成功：部门经理同意【" + user + "】的聚餐费用，金额为" + fee + "元";    
            }else
            {
                //其他人一律不同意
                str = "失败：部门经理不同意【" + user + "】的聚餐费用，金额为" + fee + "元";
            }
        }else
        {
            //超过1000，继续传递给级别更高的人处理
            if(getSuccessor() != null)
            {
                return getSuccessor().handleFeeRequest(user, fee);
            }
        }
        return str;
    }
}
public class GeneralManager extends Handler {

    @Override
    public String handleFeeRequest(String user, double fee) {
        
        String str = "";
        //总经理的权限很大，只要请求到了这里，他都可以处理
        if(fee >= 1000)
        {
            //为了测试，简单点，只同意张三的请求
            if("张三".equals(user))
            {
                str = "成功：总经理同意【" + user + "】的聚餐费用，金额为" + fee + "元";    
            }else
            {
                //其他人一律不同意
                str = "失败：总经理不同意【" + user + "】的聚餐费用，金额为" + fee + "元";
            }
        }else
        {
            //如果还有后继的处理对象，继续传递
            if(getSuccessor() != null)
            {
                return getSuccessor().handleFeeRequest(user, fee);
            }
        }
        return str;
    }

}
public class Client {

    public static void main(String[] args) {
        //先要组装责任链
        Handler h1 = new GeneralManager();
        Handler h2 = new DeptManager();
        Handler h3 = new ProjectManager();
        h3.setSuccessor(h2);
        h2.setSuccessor(h1);
        
        //开始测试
        String test1 = h3.handleFeeRequest("张三", 300);
        System.out.println("test1 = " + test1);
        String test2 = h3.handleFeeRequest("李四", 300);
        System.out.println("test2 = " + test2);
        System.out.println("---------------------------------------");
        
        String test3 = h3.handleFeeRequest("张三", 700);
        System.out.println("test3 = " + test3);
        String test4 = h3.handleFeeRequest("李四", 700);
        System.out.println("test4 = " + test4);
        System.out.println("---------------------------------------");
        
        String test5 = h3.handleFeeRequest("张三", 1500);
        System.out.println("test5 = " + test5);
        String test6 = h3.handleFeeRequest("李四", 1500);
        System.out.println("test6 = " + test6);
    }

}

 

 运行结果如下所示：