微网站预览,网站建设数据库配置,wordpress注册未发送邮件,网站开发域名注册功能摘要
责任链设计模式是一种行为设计模式#xff0c;通过链式调用将请求逐一传递给一系列处理器#xff0c;直到某个处理器处理了请求或所有处理器都未能处理。它解耦了请求的发送者和接收者#xff0c;允许动态地将请求处理职责分配给多个对象#xff0c;支持请求的灵活传…摘要
责任链设计模式是一种行为设计模式通过链式调用将请求逐一传递给一系列处理器直到某个处理器处理了请求或所有处理器都未能处理。它解耦了请求的发送者和接收者允许动态地将请求处理职责分配给多个对象支持请求的灵活传递或中断。
1. 责任链设计模式是什么
1.1. 责任链设计模式
责任链模式理解就是遍历某一个接口下所有的实现类中方法。责任链模式的核心思想就是通过链式调用将请求逐一传递给一系列处理器实现了同一个接口的对象直到某个处理器处理了请求或者链中的所有处理器都未能处理该请求。
1.2. 责任链模式的基本工作原理
处理者链将多个处理者通常是实现了相同接口的类链接在一起每个处理者负责处理请求的一个特定方面。请求传递请求会沿着责任链传递每个处理者都会判断是否能够处理该请求处理后返回或继续传递给下一个处理者。终止条件如果某个处理者能够处理该请求链条上后续的处理者通常会被跳过直接返回处理结果如果没有处理者能处理最终请求可能会失败。
1.3. 简化的责任链模式结构
可以把责任链模式理解为
链表结构每个节点处理器持有对下一个节点的引用依次处理请求。处理器接口每个节点实现一个接口负责具体的处理逻辑。
责任链模式Chain of Responsibility Pattern与 装饰器模式Decorator Pattern 和 迭代器模式Iterator Pattern 在某些方面有相似之处但它们的核心思想和使用场景略有不同。 特性 责任链模式 装饰器模式 目的 解耦请求的发送者和接收者将请求交给多个处理者逐一处理 动态为对象添加功能增强其行为 结构 请求按链式结构传递每个处理者持有下一个处理者的引用 对原对象进行包装增加额外功能 请求传递 请求沿着责任链传递直到某个处理器处理请求或链终止 不传递请求直接在原对象上增强功能 设计模式重点 请求处理的顺序和中断条件控制 通过包装原对象来动态增加功能 典型应用场景 多个处理器顺序处理请求逐个判断并决定是否处理 动态为对象添加行为功能扩展而不修改原对象代码 耦合性 请求发送者与接收者解耦减少了依赖关系 可以灵活地为对象添加功能扩展类的功能而不修改其代码 责任 每个处理者负责部分请求处理逻辑 每个装饰器负责对原对象的功能扩展
1.4. 责任链设计模式的作用
请求传递每个处理者链上的对象都有一个引用指向下一个处理者。请求沿着链依次传递直到被某个处理者处理或链结束。解耦发送方无需直接与处理方耦合降低代码的复杂度。可扩展性可以灵活地添加、删除或修改链上的处理者而不影响整体结构。职责分离每个处理者只关注自己能处理的部分其余的请求传递给下一个处理者。
1.5. 责任链模式的优点
解耦请求与处理者请求方不需要知道具体处理者是谁降低耦合。动态组合职责链可以灵活地增加、删除或重排链中的处理节点。代码清晰将复杂的逻辑分解到多个处理节点中职责单一。
1.6. 责任链模式的缺点
性能开销当责任链过长时可能带来性能问题。调试困难请求处理链条较长时调试排查问题可能变得复杂。不保证请求被处理如果没有合适的处理者可能导致请求最终未被处理。执行链是有默认的顺序可以借助Spring中Order注解来实现有序
2. 责任链模式类图实现 2.1. 责任链模式的结构
责任链模式主要包含以下角色
Handler处理者抽象类/接口 定义处理请求的接口并存储下一个处理者的引用。
ConcreteHandler具体处理者 继承或实现 Handler处理它负责的请求。如果无法处理则将请求转发给下一个处理者。
Client客户端 创建责任链并向链头发出请求。
3. 责任链模式使用场景
3.1. 多级请求处理
当一个请求需要经过多个对象处理且不明确具体是由哪个对象处理时。示例 日志系统根据日志级别DEBUG、INFO、WARN、ERROR动态决定由哪个日志处理器处理。审批流如贷款审批流程依次经过组长、经理、总监的审批。
3.2. 请求处理职责动态变化
处理职责可能会随时增减且希望能灵活调整处理顺序。示例风控规则引擎新增或调整规则处理节点时动态维护责任链。
3.3. 避免请求发送者与接收者耦合
当请求发送者不需要知道接收者的具体实现时可以通过责任链解耦。示例支付系统如多种支付渠道银行卡、第三方支付、余额支付按优先级尝试支付。
3.4. 请求的处理逻辑可以被分解
请求的处理逻辑非常复杂且可以拆分成多个步骤时每个步骤都可以成为责任链上的一个节点。示例HTTP 请求拦截器如在请求到达服务器前依次经过身份认证、权限验证、数据校验等。
3.5. 需要支持请求的灵活传递或中断
某个处理器完成后可以继续传递给下一个处理器也可以选择中止传递。示例事件处理机制如 Java 的事件监听器事件沿着监听器链依次传递直到某个监听器处理完成。
3.6. 责任链具体场景示例
3.6.1. 风控规则链
在信贷风控中每个用户的申请需要经过一系列的规则检查例如
身份证校验黑名单检测信用评分计算额度限制校验
这些规则可以按顺序依次处理或者某个规则失败时中断处理。
3.6.2. API 请求过滤
如在微服务架构中API 请求经过以下责任链
身份验证拦截器参数校验拦截器权限检查拦截器日志记录拦截器
3.6.3. 异常处理链
多个异常处理器按顺序处理异常例如
数据库异常处理器网络异常处理器业务逻辑异常处理器 责任链可以逐级定位和处理异常。
3.6.4. 广告投放系统
按用户属性年龄、性别、兴趣动态匹配投放规则。若某规则不适用则传递给下一个规则。
4. 责任链模式示例Spring
在 Spring 中使用 责任链模式 并让链上的处理器由 Spring 容器管理可以通过以下方式实现利用 Spring 的 Component 注解 配合 自动注入Autowired 或者通过 Order 注解 实现责任链的顺序化管理。
4.1. 定义责任链接口
public interface Handler {boolean handle(Request request);
}
每个校验规则实现该接口handle 方法返回 true 代表校验通过false 代表校验失败。
4.2. 定义请求对象
Data
public class Request {private String userId;private int creditScore;private double loanAmount;// 其他字段...// Getter Setter
}
4.3. 创建具体的处理器
每个处理器节点实现 Handler 接口例如
4.3.1. 身份校验处理器
Component
public class IdentityValidationHandler implements Handler {Overridepublic boolean handle(Request request) {// 假设用户 ID 不能为空if (request.getUserId() null || request.getUserId().isEmpty()) {System.out.println(身份校验失败);return false;}System.out.println(身份校验通过);return true;}
}
4.3.2. 黑名单检测处理器
Component
public class BlacklistCheckHandler implements Handler {Overridepublic boolean handle(Request request) {// 假设用户 123 是黑名单用户if (123.equals(request.getUserId())) {System.out.println(黑名单校验失败);return false;}System.out.println(黑名单校验通过);return true;}
}
4.3.3. 信用评分校验处理器
public class CreditScoreCheckHandler implements Handler {Overridepublic boolean handle(Request request) {// 假设信用评分不能低于 600if (request.getCreditScore() 600) {System.out.println(信用评分校验失败);return false;}System.out.println(信用评分校验通过);return true;}
}
4.3.4. 额度检查处理器
Component
public class LoanAmountCheckHandler implements Handler {Overridepublic boolean handle(Request request) {// 假设贷款金额不能超过 50 万if (request.getLoanAmount() 500000) {System.out.println(额度检查失败);return false;}System.out.println(额度检查通过);return true;}
}
4.4. 责任链测试
package com.zhuangxiaoyan.hyxftest.chain;import com.zhuangxiaoyan.hyxftest.HyxfTestApplication;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;/*** chaintest** author xjl* version 2024/12/04 19:56**/SpringBootTest(classes HyxfTestApplication.class)
public class ChainTest {Autowiredprivate HandlerChain handlerChain;Testpublic void chainTest() {handlerChain.process(new Request(122222, 500, 10000));}
}
5. 博文参考
《软件设计模式》
