职责链实现的apache.chain使用

时间:2022-02-06 20:43:53

其实职责链在老早就使用过了,以前在HW给Vodafone做金融项目的时候,使用职责链完成交易步骤,那时觉得这东西真好用,可以直接通过配置决定业务流程,现在终于有机会实践一下。

 
    
    这种设计模式本身的实现是非常容易的,可以简单单做是一组IF条件的集合,符合条件的继续传递;不符合条件的终止运行。chain代表了一条运行逻辑,就如同一条项链,我们的业务逻辑就如同是珍珠,并且都实现了同样的compute接口。apache的实现,是通过将数据封装到上下文(context)中,而且该上下文就是串起这些珍珠的金线。
 
    下面是自己写的一段例子:
 
 链的组织,也可以通过配置xml文件来实现,用在spring框架中非常合适。
 
/**
* 职责链的组织类,负责构造整个链
*/
public class RootCauseChain extends ChainBase
{
/**
* 通过此方法增减生效的分析器
*/
public RootCauseChain()
{
addCommand(new DataRootCauseAnalyzer());
//addCommand(new EnvRootCauseAnalyzer());
//addCommand(new PifRootCauseAnalyzer());
//addCommand(new TaskRootCauseAnalyzer());
}
}

具体的业务:  

/**
* 实现了command接口,数据均通过context组织
*/
public class DataRootCauseAnalyzer implements Command
{
private DataQueryService dqService = new DataQueryService(); private static final String ROOT_CAUSE_FORMAT = "indicator value is abnormal: check ? for more information"; @SuppressWarnings("unchecked")
@Override
public boolean execute(Context arg0) throws Exception
{
boolean res = false; Log.info(RootCauseConstant.MODULE_CODE, "0000",
"begin to execute DataRootCauseAnalyzer.execute"); List<DataPoint> exceptionDataPoints = (List<DataPoint>) arg0.get("expData");
ExceptionRule exceptionRule = (ExceptionRule) arg0.get("rule"); List<RootCause> result = new ArrayList<RootCause>(); if (exceptionDataPoints != null && !exceptionDataPoints.isEmpty())
{
for (DataPoint dataPoint : exceptionDataPoints)
{
List<RootCause> rootCauseList = generateRootCause(dataPoint, exceptionRule); result.addAll(rootCauseList);
}
} // 如果分析出了根因,则结束分析流程
if (result != null && !result.isEmpty())
{
arg0.put("result", result); res = true;
} // 没有分析出根因,交到下一个分析器进行分析
return res;
} /**
* 生成具体的异常信息
*
* @param exceptionPoint
* 异常数据点
* @param rule
* 异常规则
* @return 查询上下级关系
*/
private List<RootCause> generateRootCause(DataPoint exceptionPoint, ExceptionRule rule)
{
List<RootCause> rclist = new ArrayList<RootCause>(); return rclist;
}
}

  调用:

public class RootCauseService
{
/**
* 分析异常点的根因
*
* @param points
* 异常数据点
* @param rule
* 异常数据发现规则
* @return 异常数据点及根因
*/
@SuppressWarnings("unchecked")
public List<RootCause> getRootCause(List<DataPoint> points, ExceptionRule rule)
{
Log.info(RootCauseConstant.MODULE_CODE, "0000", "begin to execute getRootCause, points="
+ points + ", rule=" + rule); List<RootCause> result = new ArrayList<RootCause>(); try
{
Command command = new RootCauseChain();
ContextBase ctx = new ContextBase(); ctx.put("expData", points);
ctx.put("rule", rule); command.execute(ctx);
result = (List<RootCause>) ctx.get("result");
}
catch (Exception e)
{
Log.error(RootCauseConstant.MODULE_CODE, "0000",
"execute analysisRootCauseByCommandChain exception.", e);
} Log.info(RootCauseConstant.MODULE_CODE, "0000", "execute getRootCause finished, result="
+ result); return result;
}
}