JAVA：Spring Boot 实现责任链模式处理订单流程的技术指南

1、简述

在复杂的业务系统中，订单流程往往需要一系列的操作，比如验证订单、检查库存、处理支付、更新订单状态等。责任链模式（Chain of Responsibility）可以帮助我们将这些处理步骤分开，并且以链式方式处理每一个操作，从而让代码更加清晰、可扩展和模块化。本文将介绍如何在 Spring Boot 3.3 中使用责任链模式实现订单流程管理。

在这里插入图片描述

2、场景设计

责任链模式是一种行为设计模式，它通过将请求沿着处理者链进行传递，直到其中一个处理者处理该请求为止。在订单处理系统中，我们可以将每个处理步骤（如验证、库存检查、支付）作为一个节点，让请求沿着这些节点传递，直到处理完成。

假设我们的订单系统需要以下几个步骤来处理订单：

验证订单：检查订单信息是否合法。
库存检查：检查商品库存是否足够。
支付处理：处理订单支付。
更新状态：更新订单状态。

这些步骤可以通过责任链模式实现，每个步骤独立为一个处理器，并串联成链来依次执行。

3、代码实现

3.1 定义处理器接口

首先定义 OrderHandler 接口，用于统一订单处理行为。

public interface OrderHandler {void setNextHandler(OrderHandler nextHandler); // 设置下一个处理器void handle(Order order);                      // 处理订单
}

3.2 实现具体处理器

为每个步骤实现对应的处理器，比如 ValidateOrderHandler、InventoryCheckHandler、PaymentHandler 和 StatusUpdateHandler。

import org.springframework.stereotype.Component;// 订单验证处理器
@Component
public class ValidateOrderHandler implements OrderHandler {private OrderHandler nextHandler;@Overridepublic void setNextHandler(OrderHandler nextHandler) {this.nextHandler = nextHandler;}@Overridepublic void handle(Order order) {if (order.isValid()) {System.out.println("订单验证通过");if (nextHandler != null) {nextHandler.handle(order);}} else {throw new RuntimeException("订单无效！");}}
}// 库存检查处理器
@Component
public class InventoryCheckHandler implements OrderHandler {private OrderHandler nextHandler;@Overridepublic void setNextHandler(OrderHandler nextHandler) {this.nextHandler = nextHandler;}@Overridepublic void handle(Order order) {if (order.hasSufficientInventory()) {System.out.println("库存检查通过");if (nextHandler != null) {nextHandler.handle(order);}} else {throw new RuntimeException("库存不足！");}}
}// 支付处理器
@Component
public class PaymentHandler implements OrderHandler {private OrderHandler nextHandler;@Overridepublic void setNextHandler(OrderHandler nextHandler) {this.nextHandler = nextHandler;}@Overridepublic void handle(Order order) {if (order.processPayment()) {System.out.println("支付处理成功");if (nextHandler != null) {nextHandler.handle(order);}} else {throw new RuntimeException("支付失败！");}}
}// 状态更新处理器
@Component
public class StatusUpdateHandler implements OrderHandler {private OrderHandler nextHandler;@Overridepublic void setNextHandler(OrderHandler nextHandler) {this.nextHandler = nextHandler;}@Overridepublic void handle(Order order) {order.updateStatus("完成");System.out.println("订单状态更新成功");if (nextHandler != null) {nextHandler.handle(order);}}
}

3.3 配置责任链

在 Spring Boot 中，通过构造函数注入的方式，将各个处理器链接起来。

import org.springframework.stereotype.Service;
import java.util.List;@Service
public class OrderProcessingService {private final OrderHandler firstHandler;public OrderProcessingService(List<OrderHandler> handlers) {// 构建责任链for (int i = 0; i < handlers.size() - 1; i++) {handlers.get(i).setNextHandler(handlers.get(i + 1));}this.firstHandler = handlers.get(0); // 获取责任链的第一个处理器}public void processOrder(Order order) {firstHandler.handle(order);}
}

3.4 定义 Order 类

创建一个简单的 Order 类用于模拟订单数据。

public class Order {private boolean valid;private boolean sufficientInventory;private boolean paymentProcessed;private String status;// 模拟订单有效性public boolean isValid() { return valid; }public void setValid(boolean valid) { this.valid = valid; }// 模拟库存检查public boolean hasSufficientInventory() { return sufficientInventory; }public void setSufficientInventory(boolean sufficientInventory) {this.sufficientInventory = sufficientInventory;}// 模拟支付处理public boolean processPayment() { return paymentProcessed; }public void setPaymentProcessed(boolean paymentProcessed) {this.paymentProcessed = paymentProcessed;}public void updateStatus(String status) {this.status = status;}public String getStatus() {return status;}
}

3.5 测试责任链

在 OrderProcessingService 中调用 processOrder 方法测试整个订单流程。

import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;@Component
public class OrderProcessTestRunner implements CommandLineRunner {private final OrderProcessingService orderProcessingService;public OrderProcessTestRunner(OrderProcessingService orderProcessingService) {this.orderProcessingService = orderProcessingService;}@Overridepublic void run(String... args) throws Exception {Order order = new Order();order.setValid(true);order.setSufficientInventory(true);order.setPaymentProcessed(true);try {orderProcessingService.processOrder(order);System.out.println("订单处理完成，状态：" + order.getStatus());} catch (Exception e) {System.out.println("订单处理失败：" + e.getMessage());}}
}