Java 实现责任链策略模式优雅处理多级请求的方式一、什么是责任链模式？责任链模式（Chain of Responsibility Pattern） 是一种行为设计模式，它允许将请求沿着一个处理链传递，直到链中的某个对象处理它这样，发送者无需知道哪个对象将处理请求，所有的处理对象都可以尝试处理请求或将请求传递给链上的下一个对象核心思想：将请求的发送者与接收者解耦，通过让多个对象组成一条链，使得请求沿着链传递，直到被处理二、责任链模式的特点1. 解耦请求发出者和处理者：请求的发送者不需要知道具体的处理者是谁，增强了系统的灵活性和扩展性2. 动态组合处理逻辑：可以根据需要动态改变链的结构，添加或移除处理者3. 职责单一：责任链模式可以将每个验证逻辑封装到一个独立的处理器中，每个处理器负责单一的验证职责，符合单一职责原则4. 可扩展性： 增加新的验证逻辑时，处理者只需继承一个统一的接口，并添加新的处理器，而不需要修改现有的代码5. 清晰的流程: 将所有验证逻辑组织在一起，使得代码结构更加清晰，易于理解三、责任链模式和策略模式结合的意义· 责任链模式的作用： o 用于动态处理请求，将多个处理逻辑串联起来。
· 策略模式的作用： o 用于封装一组算法，使得可以在运行时动态选择需要的算法结合两者：· 责任链模式负责串联和传递请求，而策略模式定义了每一个处理者的具体处理逻辑· 两者结合可以实现既动态构建责任链，又灵活应用不同策略来处理请求的需求四、责任链模式解决的问题1. 耦合过高：将请求的处理者从请求的发送者中解耦，使得处理者可以独立扩展或变更2. 复杂的多条件判断：避免在代码中使用过多 if-else 或 switch-case 语句3. 灵活性不足：通过链的动态组合可以轻松调整请求的传递逻辑或插入新的处理者4. 代码重复：每个处理者只专注于处理它关心的部分，减少重复代码五、代码中的责任链模式解析场景 1：商品上架逻辑（多重校验）实现一个类似的场景——商品上架逻辑（如校验商品信息、库存信息等），可以按照以下步骤实现：1. 定义责任链抽象接口public interface MerchantAdminAbstractChainHandler extends Ordered { /** * 执行责任链逻辑 * * @param requestParam 责任链执行入参 */ void handler(T requestParam); /** * @return 责任链组件标识 */ String mark();}1. 定义商品上架的责任链标识：public enum ChainBizMarkEnum { MERCHANT_ADMIN_CREATE_PRODUCT_TEMPLATE_KEY, MERCHANT_ADMIN_PRODUCT_UPSHELF_KEY; // 新增商品上架责任链标识}1. 定义每个处理器的通用行为：@Componentpublic final class MerchantAdminChainContext implements ApplicationContextAware, CommandLineRunner { /** * 应用上下文，通过Spring IOC获取Bean实例 */ private ApplicationContext applicationContext; /** * 保存商品上架责任链实现类 * * Key：{@link MerchantAdminAbstractChainHandler#mark()} * Val：{@link MerchantAdminAbstractChainHandler} 一组责任链实现 Spring Bean 集合 * * 比如有一个商品上架模板创建责任链，实例如下： * Key：MERCHANT_ADMIN_CREATE_PRODUCT_TEMPLATE_KEY * Val： * - 验证商品信息基本参数是否必填 —— 执行器 {@link ProductInfoNotNullChainFilter} * - 验证商品库存 —— 执行器 {@link ProductInventoryCheckChainFilter} */ private final Map> abstractChainHandlerContainer = new HashMap<>(); /** * 责任链组件执行 * @param mark 责任链组件标识 * @param requestObj 请求参数 */ public void handler(String mark,T requestObj){ // 根据 mark 标识从责任链容器中获取一组责任链实现 Bean 集合 List abstractChainHandlers = abstractChainHandlerContainer.get(mark); if (CollectionUtils.isEmpty(abstractChainHandlers)) { throw new RuntimeException(String.format("[%s] Chain of Responsibility ID is undefined.", mark)); } abstractChainHandlers.forEach(each -> each.handler(requestObj)); } /** * 执行方法，接收可变参数 * 本方法主要用于初始化和处理商品上架抽象责任链容器 * 它从Spring容器中获取所有MerchantAdminAbstractChainHandler类型的Bean， * 并根据它们的mark进行分类和排序，以便后续处理 * * @param args 可变参数，可能包含方法运行所需的额外信息 * @throws Exception 如果方法执行过程中遇到错误，抛出异常 */ @Override public void run(String... args) throws Exception { // 从 Spring IOC 容器中获取指定接口 Spring Bean 集合 Map chainFilterMap = applicationContext.getBeansOfType(MerchantAdminAbstractChainHandler.class); // 遍历所有获取到的Bean，并将它们根据mark分类存入抽象责任链容器中 chainFilterMap.forEach((beanName, bean) -> { // 判断 Mark 是否已经存在抽象责任链容器中，如果已经存在直接向集合新增；如果不存在，创建 Mark 和对应的集合 List abstractChainHandlers = abstractChainHandlerContainer.getOrDefault(bean.mark(), new ArrayList<>()); abstractChainHandlers.add(bean); abstractChainHandlerContainer.put(bean.mark(), abstractChainHandlers); }); // 遍历抽象责任链容器，对每个 Mark 对应的责任链实现类集合进行排序 abstractChainHandlerContainer.forEach((mark, chainHandlers) -> { // 对每个 Mark 对应的责任链实现类集合进行排序，优先级小的在前 chainHandlers.sort(Cparing(Ordered::getOrder)); }); } @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { this.applicationContext = applicationContext; }}1. 定义商品上架的责任链处理器：@Componentpublic class ProductInfoNotNullChainFilter implements MerchantAdminAbstractChainHandler { @Override public void handler(ProductUpShelfReqDTO requestParam) { if (StringUtils.isEmpty(requestParam.getProductName())) { throw new RuntimeException("商品名称不能为空！"); } if (requestParam.getPrice() == null || requestParam.getPrice() <= 0) { throw new RuntimeException("商品价格必须大于0！"); } System.out.println("商品信息非空校验通过"); } @Override public int getOrder() { return 1; } @Override public String mark() { return ChainBizMarkEnum.MERCHANT_ADMIN_PRODUCT_UPSHELF_KEY.name(); }}@Componentpublic class ProductInventoryCheckChainFilter implements MerchantAdminAbstractChainHandler { @Override public void handler(ProductUpShelfReqDTO requestParam) { if (reques。
