〇、小故事
小王最近参与了公司一个大项目，工作很忙，经常加班熬夜，满负荷工作了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
今天的文章内容就这些了