一種松耦合的分布式工作流協(xié)調(diào)系統(tǒng)和方法

基本信息

申請(qǐng)?zhí)?/td> CN202111061941.2 申請(qǐng)日 -
公開(kāi)(公告)號(hào) CN113821322A 公開(kāi)(公告)日 2021-12-21
申請(qǐng)公布號(hào) CN113821322A 申請(qǐng)公布日 2021-12-21
分類號(hào) G06F9/48(2006.01)I;G06F9/50(2006.01)I;G06F9/54(2006.01)I 分類 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 劉媛媛;陳廷梁 申請(qǐng)(專利權(quán))人 浙江數(shù)新網(wǎng)絡(luò)有限公司
代理機(jī)構(gòu) 杭州求是專利事務(wù)所有限公司 代理人 劉靜
地址 311121浙江省杭州市余杭區(qū)倉(cāng)前街道文一西路1218號(hào)7幢101-17室
法律狀態(tài) -

摘要

摘要 本發(fā)明公開(kāi)了一種松耦合的分布式工作流協(xié)調(diào)系統(tǒng)和方法,用戶通過(guò)調(diào)用接口服務(wù)API,對(duì)工作流進(jìn)行定義、上線和運(yùn)維等;分布式工作流協(xié)調(diào)器Coordinator通過(guò)集成分布式定時(shí)引擎Quartz,來(lái)定時(shí)調(diào)度工作流并添加到工作流派發(fā)分布式消息隊(duì)列MQ,接收工作流并處理其任務(wù)依賴關(guān)系,將協(xié)調(diào)后待執(zhí)行的業(yè)務(wù)型任務(wù)添加到任務(wù)派發(fā)分布式消息隊(duì)列MQ;分布式任務(wù)執(zhí)行器Worker從任務(wù)派發(fā)分布式消息隊(duì)列MQ中接收各業(yè)務(wù)型任務(wù)并執(zhí)行,將任務(wù)執(zhí)行結(jié)果通過(guò)任務(wù)回調(diào)分布式消息隊(duì)列MQ回調(diào)至分布式工作流協(xié)調(diào)器Coordinator;最后Coordinator將任務(wù)執(zhí)行結(jié)果持久化保存到數(shù)據(jù)庫(kù),用于反饋用戶。本發(fā)明將Coordinator專注于邏輯協(xié)調(diào)處理,保證工作流協(xié)調(diào)處理與任務(wù)執(zhí)行充分解耦,提升系統(tǒng)的吞吐量、擴(kuò)展性以及伸縮性。