当前位置: 首页 > news >正文

深度剖析责任链模式

一、责任链模式的本质:灵活可扩展的流水线处理

责任链模式(Chain of Responsibility Pattern)是行为型设计模式的代表,其核心思想是将请求的发送者与接收者解耦,允许多个对象都有机会处理请求。这种模式完美解决了以下场景痛点:

  1. 动态流程编排:审批流程、风控流程等需要灵活调整顺序

  2. 请求分发机制:日志处理、权限校验等需要多层级过滤

  3. 未知处理者:异常捕获链、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或深拷贝上下文

 

相关文章:

深度剖析责任链模式

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

基于 openEuler 构建 LVS-DR 群集

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

CSS3+动画

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

使用DeepSeek和Kimi快速自动生成PPT

目录 步骤1&#xff1a;在DeepSeek中生成要制作的PPT主要大纲内容。 &#xff08;1&#xff09;在DeepSeek网页端生成 &#xff08;2&#xff09;在本地部署DeepSeek后&#xff0c;使用chatBox生成PPT内容 步骤2&#xff1a;将DeepSeek成的PPT内容复制到Kimi中 步骤3&…...

DeepSeek使用最佳实践

一、核心使用原则 任务结构化设计 明确目标&#xff1a;例如用“我需要生成包含5个功能的Python计算器代码”而非简单“帮我写代码”。分步拆解&#xff1a;复杂任务可拆成“需求分析->框架搭建->代码生成->测试验证”等阶段。格式约束&#xff1a;明确输出格式&…...

机器学习 - 进一步理解最大似然估计和高斯分布的关系

一、高斯分布得到的是一个概率吗&#xff1f; 高斯分布&#xff08;也称为正态分布&#xff09;描述的是随机变量在某范围内取值的概率分布情况。其概率密度函数&#xff08;PDF&#xff09;为&#xff1a; 其中&#xff0c;μ 是均值&#xff0c;σ 是标准差。 需要注意的是…...

Oracle常用导元数据方法

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

linux安装jdk 许可证确认 user did not accept the oracle-license-v1-1 license

一定要接受许可证&#xff0c;不然会出现 一、添加 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大模型 本篇文章是对使用文心一言大模型的使用总结 前置任务 在百度智能云开放平台中注册成为开发者 百度智能云开放平台 进入百度智能云官网进行登录&#xff0c;点击立即体验 点击千帆大模型平台 向下滑动&#xff0c;进入到模型…...

【Elasticsearch】derivative聚合

1.定义与用途 derivative聚合是一种管道聚合&#xff08;pipeline aggregation&#xff09;&#xff0c;用于计算指定度量&#xff08;metric&#xff09;的变化率。它通过计算当前值与前一个值之间的差异来实现这一点。这种聚合特别适用于分析时间序列数据&#xff0c;例如监…...

4.7.KMP算法(新版)

一.回顾&#xff1a;KMP算法基于朴素模式匹配算法优化而得来的 朴素模式匹配算法核心思想&#xff1a;把主串中所有长度与模式串长度相等的子串与模式串进行对比&#xff0c;直到找到第一个完全匹配的子串为止&#xff0c;如果当前尝试匹配的子串在某一个位置匹配失败&#xf…...

iOS AES/CBC/CTR加解密以及AES-CMAC

感觉iOS自带的CryptoKit不好用&#xff0c;有个第三方库CryptoSwift还不错&#xff0c;好巧不巧&#xff0c;清理过Xcode缓存后死活下载不下来&#xff0c;当然也可以自己编译个Framework&#xff0c;但是偏偏不想用第三方库了&#xff0c;于是研究了一下&#xff0c;自带的Com…...

错误报告:WebSocket 设备连接断开处理问题

错误报告&#xff1a;WebSocket 设备连接断开处理问题 项目背景 设备通过自启动的客户端连接到服务器&#xff0c;服务器将设备的 mac_address 和设备信息存入 Redis。前端通过 Redis 接口查看设备信息并展示。 问题描述 设备连接到服务器后&#xff0c;前端无法立即看到设…...

点云配准网络

【论文笔记】点云配准网络 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单片机俄罗斯方块整行消除函数

