设计模式---责任链模式快速demo

🕗 发布于 2024-10-11 13:32 设计模式责任链模式

Handler（处理者）： 定义一个处理请求的接口。通常包括一个处理请求的方法。它可以是抽象类或接口，也可以是具体类，具体类中包含了对请求的处理逻辑。处理者通常包含一个指向下一个处理者的引用。
ConcreteHandler（具体处理者）： 实现Handler接口的具体处理类。它负责处理请求，如果自己能够处理则处理，否则将请求传递给下一个处理者。
Client（客户端）： 创建一个请求并将其发送给处理者链中的第一个处理者，然后等待处理结果。

见代码

处理者:

package trade.pipe;

import trade.model.order.reqVo.OrderPipeReqVo;

public abstract class OrderBaseHandler {

    public String nodeName = "";

    public abstract void execute(OrderPipeReqVo request);

    public abstract void setNodeName();

    public String getNodeName() {
        return nodeName;
    }

}

具体处理者:

CheckUserPermHandler // 校验用户权限
CheckOrderReqHandler // 请求参数基本校验
CheckOrderProductHandler // 检验产品信息
CheckOrderBuyerInfoHandler // 校验买家所有信息
CheckOrderSellerInfoHandler // 校验卖家基本信息
AssembleOrderBaseHandler // 封装订单基本信息
AssembleOrderTradeHandler // 封装订单交易基本信息
AssembleOrderProductHandler // 封装订单商品基本信息
AssembleOrderPriceHandler // 封装订单价格信息
AssembleOrderPayHandler // 封装付款单
AssembleOrderPayDetailHandler // 封装付款单详情
AssembleOrderInvoiceHandler // 封装订单发票基本信息
OccupiedInventoryHandler // 锁定库存
SaveOrderBaseHandler // 保存普通订单所有数据
SaveOrderSearchHandler // 保存寻车订单特别数据
SaveOrderLogHandler // 保存订单日志
OrderJobsHandler // 订单完成创建定时任务
OrderMQsHandler // MQ

此处只列举几个

@Component
@Slf4j
public class CheckUserPermHandler extends OrderBaseHandler {
    @Override
    public void execute(OrderPipeReqVo request) {
        log.info("校验用户权限==>>start");

        log.info("校验用户权限==>>end");
    }


    @Override
    public void setNodeName() {
        this.nodeName = "校验用户权限";
    }
}

// ...
@Component
@Slf4j
public class CheckOrderReqHandler extends OrderBaseHandler {


    @Override
    public void execute(OrderPipeReqVo request) {
        log.info("请求参数基本校验==>>start");

        log.info("请求参数基本校验==>>end");
    }

    @Override
    public void setNodeName() {
        this.nodeName = "请求参数基本校验";
    }
}

// ...
@Component
@Slf4j
public class CheckOrderProductHandler extends OrderBaseHandler {

    @Override
    public void execute(OrderPipeReqVo request) {
        log.info("检验产品信息==>>start");
       
        log.info("检验产品信息==>>end");
    }

    @Override
    public void setNodeName() {
        this.nodeName = "检验产品信息";
    }
}

责任链节点请求类

public class OrderPipeReqVo implements Serializable {

    private ResultVo<Object> resultVo;

    private Object a;
    private Object b;
    private Object c;
    private Object d;
    // 其他业务处理类
}

封装客户端

实际应用中,我们需要对责任链进行组装,以便客户端可以方便快速的调用 ,且无需重复组装.

import cn.hutool.extra.spring.SpringUtil;

@Component
@Slf4j
public class OrderPipeline {

    private static Map<String, List<OrderBaseHandler>> handlersMap = new HashMap<>();

    public static List<OrderBaseHandler> getHandlersMap(String tradeType) {
        return handlersMap.get(tradeType);
    }

