叶彬：弹性可伸缩海量工作流引擎建设实践.docx

弹性可伸缩海量工作流引擎建设实践

腾讯架构师/叶彬

InfoQ极客传媒

目录

·背景

·工作流引擎技术选型·高可用架构落地实践·落地场景与取得效果·下一步计划与思考

InfoQ极客传媒

zB

示

InfoQ极客传媒

什么是工作流

即工作流程的计算模型，为完成一个业务目标，所需要经历的一系列步骤，通常用流程图来表示(业界通常用BPMN流程图来描述一个工作流)

示例：服务器硬件故障自动诊断流程，日志下载→规则库加载→策略匹配

日志下载规则加载规则匹配

结束开始

结束

InfoQ极客传媒

非工作流模式下系统实现

非工作流模式下，原始需求：日志下载→规则库加载→规则匹配

classLogsLoadTask{voidhandle(){

doLogsLoad();

rulesLoadTask.handle();-}

classRulesLoadTask{voidhandle(){

doRulesLoad();

rulesMatchTask.handle();}

classRulesMatchTask{

voidhandle(){

doRulesMatch();

}

新增需求：1)指定机型派单人工分析；2)命中指定规则派单至厂商分析

InfoQ极客传媒

非工作流模式下的问题

耦合高、调整难、复用低classManualAnalyTask{classSupplyDiagnoseTask{

voidhandle(){voidhandle(){

doSupplierDiagnose();新增逻辑块1doManualAnalysis();

doSupplierDiagnose();

新增逻辑块1

}

」新增逻辑块2

」

}

classLogsLoadTask{voidhandle(){

doLogsLoad();

if(isSpecialServer){

manualAnalyTask.handle()

lelse{

rulesLoadTask.handle();

}

}

}

classRulesLoadTask{

voidhandle(){

doRulesLoad();

rulesMatchTask.handle();一

}

}

classRulesMatchTask{

voidhandle(){

doRulesMatch();if(isSpecialRule){

supplyDiagnoseTask.handle();

新加业务场景，要改已有的代码。→这不符合开闭原则!

InfoQ极客传媒

云

么T女FU

使用工作流模式的任务协作-分离任务实现和任务协作关系

日志下载规则加载规则匹配

开始结束

classLogsLoadTask{

voidhandle(){

doLogsLoad();

rulesLoadTask.handle();

}

classRulesLoadTask{

voidhandle(){

doRulesLoad();

rulesMatchTask.handle();

}

}

classRulesMatchTask{

voidhandle(){

doRulesMatch();

」

}

使用工作流模式，各任务只实现自身原子逻辑，协同关系使用流程图表示

InfoQ极客传媒

为什么需要工作流

当新的逻辑需要复用已有任务节点时，只需调整流程图，无需修改已有代码

classSupplierAnalysisTask{voidhandle(){

classSupplierAnalysisTask{

voidhandle(){

voidhandle(){

doSupplierAnalysis();doManualAnalysis

doSupplierAnalysis();

}}

}

BPMN流程图

人工分析