一種基于AMQP協(xié)議的高可靠性任務(wù)調(diào)度方法和系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN201710985447.2 申請(qǐng)日 -
公開(kāi)（公告）號(hào) CN107943567B 公開(kāi)（公告）日 2021-12-28
申請(qǐng)公布號(hào) CN107943567B 申請(qǐng)公布日 2021-12-28
分類號(hào) G06F9/48（2006.01）I;G06F9/54（2006.01）I 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 孫耀輝 申請(qǐng)（專利權(quán)）人 北京知道未來(lái)信息技術(shù)有限公司
代理機(jī)構(gòu) 北京君尚知識(shí)產(chǎn)權(quán)代理有限公司 代理人 邱曉鋒
地址 100102北京市朝陽(yáng)區(qū)阜通東大街1號(hào)院3號(hào)樓1單元112102室
法律狀態(tài) -

摘要

摘要 本發(fā)明涉及一種基于AMQP協(xié)議的高可靠性任務(wù)調(diào)度方法和系統(tǒng)。該方法包括：1）將任務(wù)拆分為若干子任務(wù)，并將子任務(wù)放入任務(wù)隊(duì)列；2）記錄未收到確認(rèn)回執(zhí)的子任務(wù)狀態(tài)到子任務(wù)狀態(tài)集，并將子任務(wù)狀態(tài)集持久化存儲(chǔ)；3）從任務(wù)隊(duì)列中獲取子任務(wù)，然后執(zhí)行子任務(wù)并將執(zhí)行結(jié)果放入結(jié)果隊(duì)列；4）從結(jié)果隊(duì)列中獲取執(zhí)行結(jié)果并將其作為確認(rèn)回執(zhí)，從子任務(wù)狀態(tài)集中刪除對(duì)應(yīng)子任務(wù)的狀態(tài)信息，并將更新后的子任務(wù)狀態(tài)集持久化存儲(chǔ)。當(dāng)災(zāi)備場(chǎng)景發(fā)生時(shí)，從持久化存儲(chǔ)中獲取子任務(wù)狀態(tài)集，重新生成子任務(wù)并恢復(fù)到任務(wù)隊(duì)列中。本發(fā)明有效避免了任務(wù)的重復(fù)調(diào)度、任務(wù)和任務(wù)結(jié)果丟失等問(wèn)題的發(fā)生，保證了調(diào)度系統(tǒng)的可靠性和任務(wù)結(jié)果的高可靠性。