    // 封装A订单链点静态方法
    private static List<String> getOrderHandlers() {
        List<String> list = Lists.newArrayList();
        list.add("checkUserPermHandler"); // 校验用户权限
        list.add("checkOrderReqHandler"); // 请求参数基本校验
        list.add("checkOrderProductHandler"); // 检验产品信息
        list.add("checkOrderSellerInfoHandler"); // 校验卖家基本信息
        list.add("checkOrderBuyerInfoHandler"); // 校验买家所有信息
        list.add("assembleOrderBaseHandler"); // 封装订单基本信息
        list.add("assembleOrderTradeHandler"); // 封装订单交易基本信息
        list.add("assembleOrderProductHandler"); // 封装订单商品基本信息
        list.add("assembleOrderPriceHandler"); // 封装订单价格信息
        list.add("assembleOrderPayHandler"); // 封装付款单
        list.add("assembleOrderPayDetailHandler"); // 封装付款单详情
        list.add("assembleOrderInvoiceHandler"); // 封装订单发票基本信息
        list.add("checkOrderAssemble2ReqHandler"); // 业务封装 校验
        list.add("occupiedInventoryHandler"); // 锁定库存
        list.add("saveOrderBaseHandler"); // 保存普通订单所有数据
        list.add("saveOrderSearchHandler"); // 保存订单特别数据
        list.add("saveOrderLogHandler"); // 保存订单日志
        list.add("orderJobsHandler"); // 订单完成创建定时任务
        list.add("orderMQsHandler"); // MQ
        return list;

    }

    // 封装B订单链点静态方法
    private static List<String> getSearchOrderHandlers() {
        List<String> list = Lists.newArrayList();
        list.add("checkUserPermHandler"); // 校验用户权限
        list.add("checkOrderReqHandler"); // 请求参数基本校验
        list.add("checkOrderProductHandler"); // 检验产品信息
        list.add("checkOrderSellerInfoHandler"); // 校验卖家基本信息
        list.add("checkOrderBuyerInfoHandler"); // 校验买家所有信息
        list.add("assembleOrderBaseHandler"); // 封装订单基本信息
        list.add("assembleOrderTradeHandler"); // 封装订单交易基本信息
        list.add("assembleOrderProductHandler"); // 封装订单商品基本信息
        list.add("assembleOrderPriceHandler"); // 封装订单价格信息
        list.add("assembleOrderPayHandler"); // 封装付款单
        list.add("assembleOrderPayDetailHandler"); // 封装付款单详情
        list.add("assembleOrderInvoiceHandler"); // 封装订单发票基本信息
        list.add("assembleOrderSearchHandler"); // 封装订单信息
        list.add("checkOrderAssemble2ReqHandler"); // 业务封装 
        list.add("occupiedInventoryHandler"); // 锁定库存
        list.add("saveOrderBaseHandler"); // 保存普通订单所有数据
        list.add("saveOrderBBBHandler"); // 保存订单特别数据
        list.add("saveOrderLogHandler"); // 保存订单日志
        list.add("orderJobsHandler"); // 订单完成定时任务
        list.add("orderMQsHandler"); // MQ 无服务费 无定金 发起签约
        return list;
    }
    // ...

    // 组装订单责任链map
    @PostConstruct
    public void init() {
        log.info("开始初始化订单责任链");

        List<OrderBaseHandler> orderBaseHandlers = getOrderHandlers().stream().map(bean -> (OrderBaseHandler) SpringUtil.getBean(bean)).collect(Collectors.toList());
        orderBaseHandlers.stream().forEach(b-> System.out.print(b.getClass().getName()+"-"));
        log.info("A订单责任链组装完成");
        handlersMap.put("ORDER_A", orderBaseHandlers);

        List<OrderBaseHandler> searchOrderHandlers = getSearchOrderHandlers().stream().map(bean -> (OrderBaseHandler) SpringUtil.getBean(bean)).collect(Collectors.toList());
        searchOrderHandlers.stream().forEach(b-> System.out.print(b.getClass().getName()+"-"));
        log.info("B订单责任链组装完成");
        handlersMap.put("ORDER_B", searchOrderHandlers);

        log.info("订单责任链初始化完成");
    }
}

