深度剖析责任链模式
一、责任链模式的本质:灵活可扩展的流水线处理
责任链模式(Chain of Responsibility Pattern)是行为型设计模式的代表,其核心思想是将请求的发送者与接收者解耦,允许多个对象都有机会处理请求。这种模式完美解决了以下场景痛点:
-
动态流程编排:审批流程、风控流程等需要灵活调整顺序
-
请求分发机制:日志处理、权限校验等需要多层级过滤
-
未知处理者:异常捕获链、HTTP中间件等场景
UML类图:
二、责任链模式的三种经典实现
1. 基础链表实现(传统方式)
// 处理器接口 public interface OrderHandler {void handle(Order order);void setNext(OrderHandler next); }// 抽象基类 public abstract class AbstractOrderHandler implements OrderHandler {private OrderHandler next;@Overridepublic void setNext(OrderHandler next) {this.next = next;}protected void handleNext(Order order) {if (next != null) {next.handle(order);}} }// 具体处理器 public class InventoryCheckHandler extends AbstractOrderHandler {@Overridepublic void handle(Order order) {if (!checkInventory(order)) {throw new RuntimeException("库存不足");}System.out.println("库存校验通过");handleNext(order);}private boolean checkInventory(Order order) {// 库存检查逻辑return true;} }public class PaymentHandler extends AbstractOrderHandler {@Overridepublic void handle(Order order) {processPayment(order);System.out.println("支付处理完成");handleNext(order);}private void processPayment(Order order) {// 支付处理逻辑} }
2. 集合迭代实现(Spring风格)
// 处理器接口 public interface Filter {void doFilter(Request request, Response response, FilterChain chain); }// 链式调用容器 public class FilterChain {private List<Filter> filters = new ArrayList<>();private int index = 0;public FilterChain addFilter(Filter filter) {filters.add(filter);return this;}public void doFilter(Request request, Response response) {if (index < filters.size()) {Filter filter = filters.get(index++);filter.doFilter(request, response, this);}} }// 使用示例 FilterChain chain = new FilterChain().addFilter(new AuthFilter()).addFilter(new LogFilter()).addFilter(new EncodingFilter()); chain.doFilter(request, response);
3. 注解驱动实现(企业级方案)
// 自定义注解 @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.TYPE) public @interface OrderProcessor {int order() default 0;String[] supportType(); }// 处理器基类 public abstract class BaseOrderProcessor {@Autowiredprivate ProcessorChain chain;public void process(OrderContext context) {if (canProcess(context)) {doProcess(context);}chain.process(context);}protected abstract boolean canProcess(OrderContext context);protected abstract void doProcess(OrderContext context); }// 具体处理器 @OrderProcessor(order = 1, supportType = "NORMAL") public class NormalOrderProcessor extends BaseOrderProcessor {@Overrideprotected boolean canProcess(OrderContext context) {return "NORMAL".equals(context.getOrderType());}@Overrideprotected void doProcess(OrderContext context) {// 普通订单处理逻辑} }
三、责任链模式的五大应用场景
场景1:审批流程系统
-
请假审批链(组长 → 经理 → 总监)
-
采购审批链(金额分级审批)
-
合同审批链(法务 → 财务 → CEO)
场景2:Web请求处理
-
Servlet Filter链
-
Spring Interceptor链
-
网关过滤器链(限流 → 鉴权 → 日志)
场景3:订单处理系统
-
订单校验链(库存 → 优惠券 → 地址)
-
订单履约链(拆单 → 分配仓库 → 物流)
场景4:异常处理系统
-
异常捕获链(业务异常 → 系统异常 → 全局异常)
-
错误恢复链(重试 → 降级 → 告警)
场景5:游戏事件处理
-
技能释放链(蓝量检查 → CD检查 → 效果触发)
-
伤害计算链(防御计算 → 暴击计算 → 元素反应)
四、责任链模式与相关模式对比
模式 | 关注点 | 与责任链的区别 |
---|---|---|
装饰器模式 | 增强对象功能 | 责任链强调传递,装饰器强调叠加功能 |
命令模式 | 请求封装 | 责任链处理请求传递,命令模式处理请求封装与执行 |
组合模式 | 树形结构 | 责任链是线性结构,组合模式是树状结构 |
策略模式 | 算法替换 | 责任链多个处理器协作,策略模式单个算法替换 |
五、企业级实战:Spring风格审批系统
架构设计
[审批请求] → [审批链构建器] → [审批处理器1] → [审批处理器2] → [...] → [审批完成]↑[审批规则配置中心]↑[数据库/配置中心]
完整代码实现
// 审批处理器接口 public interface ApprovalHandler {ApprovalResult handle(ApprovalContext context);void setNext(ApprovalHandler next);boolean support(ApprovalType type); }// 链式处理器基类 public abstract class AbstractApprovalHandler implements ApprovalHandler {private ApprovalHandler next;private ApprovalType supportType;protected AbstractApprovalHandler(ApprovalType supportType) {this.supportType = supportType;}@Overridepublic void setNext(ApprovalHandler next) {this.next = next;}@Overridepublic ApprovalResult handle(ApprovalContext context) {if (!support(context.getType())) {return next.handle(context);}ApprovalResult result = doHandle(context);if (result.isApproved() && next != null) {return next.handle(context);}return result;}@Overridepublic boolean support(ApprovalType type) {return this.supportType == type;}protected abstract ApprovalResult doHandle(ApprovalContext context); }// 具体审批处理器 public class DepartmentManagerHandler extends AbstractApprovalHandler {public DepartmentManagerHandler() {super(ApprovalType.DEPARTMENT_MANAGER);}@Overrideprotected ApprovalResult doHandle(ApprovalContext context) {// 部门经理审批逻辑return new ApprovalResult(true, "部门经理审批通过");} }// 审批链构建工厂 @Service public class ApprovalChainFactory {@Autowiredprivate List<ApprovalHandler> handlers;public ApprovalHandler createChain(ApprovalType type) {List<ApprovalHandler> sortedHandlers = handlers.stream().filter(h -> h.support(type)).sorted(Comparator.comparingInt(h -> h.getOrder())).collect(Collectors.toList());ApprovalHandler head = null;ApprovalHandler current = null;for (ApprovalHandler handler : sortedHandlers) {if (head == null) {head = handler;current = handler;} else {current.setNext(handler);current = handler;}}return head;} }
六、责任链模式的五大优化技巧
1. 动态配置链顺序
// 基于配置文件的链定义 @Configuration public class ChainConfig {@Beanpublic FilterChain securityFilterChain() {return new FilterChain().addFilter(new CorsFilter()).addFilter(new AuthFilter()).addFilter(new RateLimitFilter());} }
2. 中断机制优化
public interface Handler {enum Result {CONTINUE, BREAK}Result handle(Request request); }public class Chain {public void process(Request request) {for (Handler handler : handlers) {if (handler.handle(request) == Result.BREAK) {return;}}} }
3. 性能监控埋点
public class MonitoredHandler implements Handler {private final Handler delegate;private final MeterRegistry registry;public MonitoredHandler(Handler delegate, MeterRegistry registry) {this.delegate = delegate;this.registry = registry;}@Overridepublic Result handle(Request request) {Timer.Sample sample = Timer.start(registry);try {return delegate.handle(request);} finally {sample.stop(registry.timer("handler.time", "handler", delegate.getClass().getSimpleName()));}} }
七、常见陷阱与解决方案
陷阱 | 现象 | 解决方案 |
---|---|---|
循环引用 | 链式调用死循环 | 增加最大调用深度检测 |
处理器遗漏 | 请求未被任何处理器处理 | 设置默认处理器或抛出明确异常 |
顺序依赖错误 | 处理器执行顺序不符合预期 | 使用优先级注解明确顺序 |
性能瓶颈 | 长链路导致延迟过高 | 引入异步处理或并行执行 |
状态污染 | 处理器之间共享可变状态 | 使用ThreadLocal或深拷贝上下文 |
相关文章:

