当前位置：首页 > article >正文

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

article 2025/1/22 15:43:05

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;

    @Override
    public void setNextHandler(OrderHandler nextHandler) {
        this.nextHandler = nextHandler;
    }

    @Override
    public 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;

    @Override
    public void setNextHandler(OrderHandler nextHandler) {
        this.nextHandler = nextHandler;
    }

    @Override
    public 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;

    @Override
    public void setNextHandler(OrderHandler nextHandler) {
        this.nextHandler = nextHandler;
    }

    @Override
    public 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;

    @Override
    public void setNextHandler(OrderHandler nextHandler) {
        this.nextHandler = nextHandler;
    }

    @Override
    public 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;
    }

    @Override
    public 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());
        }
    }
}