调用实例

 @Override
    public Result<Object> test() {
        List<OrderBaseHandler> order_new = OrderPipeline.getHandlersMap("ORDER_A");
        order_new.forEach(item->{
            System.out.println(item.getClass().getName());
            item.execute(null);
        });
        System.out.println("====================================================================");
        List<OrderBaseHandler> order_search = OrderPipeline.getHandlersMap("ORDER_B");
        order_search.forEach(item->{
            System.out.println(item.getClass().getName());
            item.execute(null);
        });
        return Result.success();
    }

项目启动控制台打印:

执行test()方法:

原文地址：https://blog.csdn.net/u013408059/article/details/142845578

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：leetcode链表（一）-移除链表元素
下一篇：掌握 C# 设计模式：从基础到依赖注入

Linux: debug: perf: report: --sort
接上回：https://mzhan017.blog.csdn.net/article/details/142689870。这里介绍perf的这个参数，还是非常的有用，尤其是分析对整个系统做perf r
阅读更多2024-10-12
英伟达股价分析:英伟达股价能否上涨到150美元,接下来该如何操作?
但该公司的市盈率表明，它目前的估值是合理的，而且长期潜力仍然很大，目前市场预测，到2030年，英伟达的市值将达到10万亿美元。》，当时英伟达的股价接近1100美元，我们当时建议看涨的投资者等待回调或盘
阅读更多2024-10-12
linux下使用mpi求自然数和
搭建MPI并行计算环境，编写要求:1.使用100个进程;2.进程0计算1 +2+...+100,进程1计算101+ 102+...+ 200,.....进程99计算9901 + 9902+... +1
阅读更多2024-10-12
vue使用js-xlsx导入本地excle表格数据，回显在页面上
页面代码，导入本地文件我用的是element的上传工具。这链接是详细的说明这个js-xlsx的，可以看看这个。解释放在代码的注释中。
阅读更多2024-10-12
LeetCode讲解篇之2266. 统计打字方案数
类似的按存在四个字母的按键，当连续按i次时其方案数f[i] = f[i - 1] + f[i - 2] + f[i - 3] + f[i - 4]我们发现连续按存在三个字母的按键，当连续按i次时其方案
阅读更多2024-10-12
电脑报错msvcr120.dll丢失怎么办？这些方法快速修复
如果msvcr120.dll文件丢失或损坏，可能会导致相关软件无法启动，出现“无法找到msvcr120.dll”或“程序无法启动，因为计算机中丢失msvcr120.dll”等错误提示。金山毒霸的DLL
阅读更多2024-10-12
RTSP RTP RTCP SDP基础知识
实时流传输协议（RTSP：Real Time Streaming Protocol）是⼀种⽹络传输协议，旨在发送低延迟流。该协议由RealNetworks，Netscape和哥伦⽐亚⼤学的专家在199
阅读更多2024-10-12
基于SpringBoot+Vue的爱宠医院管理系统（Java毕业设计）
基于SpringBoot+Vue的爱宠医院管理系统项目编号：90JDK版本: Java JDK1.8开发工具:IDEA数据库版本: mysql8.0node版本：14.16.1数据库可视化工具: na
阅读更多2024-10-12
AI应用落地深度分析报告：AI落地切实推动内容与营销产业快速增长
大模型的发展开启了AIGC时代，当前多模态发展趋势清晰，AI视频生成正在迅速发展。目前大模型已从早期的技术驱动转向生态驱动，AI技术持续商业化应用与落地。AIGC技术应用与落地带来的提质、降本、增效
阅读更多2024-10-12
linux Load Average 计算
linux Load Average 计算
阅读更多2024-10-12