责任链模式：优雅处理复杂流程的设计艺术

引言

在软件设计中，我们经常会遇到需要按特定顺序处理请求的场景。例如，一个订单处理系统可能需要经过验证、付款、物流安排和客户通知等多个步骤。如果我们将这些步骤硬编码在一个方法中，代码将变得臃肿且难以维护。这时，责任链模式（Chain of Responsibility Pattern）就显示出了它的价值。

责任链模式是一种行为设计模式，它允许多个对象依次处理同一个请求，从而将请求的发送者与接收者解耦。本文将详细介绍责任链模式的核心概念、实现方法以及适用场景。

什么是责任链模式？

责任链模式是这样工作的：一个请求沿着一条预定义的对象链传递，直到有一个对象处理它或者请求到达链尾。每个处理者决定是自己处理请求还是将其传递给链中的下一个对象。

这种模式的美妙之处在于：请求的发送者不需要知道谁会处理这个请求，而每个处理者也只需要关注自己的职责，无需知道整个链的结构。

责任链模式的核心组件

抽象处理者(Handler): 定义了处理请求的接口，通常包含设置下一个处理者和处理请求的方法。
具体处理者(ConcreteHandler): 实现抽象处理者的接口，处理自己负责的请求，如果不能处理则传递给下一个处理者。
客户端(Client): 创建处理者对象并组成责任链，然后向链上的第一个处理者发送请求。

类图

下面是责任链模式的类图：

责任链模式的实现

让我们以一个订单处理系统为例，说明如何实现责任链模式：

1. 创建订单类

/*** 订单类 - 包含订单的基本信息和处理状态*/
public class Order {private int id;                  // 订单IDprivate double amount;           // 订单金额private String customerName;     // 客户名称private boolean isValidated;     // 订单是否已验证private boolean isPaymentProcessed; // 支付是否已处理private boolean isDeliveryArranged; // 配送是否已安排private boolean isNotificationSent;  // 通知是否已发送/*** 订单构造函数* @param id 订单ID* @param amount 订单金额* @param customerName 客户名称*/public Order(int id, double amount, String customerName) {this.id = id;this.amount = amount;this.customerName = customerName;this.isValidated = false;this.isPaymentProcessed = false;this.isDeliveryArranged = false;this.isNotificationSent = false;}// Getters and setterspublic int getId() {return id;}public double getAmount() {return amount;}public String getCustomerName() {return customerName;}public boolean isValidated() {return isValidated;}public void setValidated(boolean validated) {isValidated = validated;}public boolean isPaymentProcessed() {return isPaymentProcessed;}public void setPaymentProcessed(boolean paymentProcessed) {this.isPaymentProcessed = paymentProcessed;}public boolean isDeliveryArranged() {return isDeliveryArranged;}public void setDeliveryArranged(boolean deliveryArranged) {this.isDeliveryArranged = deliveryArranged;}public boolean isNotificationSent() {return isNotificationSent;}public void setNotificationSent(boolean notificationSent) {this.isNotificationSent = notificationSent;}@Overridepublic String toString() {return "Order{" +"id=" + id +", amount=" + amount +", customerName='" + customerName + '\'' +", isValidated=" + isValidated +", isPaymentProcessed=" + isPaymentProcessed +", isDeliveryArranged=" + isDeliveryArranged +", isNotificationSent=" + isNotificationSent +'}';}
}

2. 创建处理器接口

/*** 订单处理器抽象类 - 责任链模式的核心* 定义了处理订单的通用接口和设置下一个处理器的方法*/
public abstract class OrderHandler {protected OrderHandler nextHandler; // 责任链中的下一个处理器/*** 设置责任链中的下一个处理器* @param nextHandler 下一个处理器*/public void setNextHandler(OrderHandler nextHandler) {this.nextHandler = nextHandler;}/*** 处理订单的抽象方法，由具体的处理器实现* @param order 要处理的订单*/public abstract void handleOrder(Order order);
}

3. 实现具体的处理器类

订单验证处理器

