本文介绍: *** 存储责任链上下文具体请求数据*//*** 责任链中断的标识*//*** 每个链路处理的结果*/
1 总览
2 概念
避免请求发送者与接收者耦合在一起,让多个对象都有可能接收请求,将这些对象连接成一条链,并且沿着这条链传递请求,直到有对象处理它为止。职责链模式是一种对象行为型模式。
3 实现
公共部分,一个系统仅需要一个
3.1 责任链传递的数据,所有对象实现该接口
/**
* 真正存储着责任链的数据
*/
public interface ProcessModel {
}
3.2 责任链上下文,包含请求和返回结果(结果代码中自定义),中断标识等
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;
}
}
3.3 抽象责任链接口
public interface AbstractChainProcessor<T extends ProcessModel> {
void processRequest(ProcessContext<T> request);
}
3.4 责任链具体实现(多个,按需实现)
3.5 责任链组装
/**
* @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;
}
3.6 使用实例:责任链具体使用
//责任链入参
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)
}
原文地址:https://blog.csdn.net/u013984781/article/details/135926069
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_64913.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。