〇、小故事
小王最近参与了公司一个大项目，工作很忙，经常加班熬夜，满负荷工作了2个月后，项目终于如期上线，并且客户反馈也特别的好。老板很开心，知道大家为这个项目付出了很多，所以给全组同事都放了1个星期的假。
小王在项目期间也经常因为饮食不规范而导致胃疼，最近也越来越严重了。所以他就想趁着这个假期时间去医院检查一下身体。
他来到医院的挂号处，首先缴费挂号，挂了一个检查胃部的诊室。
小王按照挂号信息，来到了诊室，医生简单的询问了一下他的病情，然后给他开了几个需要检查的单子。
小王带着医生开具的检查单，就在医院的收费处排队等待着缴费。
缴费完毕后，小王就按照医生开的检查项目进行了身体检查……
那么从上面小王的一系列看病流程我们可以发现，这是一系列的处理过程，跟链条一样，即：
挂号——>开检查单——>缴费——>检查——>……
那么对于类似这种的业务逻辑，我们就可以使用一种设计模式来处理，即今天要介绍的——责任链模式。
一、模式定义
责任链模式（Chain of Responsibility Pattern）
使多个对象都有机会处理请求，从而避免了请求的发送者和接受者之间的耦合关系。将这些对象连成一条链，并沿着这条链传递该请求，直到有对象处理它为止。
二、模式类图
下面我们再举一个例子，一家公司收到了好多的电子邮件，其中大致分为四类：
【CEO处理】公司
粉丝发来的邮件。【法律部门处理】
诽谤公司产品的邮件。【业务部门处理】要求业务
合作的邮件。【直接丢弃】其他
垃圾邮件。
这里需要CEO先查阅邮件处理，然后再由法务部处理，随后是业务部处理，最后是垃圾邮件执行废弃。根据以上的描述，我们首先需要邮件实体类Email，和用于区分不同处理方式的邮件类型EmailType。对于所有处理者，我们首先创建一个抽象的处理器类AbstractProcessor，再创建四个处理器的实现类，分别是CEO处理器CeoProcessor、法务部门处理器LawProcessor、业务部门处理器BusinessProcessor和垃圾邮件处理器GarbageProcessor。具体类关系如下图所示：
三、模式实现
创建邮件实体类：Email.java
@Data @NoArgsConstructor @AllArgsConstructor public class Email { // 邮件类型 private int type; // 邮件内容 private String content; }
创建邮件类型枚举类：EmailType.java
public enum EmailType { FANS_EMAIL(1, "粉丝邮件"), SLANDER_EMAIL(2, "诽谤邮件"), COOPERATE_EMAIL(3, "业务合作邮件"), GARBAGE_EMAIL(99, "垃圾邮件"); public int type; public String remark; EmailType(int type, String remark) { this.type = type; this.remark = remark; } }
创建抽象处理类：AbstractProcessor.java
public abstract class AbstractProcessor { // 责任链中下一个处理节点 private AbstractProcessor nextProcessor; // 返回的处理结果 private String result; public final String handleMessage(List<Email> emails) { List<Email> filterEmails = emails.stream().filter(email -> email.getType() == this.emailType()).collect(Collectors.toList()); result = this.execute(filterEmails); if (this.nextProcessor == null) { return result; } return this.nextProcessor.handleMessage(emails); } // 设置责任链的下一个处理器 public void setNextProcessor(AbstractProcessor processor) { this.nextProcessor = processor; } // 获得当前Processor可以处理的邮件类型 protected abstract int emailType(); // 具体处理方法 protected abstract String execute(List<Email> emails); }
创建CEO处理类：CeoProcessor.java
public class CeoProcessor extends AbstractProcessor { @Override protected int emailType() { return EmailType.FANS_EMAIL.type; // 处理粉丝来的邮件 } @Override protected String execute(List<Email> emails) { if (CollectionUtils.isNotEmpty(emails)) { System.out.println("-------CEO开始处理邮件-------"); emails.stream().forEach(email -> System.out.println(email.getContent())); } return "任务执行完毕！"; } }
创建法律部门处理类：LawProcessor.java
public class LawProcessor extends AbstractProcessor { @Override protected int emailType() { return EmailType.SLANDER_EMAIL.type; // 处理诽谤类型的邮件 } @Override protected String execute(List<Email> emails) { if (CollectionUtils.isNotEmpty(emails)) { System.out.println("-------法律部门开始处理邮件-------"); emails.stream().forEach(email -> System.out.println(email.getContent())); } return "任务执行完毕！"; } }
创建业务部门处理类：BusinessProcessor.java
public class BusinessProcessor extends AbstractProcessor { @Override protected int emailType() { return EmailType.COOPERATE_EMAIL.type; // 处理合作类型的邮件 } @Override protected String execute(List<Email> emails) { if (CollectionUtils.isNotEmpty(emails)) { System.out.println("-------业务部门开始处理邮件-------"); emails.stream().forEach(email -> System.out.println(email.getContent())); } return "任务执行完毕！"; } }
创建垃圾邮件处理类：GarbageProcessor.java
public class GarbageProcessor extends AbstractProcessor { @Override protected int emailType() { return EmailType.GARBAGE_EMAIL.type; // 处理垃圾类型邮件 } @Override protected String execute(List<Email> emails) { if (CollectionUtils.isNotEmpty(emails)) { System.out.println("-------垃圾开始处理邮件-------"); emails.stream().forEach(email -> System.out.println(email.getContent())); } return "任务执行完毕！"; } }
创建责任链模式测试类：ChainTest.java
public class ChainTest { // 初始化待处理邮件 private static List<Email> emails = Lists.newArrayList( new Email(EmailType.FANS_EMAIL.type, "我是粉丝A"), new Email(EmailType.COOPERATE_EMAIL.type, "我要找你们合作"), new Email(EmailType.GARBAGE_EMAIL.type, "我是垃圾邮件"), new Email(EmailType.FANS_EMAIL.type, "我是粉丝B")); public static void main(String[] args) { // 初始化处理类 AbstractProcessor ceoProcessor = new CeoProcessor(); AbstractProcessor lawProcessor = new LawProcessor(); AbstractProcessor businessProcessor = new BusinessProcessor(); AbstractProcessor garbageProcessor = new GarbageProcessor(); // 设置责任链条 ceoProcessor.setNextProcessor(lawProcessor); lawProcessor.setNextProcessor(businessProcessor); businessProcessor.setNextProcessor(garbageProcessor); // 开始处理邮件 ceoProcessor.handleMessage(emails); } }
执行后的结果：
-------CEO开始处理邮件------- 我是粉丝A 我是粉丝B -------业务部门开始处理邮件------- 我要找你们合作 -------垃圾开始处理邮件------- 我是垃圾邮件 Process finished with exit code 0
今天的文章内容就这些了：
写作不易，笔者几个小时甚至数天完成的一篇文章，只愿换来您几秒钟的 点赞 & 分享 。
更多技术干货，欢迎大家关注公众号“爪哇缪斯” ~ \(^o^)/ ~ 「干货分享，每天更新」
