责任链模式在java中的实现

本文介绍: *** 存储责任链上下文具体请求数据*//*** 责任链中断的标识*//*** 每个链路处理的结果*/

避免请求发送者与接收者耦合在一起，让多个对象都有可能接收请求，将这些对象连接成一条链，并且沿着这条链传递请求，直到有对象处理它为止。职责链模式是一种对象行为型模式。

公共部分，一个系统仅需要一个

/**
 * 真正存储着责任链的数据
 */
public interface ProcessModel {

}

public class ProcessContext<T extends ProcessModel> {

    /**
     * 存储责任链上下文具体请求数据
     */
    private T processModel;

    /**
     * 责任链中断的标识
     */
    private Boolean needBreak;

    /**
     * 每个链路处理的结果
     */
    XXXResponse response;

    public T getProcessModel() {
        return processModel;
    }

    public void setProcessModel(T processModel) {
        this.processModel = processModel;
    }

    public Boolean getNeedBreak() {
        return needBreak;
    }

    public void setNeedBreak(Boolean needBreak) {
        this.needBreak = needBreak;
    }

    public XXXResponse getResponse() {
        return response;
    }

    public void setResponse(XXXResponse response) {
        this.response = response;
    }
}

public interface AbstractChainProcessor<T extends ProcessModel> {

    void processRequest(ProcessContext<T> request);
}

/**
 * @author sighting
 * @version 1.0.0.0
 * @description: 消息发送处理模版
 * @date 2022/12/1 4:11 下午
 */

public class ProcessTemplate {

    private List<AbstractChainProcessor> processList;

    public List<AbstractChainProcessor> getProcessList() {
        return processList;
    }

    public void setProcessList(List<AbstractChainProcessor> processList) {
        this.processList = processList;
    }

}

调用方组装责任链(非公共部分，按需实现)，设置链执行顺序，当然也可以每个对象中设置责任链的下游对象,具体实现为，在抽象责任链中增加第二段代码

public ProcessTemplate getAsseblyChain(String exeMode) {
        ProcessTemplate processTemplate = new ProcessTemplate();
        MessageSendModeEnum sendMode = MessageSendModeEnum.getByName(exeMode);
        BizValidation.isTrueBCheck(MessageResultCode.SEND_MODE_NOT_SUPPORT, sendMode != null,null);
        if (MessageSendModeEnum.SYNC.getCode() == sendMode.getCode()) {
            processTemplate.setProcessList(Arrays.asList(xxxx,xxxx));
        } else {
            processTemplate.setProcessList(Arrays.asList(xxx,ssss,needed));
        }
        return processTemplate;
    }

//维持对下家的引用
protected Handler successor;
public void setSuccessor(Handler successor) {
		this.successor=successor;
}

         //责任链入参
        ProcessContext<MessageSendReqBO> processContext = new ProcessContext<>();
        processContext.setProcessModel(reqBO);
        processContext.setNeedBreak(false);
        processContext.setResponse(new SimbaResponse());
        try {
            //责任链处理
            for (AbstractChainProcessor businessProcess : 上个方法.getAsseblyChain(reqBO.getExecMode()).getProcessList()) {
                businessProcess.processRequest(processContext);
                if (processContext.getNeedBreak()) {
                    break;
                }
            }
         } catch (Exception e) {
            log.error("chains exe failed",e)
         }

显示所有内容

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。