CanalRowConvertablebinlog数据转换处理接口
......
AbstractCanalRowComputerbinlog数据计算处理基类
AbstractComputer计算器基类
N：返回队列
WeixinNotifier
DeliveryExceptionOrderDataConverterdelivery_exception_oder转换实现
AbstractOfsCanalRowListenerbinlog库表通用处理基类
PicklistOrderDataConverterdelivery_order表转换实现
ExpressionExecutor表达式执行引擎
END
计算参数是否满足?
Redis:GetAndPut
核心流程
MsgNoticeable消息通知接口
RegComputerService规则数据计算服务
SmsNotifier
是否表达式计算器
DevliveryOrderListenerdelivery_order表监听实现
CustomerLogic自定义逻辑处理
Dubbo:RequestAndResponse
PicklistOrderDataComputerdelivery_order表计算实现
AbstractMsgNotifier消息处理基类
ExpressionComputer表达式计算器
计算结果是否满足预期
EmailNotifier
RegComputable计算接口
AbstractOfsCanalRowConverterbinlog通用处理基类
alarm-center
Y
PicklistOrderListenerpicklist_order表监听实现
DevliveryExceptionOrderListenerdelivery_exception_oder表监听实现
START
可选，扩展使用
CustomerComputer自定义计算器
CannalMonitorServiceBinlog监控服务
N：SetResultAndFail
Y：SetResultAndSuccess
OtherCustomerComputer其他自定义计算器具体实现
N
DeliveryOrderDataComputerdelivery_exception_oder表计算实现
CanalRowMonitableBinlog库表监听接口
计算结果是否满足触发条件？
CanalRowComputablebinlog数据计算接口
是否是要监控的库表
AlarmRedisCacher缓存收集参数或者双落
ComputerRegistable计算器注册接口
alarm-makeup