/************************************************************************************************************** * 名称&#xff1a;flash * 功能&#xff1a;行清除动画 * 参数&#xff1a;NULL * 返回&#xff1a;NULL * 备注&#xff1a; * 采用非阻塞延时&#xff0…...

Vue 3 30天精进之旅:Day 21 - 项目实践:打造功能完备的Todo应用

前言 经过前20天的学习&#xff0c;我们已经掌握了Vue 3的核心概念、组合式API、路由、状态管理等关键技术。今天将通过一个完整的项目实践——Todo应用&#xff0c;将所学知识融会贯通。我们将为Todo应用添加编辑、删除、过滤等进阶功能&#xff0c;并优化代码结构。 一、项目…...

32单片机学习记录1之GPIO

32单片机学习记录1之GPIO 前置 GPIO口在单片机中扮演着什么角色&#xff1f; 在单片机中&#xff0c;GPIO口&#xff08;General Purpose Input/Output&#xff09; 是一种通用输入/输出接口&#xff0c;扮演着连接单片机与外部设备的桥梁角色。具体来说&#xff0c;它在单片…...

AI 编程助手 Cline

Cline 是一款集成于 Visual Studio Code&#xff08;VS Code&#xff09;的 AI 编程助手&#xff0c;旨在提升开发者的编程效率和代码质量。 主要功能&#xff1a; 代码生成与补全&#xff1a;Cline 能根据开发者的输入&#xff0c;自动生成代码片段或完整的函数&#xff0c;减…...

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&#xff5c;GIF 解析与构建&#xff08;5&#xff09;&#xff1a;手搓截屏和帧率控制 一、引言 二、技术实现&#xff1a;手搓截屏模块 2.1 核心原理 2.2 代码解析&#xff1a;ScreenshotData类 2.2.1 截图函数&#xff1a;capture_screen 三、技术实现&…...

智慧医疗能源事业线深度画像分析(上)

引言 医疗行业作为现代社会的关键基础设施,其能源消耗与环境影响正日益受到关注。随着全球"双碳"目标的推进和可持续发展理念的深入,智慧医疗能源事业线应运而生,致力于通过创新技术与管理方案,重构医疗领域的能源使用模式。这一事业线融合了能源管理、可持续发…...

论文解读:交大港大上海AI Lab开源论文 | 宇树机器人多姿态起立控制强化学习框架(二)

HoST框架核心实现方法详解 - 论文深度解读(第二部分) 《Learning Humanoid Standing-up Control across Diverse Postures》 系列文章: 论文深度解读 + 算法与代码分析(二) 作者机构: 上海AI Lab, 上海交通大学, 香港大学, 浙江大学, 香港中文大学 论文主题: 人形机器人…...

(二)TensorRT-LLM | 模型导出(v0.20.0rc3)

0. 概述 上一节 对安装和使用有个基本介绍。根据这个 issue 的描述&#xff0c;后续 TensorRT-LLM 团队可能更专注于更新和维护 pytorch backend。但 tensorrt backend 作为先前一直开发的工作&#xff0c;其中包含了大量可以学习的地方。本文主要看看它导出模型的部分&#x…...

鸿蒙中用HarmonyOS SDK应用服务 HarmonyOS5开发一个医院挂号小程序

一、开发准备 ​​环境搭建​​&#xff1a; 安装DevEco Studio 3.0或更高版本配置HarmonyOS SDK申请开发者账号 ​​项目创建​​&#xff1a; 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中&#xff0c;给视频添加音频和字幕可以使用电影文件处理库MoviePy和字幕处理库Subtitles。下面将详细介绍如何使用这些库来实现视频的音频和字幕添加&#xff0c;包括必要的代码示例和详细解释。 环境准备 在开始之前&#xff0c;需要安装以下Python库&#xff1a;…...

全志A40i android7.1 调试信息打印串口由uart0改为uart3

一&#xff0c;概述 1. 目的 将调试信息打印串口由uart0改为uart3。 2. 版本信息 Uboot版本&#xff1a;2014.07&#xff1b; Kernel版本&#xff1a;Linux-3.10&#xff1b; 二&#xff0c;Uboot 1. sys_config.fex改动 使能uart3(TX:PH00 RX:PH01)&#xff0c;并让boo…...

2023赣州旅游投资集团

单选题 1.“不登高山&#xff0c;不知天之高也&#xff1b;不临深溪&#xff0c;不知地之厚也。”这句话说明_____。 A、人的意识具有创造性 B、人的认识是独立于实践之外的 C、实践在认识过程中具有决定作用 D、人的一切知识都是从直接经验中获得的 参考答案: C 本题解…...