深度剖析责任链模式
一、责任链模式的本质:灵活可扩展的流水线处理 责任链模式(Chain of Responsibility Pattern)是行为型设计模式的代表,其核心思想是将请求的发送者与接收者解耦,允许多个对象都有机会处理请求。这种模式完美解决了以下…...

基于 openEuler 构建 LVS-DR 群集
一、 对比 LVS 负载均衡群集的 NAT 模式和 DR 模式,比较其各自的优势 。 二、 基于 openEuler 构建 LVS-DR 群集。 一 NAT 模式 部署简单:NAT 模式下,所有的服务器节点只需要连接到同一个局域网内,通过负载均衡器进行网络地址转…...

CSS3+动画
浏览器内核以及其前缀 css标准中各个属性都要经历从草案到推荐的过程,css3中的属性进展都不一样,浏览器厂商在标准尚未明确的情况下提前支持会有风险,浏览器厂商对新属性的支持情况也不同,所有会加厂商前缀加以区分。如果某个属性…...

使用DeepSeek和Kimi快速自动生成PPT
目录 步骤1:在DeepSeek中生成要制作的PPT主要大纲内容。 (1)在DeepSeek网页端生成 (2)在本地部署DeepSeek后,使用chatBox生成PPT内容 步骤2:将DeepSeek成的PPT内容复制到Kimi中 步骤3&…...
DeepSeek使用最佳实践
一、核心使用原则 任务结构化设计 明确目标:例如用“我需要生成包含5个功能的Python计算器代码”而非简单“帮我写代码”。分步拆解:复杂任务可拆成“需求分析->框架搭建->代码生成->测试验证”等阶段。格式约束:明确输出格式&…...

