2019年阿里云双11活动拼团：https://www.aliyun.com/1111/2019/group-buying-share
生产一个产品，需要依次执行多个步骤，才能完成，那么是使用责任链模式则是极好的。
在性能告警模块开发过程中，创建一条告警规则需要执行阈值解析，中间表生成，流任务生成，规则入库，告警事件入库等诸多操作。如果把这些步骤糅合在一个类中，代码可读性及复杂度往往是灾难的，特别对于这么多步骤的事务性操作，更是力不从心。使用责任链模式，上述问题迎刃而解。
以告警规则创建为例子，简化流程如下
阈值解析 ---> 流任务生成 ---> 规则入库
回滚流程如下
1、 阈值解析失败：回滚阈值解析。
2、 流任务生产失败：回滚流任务生成，阈值解析。
3、 规则入库失败：回滚规则入库，流任务生成，阈值解析。
采用责任链模式编码，思路如下：
1、 编写阈值解析处理器，流任务生成处理器，规则入库处理器，每个处理器包含业务处理方法和回滚方法；
2、 一个处理器业务代码执行完成后主动调用下一个处理器业务方法；
3、 一个处理器业务代码执行失败主动调用本处理器回滚方法，本处理器回滚完成后主动调用上一个处理器回滚方法。
代码如下
1、 抽象处理器
package com.coshaho.learn.handler;
/**
*
* AbstractRuleHandler.java Create on 2017年5月5日 下午11:20:15
*
* 类功能说明: 告警规则责任链处理节点抽象类
*
* Copyright: Copyright(c) 2013
* Company: COSHAHO
* @Version 1.0
* @Author coshaho
*/
public abstract class AbstractRuleHandler
{
// 上一个处理器
private AbstractRuleHandler preHandler;
// 下一个处理器
private AbstractRuleHandler nextHandler;
/**
* 业务执行
*
* @author coshaho
* @param rule
*/
public void doHandle(AlarmRule rule)
{
try
{
doHandleReal(rule);
}
catch(Exception e)
{
// 业务代码执行失败主动回滚
rollBack(rule);
return;
}
// 业务代码执行成功主动调用下一个处理器处理
if(null != nextHandler)
{
nextHandler.doHandle(rule);
}
}
/**
* 事务回滚
*
* @author coshaho
* @param rule
*/
public void rollBack(AlarmRule rule)
{
rollBackReal(rule);
// 本处理器业务回滚完成，主动调用前一个处理器业务回滚
if(null != preHandler)
{
preHandler.rollBack(rule);
}
}
/**
* 每个处理器特有的业务处理方法
*
* @author coshaho
* @param rule
* @throws Exception
*/
public abstract void doHandleReal(AlarmRule rule) throws Exception;
/**
* 每个处理器特有的业务回滚方法
*
* @author coshaho
* @param rule
*/
public abstract void rollBackReal(AlarmRule rule);
private AbstractRuleHandler setPreHandler(AbstractRuleHandler preHandler)
{
this.preHandler = preHandler;
return preHandler;
}
public AbstractRuleHandler setNextHandler(AbstractRuleHandler nextHandler)
{
this.nextHandler = nextHandler;
nextHandler.setPreHandler(this);
return nextHandler;
}
}
2、阈值解析处理器
package com.coshaho.learn.handler;
import org.apache.commons.lang.StringUtils;
/**
*
* ThresholdParseHandler.java Create on 2017年5月5日 下午11:41:20
*
* 类功能说明: 阈值解析
*
* Copyright: Copyright(c) 2013
* Company: COSHAHO
* @Version 1.0
* @Author coshaho
*/
public class ThresholdParseHandler extends AbstractRuleHandler
{
@Override
public void doHandleReal(AlarmRule rule) throws Exception
{
if(StringUtils.isEmpty(rule.getThreshold()))
{
throw new Exception("Threshold is empty.");
}
System.out.println("Parse threshold success. Threshold is " + rule.getThreshold());
}
@Override
public void rollBackReal(AlarmRule rule)
{
System.out.println("Roll parse threshold. Threshold is " + rule.getThreshold());
}
}
3、流任务生成处理器
package com.coshaho.learn.handler;
/**
*
* StreamGenerateHandler.java Create on 2017年5月5日 下午11:41:43
*
* 类功能说明: 告警流规则生成
*
* Copyright: Copyright(c) 2013
* Company: COSHAHO
* @Version 1.0
* @Author coshaho
*/
public class StreamGenerateHandler extends AbstractRuleHandler
{
@Override
public void doHandleReal(AlarmRule rule) throws Exception
{
System.out.println("Generate stream success.");
}
@Override
public void rollBackReal(AlarmRule rule)
{
System.out.println("Roll Generate stream.");
}
}
4、规则入库处理器
package com.coshaho.learn.handler;
import org.apache.commons.lang.StringUtils;
/**
*
* RulePesistHandler.java Create on 2017年5月5日 下午11:41:08
*
* 类功能说明: 告警规则持久化
*
* Copyright: Copyright(c) 2013
* Company: COSHAHO
* @Version 1.0
* @Author coshaho
*/
public class RulePesistHandler extends AbstractRuleHandler
{
@Override
public void doHandleReal(AlarmRule rule) throws Exception {
if(StringUtils.isEmpty(rule.getName()))
{
throw new Exception("Rule name is empty.");
}
System.out.println("Persist rule success. Rule name is " + rule.getName());
}
@Override
public void rollBackReal(AlarmRule rule) {
System.out.println("Roll persist rule. Rule name is " + rule.getName());
}
}
5、规则入库处理器
package com.coshaho.learn.handler;
import org.apache.commons.lang.StringUtils;
/**
*
* RulePesistHandler.java Create on 2017年5月5日 下午11:41:08
*
* 类功能说明: 告警规则持久化
*
* Copyright: Copyright(c) 2013
* Company: COSHAHO
* @Version 1.0
* @Author coshaho
*/
public class RulePesistHandler extends AbstractRuleHandler
{
@Override
public void doHandleReal(AlarmRule rule) throws Exception {
if(StringUtils.isEmpty(rule.getName()))
{
throw new Exception("Rule name is empty.");
}
System.out.println("Persist rule success. Rule name is " + rule.getName());
}
@Override
public void rollBackReal(AlarmRule rule) {
System.out.println("Roll persist rule. Rule name is " + rule.getName());
}
}
6、告警规则
package com.coshaho.learn.handler;
/**
*
* AlarmRule.java Create on 2017年5月5日 下午11:40:50
*
* 类功能说明: 告警规则
*
* Copyright: Copyright(c) 2013
* Company: COSHAHO
* @Version 1.0
* @Author coshaho
*/
public class AlarmRule
{
private String name;
private String type;
private String threshold;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public String getThreshold() {
return threshold;
}
public void setThreshold(String threshold) {
this.threshold = threshold;
}
}
7、规则创建责任链
package com.coshaho.learn.handler;
/**
*
* AlarmRuleCreator.java Create on 2017年5月5日 下午11:56:45
*
* 类功能说明: 告警规则创建
*
* Copyright: Copyright(c) 2013
* Company: COSHAHO
* @Version 1.0
* @Author coshaho
*/
public class AlarmRuleCreator
{
private AbstractRuleHandler alarmRuleHandler;
public AlarmRuleCreator()
{
alarmRuleHandler = new ThresholdParseHandler();
alarmRuleHandler.setNextHandler(new StreamGenerateHandler())
.setNextHandler(new RulePesistHandler());
}
public void create(AlarmRule rule)
{
alarmRuleHandler.doHandle(rule);
}
public static void main(String[] args)
{
AlarmRule rule = new AlarmRule();
rule.setThreshold("cpuRate < 10");
rule.setName("Cpu Alarm");
AlarmRuleCreator ruleCreator = new AlarmRuleCreator();
ruleCreator.create(rule);
System.out.println();
rule.setName("");
ruleCreator.create(rule);
}
}
测试结果
Parse threshold success. Threshold is cpuRate < 10
Generate stream success.
Persist rule success. Rule name is Cpu Alarm
Parse threshold success. Threshold is cpuRate < 10
Generate stream success.
Roll persist rule. Rule name is
Roll Generate stream.
Roll parse threshold. Threshold is cpuRate < 10