/*** 订单验证处理器 - 责任链的第一环* 负责验证订单的基本信息是否有效*/
public class OrderValidationHandler extends OrderHandler {@Overridepublic void handleOrder(Order order) {System.out.println("OrderValidationHandler: 验证订单 #" + order.getId());// 验证订单逻辑if (order.getAmount() <= 0) {System.out.println("OrderValidationHandler: 订单金额无效，处理终止");return; // 终止责任链，不再继续处理}if (order.getCustomerName() == null || order.getCustomerName().isEmpty()) {System.out.println("OrderValidationHandler: 客户信息无效，处理终止");return; // 终止责任链，不再继续处理}// 标记为已验证order.setValidated(true);System.out.println("OrderValidationHandler: 订单 #" + order.getId() + " 已验证通过");// 传递给下一个处理器if (nextHandler != null) {nextHandler.handleOrder(order); // 继续责任链的处理流程}}
}

支付处理器

/*** 支付处理器 - 责任链的第二环* 负责处理订单的支付流程*/
public class PaymentProcessHandler extends OrderHandler {@Overridepublic void handleOrder(Order order) {// 检查订单是否已验证，确保责任链的顺序性if (!order.isValidated()) {System.out.println("PaymentProcessHandler: 订单 #" + order.getId() + " 未通过验证，无法处理支付");return; // 前置条件不满足，终止处理}System.out.println("PaymentProcessHandler: 处理订单 #" + order.getId() + " 的支付，金额: " + order.getAmount());// 模拟支付处理逻辑// 这里可以加入支付网关调用等实际业务逻辑boolean paymentSuccessful = processPayment(order);if (paymentSuccessful) {order.setPaymentProcessed(true);System.out.println("PaymentProcessHandler: 订单 #" + order.getId() + " 支付成功");// 传递给下一个处理器if (nextHandler != null) {nextHandler.handleOrder(order); // 继续责任链的处理流程}} else {System.out.println("PaymentProcessHandler: 订单 #" + order.getId() + " 支付失败，处理终止");// 支付失败，终止责任链}}/*** 处理支付的内部方法* @param order 要处理支付的订单* @return 支付是否成功*/private boolean processPayment(Order order) {// 模拟支付处理// 在实际应用中，这里会调用支付网关APIreturn order.getAmount() <= 10000; // 假设10000以上的订单需要额外审核}
}

配送安排处理器

/*** 配送安排处理器 - 责任链的第三环* 负责为已支付的订单安排配送*/
public class DeliveryArrangementHandler extends OrderHandler {@Overridepublic void handleOrder(Order order) {// 检查订单是否已支付，确保责任链的顺序性if (!order.isPaymentProcessed()) {System.out.println("DeliveryArrangementHandler: 订单 #" + order.getId() + " 未完成支付，无法安排配送");return; // 前置条件不满足，终止处理}System.out.println("DeliveryArrangementHandler: 为订单 #" + order.getId() + " 安排配送");// 模拟配送安排逻辑arrangeDelivery(order);order.setDeliveryArranged(true);System.out.println("DeliveryArrangementHandler: 订单 #" + order.getId() + " 已安排配送");// 传递给下一个处理器if (nextHandler != null) {nextHandler.handleOrder(order); // 继续责任链的处理流程}}/*** 安排配送的内部方法* @param order 要安排配送的订单*/private void arrangeDelivery(Order order) {// 模拟配送安排// 在实际应用中，这里会与物流系统对接System.out.println("DeliveryArrangementHandler: 正在为客户 " + order.getCustomerName() + " 安排递送服务");}
}

通知处理器

/*** 通知处理器 - 责任链的最后一环* 负责在订单处理完成后发送通知给客户*/
public class NotificationHandler extends OrderHandler {@Overridepublic void handleOrder(Order order) {// 检查订单是否已安排配送，确保责任链的顺序性if (!order.isDeliveryArranged()) {System.out.println("NotificationHandler: 订单 #" + order.getId() + " 未安排配送，无法发送通知");return; // 前置条件不满足，终止处理}System.out.println("NotificationHandler: 发送订单 #" + order.getId() + " 的通知");// 模拟发送通知逻辑sendNotification(order);order.setNotificationSent(true);System.out.println("NotificationHandler: 订单 #" + order.getId() + " 的通知已发送");// 完成处理，这是责任链的最后一环System.out.println("订单 #" + order.getId() + " 处理完成!");}/*** 发送通知的内部方法* @param order 要发送通知的订单*/private void sendNotification(Order order) {// 模拟发送通知// 在实际应用中，这里会调用邮件或短信服务System.out.println("NotificationHandler: 向客户 " + order.getCustomerName() + " 发送订单确认通知");}
}

4. 创建客户端测试类

/*** 订单处理器 - 客户端类* 负责构建和初始化责任链，并启动订单处理流程*/
public class OrderProcessor {private OrderHandler chain; // 责任链的起点/*** 构造函数，初始化责任链*/public OrderProcessor() {// 构建责任链buildOrderProcessingChain();}/*** 构建订单处理责任链* 设定处理器的顺序：验证 -> 支付 -> 配送 -> 通知*/private void buildOrderProcessingChain() {// 创建各个处理器OrderHandler validationHandler = new OrderValidationHandler();OrderHandler paymentHandler = new PaymentProcessHandler();OrderHandler deliveryHandler = new DeliveryArrangementHandler();OrderHandler notificationHandler = new NotificationHandler();// 设置处理器链，定义处理顺序validationHandler.setNextHandler(paymentHandler);paymentHandler.setNextHandler(deliveryHandler);deliveryHandler.setNextHandler(notificationHandler);// 设置责任链的起点this.chain = validationHandler;}/*** 处理订单的方法，将订单传入责任链的起点* @param order 要处理的订单*/public void processOrder(Order order) {System.out.println("开始处理订单 #" + order.getId());chain.handleOrder(order); // 启动责任链处理}
}

5. 主类用于运行示例

/*** 责任链模式演示类* 用于测试责任链在不同订单场景下的行为*/
public class ChainOfResponsibilityDemo {public static void main(String[] args) {// 创建订单处理器OrderProcessor processor = new OrderProcessor();// 测试案例1: 有效订单 - 应该完成所有处理步骤Order validOrder = new Order(1001, 1200.50, "张三");System.out.println("=== 处理有效订单 ===");processor.processOrder(validOrder);System.out.println("最终订单状态: " + validOrder);System.out.println();// 测试案例2: 金额无效的订单 - 应在验证阶段终止Order invalidAmountOrder = new Order(1002, 0, "李四");System.out.println("=== 处理金额无效的订单 ===");processor.processOrder(invalidAmountOrder);System.out.println("最终订单状态: " + invalidAmountOrder);System.out.println();// 测试案例3: 客户信息为空的订单 - 应在验证阶段终止Order noCustomerOrder = new Order(1003, 2500.75, "");System.out.println("=== 处理客户信息为空的订单 ===");processor.processOrder(noCustomerOrder);System.out.println("最终订单状态: " + noCustomerOrder);System.out.println();}
}