机器学习 - 进一步理解最大似然估计和高斯分布的关系
一、高斯分布得到的是一个概率吗? 高斯分布(也称为正态分布)描述的是随机变量在某范围内取值的概率分布情况。其概率密度函数(PDF)为: 其中,μ 是均值,σ 是标准差。 需要注意的是…...

Oracle常用导元数据方法
1 说明 前两天领导发邮件要求导出O库一批表和索引的ddl语句做国产化测试,涉及6个系统,6千多张表,还好涉及的用户并不多,要不然很麻烦。 如此大费周折原因,是某国产库无法做元数据迁移。。。额,只能我手动导…...

linux安装jdk 许可证确认 user did not accept the oracle-license-v1-1 license
一定要接受许可证,不然会出现 一、添加 ppa第三方软件源 sudo add-apt-repository ppa:ts.sch.gr/ppa二、更新系统软件包列表 sudo apt-get update三、接受许可证 echo debconf shared/accepted-oracle-license-v1-1 select true | sudo debconf-set-selection…...

Spring基于文心一言API使用的大模型
有时做项目我们可能会遇到要在项目中对接AI大模型 本篇文章是对使用文心一言大模型的使用总结 前置任务 在百度智能云开放平台中注册成为开发者 百度智能云开放平台 进入百度智能云官网进行登录,点击立即体验 点击千帆大模型平台 向下滑动,进入到模型…...
【Elasticsearch】derivative聚合
1.定义与用途 derivative聚合是一种管道聚合(pipeline aggregation),用于计算指定度量(metric)的变化率。它通过计算当前值与前一个值之间的差异来实现这一点。这种聚合特别适用于分析时间序列数据,例如监…...

4.7.KMP算法(新版)
一.回顾:KMP算法基于朴素模式匹配算法优化而得来的 朴素模式匹配算法核心思想:把主串中所有长度与模式串长度相等的子串与模式串进行对比,直到找到第一个完全匹配的子串为止,如果当前尝试匹配的子串在某一个位置匹配失败…...
iOS AES/CBC/CTR加解密以及AES-CMAC
感觉iOS自带的CryptoKit不好用,有个第三方库CryptoSwift还不错,好巧不巧,清理过Xcode缓存后死活下载不下来,当然也可以自己编译个Framework,但是偏偏不想用第三方库了,于是研究了一下,自带的Com…...
错误报告:WebSocket 设备连接断开处理问题
错误报告:WebSocket 设备连接断开处理问题 项目背景 设备通过自启动的客户端连接到服务器,服务器将设备的 mac_address 和设备信息存入 Redis。前端通过 Redis 接口查看设备信息并展示。 问题描述 设备连接到服务器后,前端无法立即看到设…...
点云配准网络
【论文笔记】点云配准网络 PCRNet: Point Cloud Registration Network using PointNet Encoding 2019_pcr-net-CSDN博客 【点云配准】【深度学习】Windows11下PCRNet代码Pytorch实现与源码讲解-CSDN博客 【点云配准】【深度学习】Windows11下GCNet代码Pytorch实现与源码讲解_…...

