牢记于心

职责单一: 责任链模式可以将每个验证逻辑封装到一个独立的处理器中，每个处理器负责单一的验证职责，符合单一职责原则。

可扩展性: 增加新的验证逻辑时，只需添加新的处理器，而不需要修改现有的代码。

清晰的流程: 将所有验证逻辑组织在一起，使得代码结构更加清晰，易于理解。

使用场景

现在有个逻辑判断，商家端创建优惠券的时候，需要给出一些指定信息，后台会对这些信息进行判断，比如：优惠券名称是否合法，是否为空，时间是否正确（失效时间先于启用时间），绑定的商品是否存在....等等逻辑判断。
我们不可能说，每加一个判断标准就去核心代码里面改动，不便于维护....

这里采用责任链设计模式，将逻辑判断分为两块，即两个独立的处理器：

判断必要条件是否为空、判断指定商品是否存在（微服务中，往往需要给商品服务发http请求）。

步骤

1、编写责任链接口

public interface MerchantAdminAbstractChainHandler<T> extends Ordered {/*** 执行责任链逻辑** @param requestParam 责任链执行入参*/void handler(T requestParam);/*** @return 责任链组件标识*/String mark();
}

细节：通过继承Ordered抽象类，让处理器有顺序的执行，先执行性能花费小的，再执行性能花费大的（调用第三方API）。 

2、编写责任链处理器实现类

相同的责任链下的不同处理器，他们的mark方法的返回值要一样，后期根据这个做map的key，将同一个责任链进行绑定（value为一个list集合）

@Component
public class CouponTemplateCreateParamNotNullChainFilter implements MerchantAdminAbstractChainHandler<CouponTemplateSaveReqDTO> {@Overridepublic void handler(CouponTemplateSaveReqDTO requestParam) {if (StrUtil.isEmpty(requestParam.getName())) {throw new ClientException("优惠券名称不能为空");}if (ObjectUtil.isEmpty(requestParam.getSource())) {throw new ClientException("优惠券来源不能为空");}if (ObjectUtil.isEmpty(requestParam.getTarget())) {throw new ClientException("优惠对象不能为空");}if (ObjectUtil.isEmpty(requestParam.getType())) {throw new ClientException("优惠类型不能为空");}if (ObjectUtil.isEmpty(requestParam.getValidStartTime())) {throw new ClientException("有效期开始时间不能为空");}if (ObjectUtil.isEmpty(requestParam.getValidEndTime())) {throw new ClientException("有效期结束时间不能为空");}if (ObjectUtil.isEmpty(requestParam.getStock())) {throw new ClientException("库存不能为空");}if (StrUtil.isEmpty(requestParam.getReceiveRule())) {throw new ClientException("领取规则不能为空");}if (StrUtil.isEmpty(requestParam.getConsumeRule())) {throw new ClientException("消耗规则不能为空");}}@Overridepublic String mark() {return MERCHANT_ADMIN_CREATE_COUPON_TEMPLATE_KEY.name();}@Overridepublic int getOrder() {return 0;}
}

 负责调用第三方服务，查看指定商品是否存在（第三方服务往往开设一个接口，给外部调用）

@Component
public class CouponTemplateCreateParamVerifyChainFilter implements MerchantAdminAbstractChainHandler<CouponTemplateSaveReqDTO> {@Overridepublic void handler(CouponTemplateSaveReqDTO requestParam) {if (ObjectUtil.equal(requestParam.getTarget(), DiscountTargetEnum.PRODUCT_SPECIFIC)) {// 调用商品中台验证商品是否存在，如果不存在抛出异常// ......}}@Overridepublic String mark() {return MERCHANT_ADMIN_CREATE_COUPON_TEMPLATE_KEY.name();}@Overridepublic int getOrder() {return 20;}
}

3、责任链处理器上下文

@Component
public final class MerchantAdminChainContext<T> implements ApplicationContextAware, CommandLineRunner {/*** 应用上下文，我们这里通过 Spring IOC 获取 Bean 实例*/private ApplicationContext applicationContext;/*** 保存商家后管责任链实现类*/private final Map<String, List<MerchantAdminAbstractChainHandler>> abstractChainHandlerContainer = new HashMap<>();public void handler(String mark, T requestParam) {// 根据 mark 标识从责任链容器中获取一组责任链实现 Bean 集合List<MerchantAdminAbstractChainHandler> 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(requestParam));}@Overridepublic void run(String... args) throws Exception {// 从 Spring IOC 容器中获取指定接口 Spring Bean 集合Map<String, MerchantAdminAbstractChainHandler> chainFilterMap = applicationContext.getBeansOfType(MerchantAdminAbstractChainHandler.class);chainFilterMap.forEach((beanName, bean) -> {// 判断 Mark 是否已经存在抽象责任链容器中，如果已经存在直接向集合新增；如果不存在，创建 Mark 和对应的集合List<MerchantAdminAbstractChainHandler> abstractChainHandlers = abstractChainHandlerContainer.getOrDefault(bean.mark(), new ArrayList<>());abstractChainHandlers.add(bean);abstractChainHandlerContainer.put(bean.mark(), abstractChainHandlers);});abstractChainHandlerContainer.forEach((mark, unsortedChainHandlers) -> {// 对每个 Mark 对应的责任链实现类集合进行排序，优先级小的在前unsortedChainHandlers.sort(Comparator.comparing(Ordered::getOrder));});}@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext = applicationContext;}
}

 细节：通过ApplicationAware接口和CommandLineRunner接口，进行时期分离，保证Bean对象初始化后，先进行初始化applicationContext对象，等SpringBoot服务完全跑起来后，再去调用重写的run方法（此时applicationContext对象已经完成了初始化）

4、实现类中的使用

@Service
@RequiredArgsConstructor
public class CouponTemplateServiceImpl extends ServiceImpl<CouponTemplateMapper, CouponTemplateDO> implements CouponTemplateService {private final MerchantAdminChainContext merchantAdminChainContext;@Overridepublic void createCouponTemplate(CouponTemplateSaveReqDTO requestParam) {// 通过责任链验证请求参数是否正确merchantAdminChainContext.handler(MERCHANT_ADMIN_CREATE_COUPON_TEMPLATE_KEY.name(), requestParam);}
}

通过 Spring IOC 容器去获取责任链处理器的，所以不管新增和删除都不需要变更获取逻辑。新增的话创建对应处理器即可，符合开闭原则。
我们直接通过上下文去判断是否符合逻辑，不符合的直接抛错，不再继续...