责任链模式

Bummon2023-06-16

责任链模式

一、定义

摘自百度百科： 在责任链模式里，很多对象由每一个对象对其下家的引用而连接起来形成一条链。请求在这个链上传递，直到链上的某一个对象决定处理此请求。发出这个请求的客户端并不知道链上的哪一个对象最终处理这个请求，这使得系统可以在不影响客户端的情况下动态地重新组织和分配责任。

点击查看源码

二、角色分类

抽象处理者（Handler）

定义了处理请求的接口或者抽象类，并提供了处理请求的的方法和设置下一个处理者的方法

具体处理者（Concrete Handler）

它是抽象处理者的子类，可以处理用户请求，在具体处理者类中实现了抽象处理者中定义的抽象请求处理方法，在处理请求之前需要进行判断，看是否有相应的处理权限，如果可以处理请求就处理它，否则将请求转发给后继者；在具体处理者中可以访问链中下一个对象，以便请求的转发

客户角色（Client）

具体调用方法的角色

三、实现方式

UML图

未命名文件 (3)

具体实现

假如我们想用责任链模式实现一个请假流程，可以这么来实现

抽象处理者（Handler）

@Data
public abstract class Handler {
  // 处理者姓名
  protected String processorName;
  // 下一个处理者
  protected Handler nextHandler

  public Handler (String processorName) {
    this.processorName = processorName;
  }

  /**
   * 处理请假抽象方法
   * @param name 请假人姓名
   * @param numOfDays 请假天数
   */
  public abstract boolean process(String name, int numOfDays);
}

具体处理者（Concrete Handler）

/**
 * 组长
 */
@Slf4j
public class TeamLeaderHandler extends Handler {
  public TeamLeaderHandler(String processorName) {
    this.processorName = processorName;
  }

  @Override
  public boolean process(String name, int numOfDays) {
    // 创建随机数，值大于3则为通过，否则为不通过
    boolean res = (new Random().nextInt(10)) > 3;
    String result = res ? "通过" : "驳回";
    log.info("组长<{}>审批<{}>的请假申请，请假天数为：<{}>天，审批结果为：<{}>", processorName, name, numOfDays, result);

    if(Boolean.FALSE.equals(res)) {
      // 审批驳回
      return false;
    } else if (numOfDays < 3){
      // 请假通过且请假天数小于3天时直接通过
      return true;
    }
    // 若审批通过且请假天数大于等于3天时提交给下一个审批人
    return nextHandler.process(name, numOfDays);
  }
}

/**
 * 部门经理
 */
@Slf4j
public class DepartmentManagerHandler extends Handler {
  public DepartmentManagerHandler(String processorName) {
    super(name);
  }

  @Override
  public boolean process(String name, int numOfDays) {
    // 创建一个随机数 当随机数大于3时为通过，否则为不通过
    boolean res = (new Random().nextInt(10)) > 3;
    String result = res ? "通过" : "驳回";
    log.info("部门经理<{}>审批<{}>的请假申请，请假天数为：<{}>天，审批结果为：<{}>", processorName, name, numOfDays, result);

    if(Boolean.FALSE.equals(res)) {
      // 审批驳回
      return false;
    } else if (numOfDays <7) {
      // 审批通过且审批天数小于7天时直接通过
      return true;
    }
    // 批准天数大于等于7天时提交给下一个审批人
    return nextHandler.process(name, numOfDays);
  }

  /**
   * CEO
   */
  @Slf4j
  public class CEOHandler extends Handler {
    public CEOHandler(String processorName) {
      super(name);
    }

    public boolean process(String name, int numOfDays) {
      // 创建一个随机数，大于3则为通过，否则为驳回
      boolean res = (new Random().nextInt(10)) > 3;
      String result = res ? "通过" : "驳回";
      log.info("CEO<{}>审批<{}>的请假申请，请假天数为：<{}>天，审批结果为：<{}>", processorName, name, numOfDays, result);

      if(Boolean.FALSE.equals(res)) {
        //驳回
        return false;
      }
      return true;
    } 
  } 
}

客户角色（Client）

public class Client {
  public static void main(String[] args) {
        Handler zhangsan = new TeamLeaderHandler("张三");
        Handler lisi = new DepartmentManagerHandler("李四");
        Handler wangwu = new CEOHandler("王五");

        // 创建责任链
        zhangsan.setNextHandler(lisi);
        lisi.setNextHandler(wangwu);

        // 发起请假申请
        boolean res1 = zhangsan.leave("小A", 2);
        System.out.println("最终结果：" + res1);

        boolean res2 = zhangsan.leave("小B", 5);
        System.out.println("最终结果：" + res2);

        boolean res3 = zhangsan.leave("小C", 10);
        System.out.println("最终结果：" + res3);
    }
}

运行结果

组长<张三>审批<小A>的请假申请，请假天数为：<2>天，审批结果为：<通过>
最终结果：true

部门经理<李四> 审批 <小B> 的请假申请，请假天数： <5>天 ，审批结果：<不通过> 
最终结果：false

组长<张三> 审批 <小C> 的请假申请，请假天数： <10> 天，审批结果：<通过> 
部门经理<李四> 审批 <小C> 的请假申请，请假天数： <10> 天，审批结果：<通过> 
CEO<王五> 审批 <小C> 的请假申请，请假天数： <10> 天，审批结果：<通过> 
最终结果：true