黑马Redis详细笔记(实战篇---短信登录)
目录 一.短信登录 1.1 导入项目 1.2 Session 实现短信登录 1.3 集群的 Session 共享问题 1.4 基于 Redis 实现共享 Session 登录 一.短信登录 1.1 导入项目 数据库准备 -- 创建用户表 CREATE TABLE user (id BIGINT AUTO_INCREMENT PRIMARY KEY COMMENT 用户ID,phone …...
51单片机俄罗斯方块整行消除函数
/************************************************************************************************************** * 名称:flash * 功能:行清除动画 * 参数:NULL * 返回:NULL * 备注: * 采用非阻塞延时࿰…...
Vue 3 30天精进之旅:Day 21 - 项目实践:打造功能完备的Todo应用
前言 经过前20天的学习,我们已经掌握了Vue 3的核心概念、组合式API、路由、状态管理等关键技术。今天将通过一个完整的项目实践——Todo应用,将所学知识融会贯通。我们将为Todo应用添加编辑、删除、过滤等进阶功能,并优化代码结构。 一、项目…...

32单片机学习记录1之GPIO
32单片机学习记录1之GPIO 前置 GPIO口在单片机中扮演着什么角色? 在单片机中,GPIO口(General Purpose Input/Output) 是一种通用输入/输出接口,扮演着连接单片机与外部设备的桥梁角色。具体来说,它在单片…...
AI 编程助手 Cline
Cline 是一款集成于 Visual Studio Code(VS Code)的 AI 编程助手,旨在提升开发者的编程效率和代码质量。 主要功能: 代码生成与补全:Cline 能根据开发者的输入,自动生成代码片段或完整的函数,减…...
YOLOv11-ultralytics-8.3.67部分代码阅读笔记-patches.py
patches.py ultralytics\utils\patches.py 目录 patches.py 1.所需的库和模块 2.def imread(filename: str, flags: int cv2.IMREAD_COLOR): 3.def imwrite(filename: str, img: np.ndarray, paramsNone): 4.def imshow(winname: str, mat: np.ndarray): 5.PyTorch…...
Python|GIF 解析与构建(5):手搓截屏和帧率控制
目录 Python|GIF 解析与构建(5):手搓截屏和帧率控制 一、引言 二、技术实现:手搓截屏模块 2.1 核心原理 2.2 代码解析:ScreenshotData类 2.2.1 截图函数:capture_screen 三、技术实现&…...

智慧医疗能源事业线深度画像分析(上)
引言 医疗行业作为现代社会的关键基础设施,其能源消耗与环境影响正日益受到关注。随着全球"双碳"目标的推进和可持续发展理念的深入,智慧医疗能源事业线应运而生,致力于通过创新技术与管理方案,重构医疗领域的能源使用模式。这一事业线融合了能源管理、可持续发…...
论文解读:交大港大上海AI Lab开源论文 | 宇树机器人多姿态起立控制强化学习框架(二)
HoST框架核心实现方法详解 - 论文深度解读(第二部分) 《Learning Humanoid Standing-up Control across Diverse Postures》 系列文章: 论文深度解读 + 算法与代码分析(二) 作者机构: 上海AI Lab, 上海交通大学, 香港大学, 浙江大学, 香港中文大学 论文主题: 人形机器人…...

(二)TensorRT-LLM | 模型导出(v0.20.0rc3)
0. 概述 上一节 对安装和使用有个基本介绍。根据这个 issue 的描述,后续 TensorRT-LLM 团队可能更专注于更新和维护 pytorch backend。但 tensorrt backend 作为先前一直开发的工作,其中包含了大量可以学习的地方。本文主要看看它导出模型的部分&#x…...
鸿蒙中用HarmonyOS SDK应用服务 HarmonyOS5开发一个医院挂号小程序
一、开发准备 环境搭建: 安装DevEco Studio 3.0或更高版本配置HarmonyOS SDK申请开发者账号 项目创建: File > New > Create Project > Application (选择"Empty Ability") 二、核心功能实现 1. 医院科室展示 /…...
MVC 数据库
MVC 数据库 引言 在软件开发领域,Model-View-Controller(MVC)是一种流行的软件架构模式,它将应用程序分为三个核心组件:模型(Model)、视图(View)和控制器(Controller)。这种模式有助于提高代码的可维护性和可扩展性。本文将深入探讨MVC架构与数据库之间的关系,以…...
鸿蒙中用HarmonyOS SDK应用服务 HarmonyOS5开发一个生活电费的缴纳和查询小程序
一、项目初始化与配置 1. 创建项目 ohpm init harmony/utility-payment-app 2. 配置权限 // module.json5 {"requestPermissions": [{"name": "ohos.permission.INTERNET"},{"name": "ohos.permission.GET_NETWORK_INFO"…...
Python如何给视频添加音频和字幕
在Python中,给视频添加音频和字幕可以使用电影文件处理库MoviePy和字幕处理库Subtitles。下面将详细介绍如何使用这些库来实现视频的音频和字幕添加,包括必要的代码示例和详细解释。 环境准备 在开始之前,需要安装以下Python库:…...

全志A40i android7.1 调试信息打印串口由uart0改为uart3
一,概述 1. 目的 将调试信息打印串口由uart0改为uart3。 2. 版本信息 Uboot版本:2014.07; Kernel版本:Linux-3.10; 二,Uboot 1. sys_config.fex改动 使能uart3(TX:PH00 RX:PH01),并让boo…...
2023赣州旅游投资集团
单选题 1.“不登高山,不知天之高也;不临深溪,不知地之厚也。”这句话说明_____。 A、人的意识具有创造性 B、人的认识是独立于实践之外的 C、实践在认识过程中具有决定作用 D、人的一切知识都是从直接经验中获得的 参考答案: C 本题解…...