Spring责任链模式使用实例讲解

责任链是行为型设计模式的一种，通过前一个处理者记录下一个处理者的方式形成一条处理链。客户端在调用时只需要将请求传递到责任上即可，无需关注链路中的具体的传递过程。而链路中内部的处理，是按照前一个处理者记录的下一个处理者依次执行

前言

在工作中会存在这种情况某些业务场景会对一份数据的属性进行多次设置，这种情况在传统的代码风格就是在一个方法中对应属性进行依次的set这种编码会在以后的业务迭代中造成很大的耦合，代码复用程度很低，后期维护成本会变大，这个时候就可以使用责任链模式对业务set这个步骤进行拆分做到可插拔式，从而做到减少迭代成本和维护成本对以后接手项目的同事友好

开始编写案例

我这里以电商项目中的商品属性设置为例productModel

1.开始搭建一个spring boot 项目

  4.0.0org.examplespring-batch1.0-SNAPSHOT org.springframework.bootspring-boot-starter-parent2.2.5.RELEASE 88  org.springframework.bootspring-boot-starter-web org.springframework.bootspring-boot-starter-test org.projectlomboklombok1.18.24provided   org.springframework.bootspring-boot-maven-plugin

2.创建对应案例数据

package com.wym.pojo; import lombok.Data; /** * 商品基础模型 */ @Data public class ProductModel { private Integer id; private String productCode; private String productName; private String productTitle; private String productTag; private String productRegion; private Integer stockNumber; private String brandName; }

package com.wym.pojo; import lombok.Data; /** * 商品附带参数 方便后期设置参数 */ @Data public class ProductParamModel { private String vendorCode; }

3.创建责任链处理器

创建一个处理接口，子类根据自己的业务特色去实现接口，对数据进行加工

/** * 商品处理 */ public interface ProductPostProcessor { /** *  商品加工 * @param productModelList 商品 * @param productParamModel 处理参数 */ void productDataProcess(List productModelList, ProductParamModel productParamModel); }

这里我设置3个常用的商品处理

/** * 商品品牌设置 */ @Component @Slf4j @Order(1) //为了后期方便业务操作顺序编排 public class ProductBrandMappingPostProcessor implements ProductPostProcessor { @Override public void productDataProcess(List productModelList, ProductParamModel productParamModel) { log.error("进入商品品牌设置"); } }

/** * 商品映射设置 */ @Component @Slf4j @Order(2) public class ProductCodeMappingPostProcessor implements ProductPostProcessor { @Override public void productDataProcess(List productModelList, ProductParamModel productParamModel) { log.error("进入商品映射设置"); } }

/** * 商品库存设置 */ @Slf4j @Component @Order(3) public class ProductStockNumberPostProcessor implements ProductPostProcessor { @Override public void productDataProcess(List productModelList, ProductParamModel productParamModel) { log.error("进入商品库存设置"); } }

这个时候就已经创建好了责任链处理器，接下来就是开始业务调用

4.创建mvc调用

controller

@RequestMapping("/test") @Slf4j @RestController public class ProductController { @Autowired private ProductServer productServer; @GetMapping("/query") public String queryProduct() { productServer.queryProduct(); return "成功"; } }

server

public interface ProductServer { /** * 查询商品 * @return List */ public List queryProduct(); }

impl 这里就是核心点如何操作这个责任链 ApplicationListener 这个取获取容器中的处理器，并排序

@Service @Slf4j public class ProductServerImpl implements ProductServer, ApplicationListener { private static List productPostProcessorList; /** * 处理排序 * * @param contextRefreshedEvent 环 * @return */ private List getProductPostProcesser(ContextRefreshedEvent contextRefreshedEvent) { //子容器加载完毕不进这个逻辑 if (contextRefreshedEvent.getApplicationContext().getParent() == null) { //监听容器加载完毕 Map beansOfType = contextRefreshedEvent.getApplicationContext().getBeansOfType(ProductPostProcessor.class); log.error("商品后置处理器注入"); List postProcessList = new ArrayList<>(beansOfType.values()); postProcessList.sort((a, b) -> { Order aOrder = AnnotationUtils.findAnnotation(a.getClass(), Order.class); Order bOrder = AnnotationUtils.findAnnotation(b.getClass(), Order.class); if (aOrder == null && bOrder == null) { return 0; } if (aOrder == null) { return 1; } if (bOrder == null) { return -1; } return aOrder.value() - bOrder.value(); } ); return postProcessList; } return null; } @Override public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent)  { List postProcessor = getProductPostProcesser(contextRefreshedEvent); if (!CollectionUtils.isEmpty(postProcessor)) { productPostProcessorList = postProcessor; } } @Override public List queryProduct() { ProductModel productModel = new ProductModel(); productModel.setId(0); productModel.setProductCode(""); productModel.setProductName(""); productModel.setProductTitle(""); productModel.setProductTag(""); productModel.setProductRegion(""); productModel.setStockNumber(0); productModel.setBrandName(""); ProductParamModel productParamModel = new ProductParamModel(); productParamModel.setVendorCode("1231"); productPostProcessorList.forEach(item -> item.productDataProcess(Arrays.asList(productModel), productParamModel)); return null; } }

进行验证

调用 http://localhost:8080/test/query 就会在控制台中打印出

2023-01-09 11:07:42.178 ERROR 25096 --- [nio-8080-exec-2] c.w.p.i.ProductBrandMappingPostProcessor : 进入商品品牌设置
2023-01-09 11:07:42.178 ERROR 25096 --- [nio-8080-exec-2] c.w.p.i.ProductCodeMappingPostProcessor : 进入商品映射设置
2023-01-09 11:07:42.179 ERROR 25096 --- [nio-8080-exec-2] c.w.p.i.ProductStockNumberPostProcessor : 进入商品库存设置

这样就做到了业务分离对后期的维护有帮助

到此这篇关于Spring责任链模式使用实例讲解的文章就介绍到这了,更多相关Spring责任链模式内容请搜索0133技术站以前的文章或继续浏览下面的相关文章希望大家以后多多支持0133技术站！

以上就是Spring责任链模式使用实例讲解的详细内容，更多请关注0133技术站其它相关文章！