一種分布式異步數(shù)據(jù)通訊的處理方法、裝置、介質(zhì)和設(shè)備

基本信息

申請(qǐng)?zhí)?/td> CN202111459260.1 申請(qǐng)日 -
公開(kāi)(公告)號(hào) CN114116262A 公開(kāi)(公告)日 2022-03-01
申請(qǐng)公布號(hào) CN114116262A 申請(qǐng)公布日 2022-03-01
分類(lèi)號(hào) G06F9/54(2006.01)I;G06F9/46(2006.01)I;G06F16/27(2019.01)I 分類(lèi) 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 王亞飛 申請(qǐng)(專利權(quán))人 北京宇信科技集團(tuán)股份有限公司
代理機(jī)構(gòu) 北京卓嵐智財(cái)知識(shí)產(chǎn)權(quán)代理事務(wù)所(特殊普通合伙) 代理人 沈煜華
地址 100044北京市海淀區(qū)高梁橋斜街42號(hào)院1號(hào)樓5層1-519
法律狀態(tài) -

摘要

摘要 本發(fā)明實(shí)施例提供一種分布式異步數(shù)據(jù)通訊的處理方法、裝置、介質(zhì)及設(shè)備,通過(guò)發(fā)送端設(shè)備接收到發(fā)送業(yè)務(wù)操作的命令后,執(zhí)行所述業(yè)務(wù)操作的數(shù)據(jù)庫(kù)事務(wù)提交,使得業(yè)務(wù)操作的業(yè)務(wù)數(shù)據(jù)落入數(shù)據(jù)庫(kù)后,發(fā)送一條異步消息到消息隊(duì)列,監(jiān)測(cè)異步消息的發(fā)送狀態(tài)并在本地發(fā)送消息表中插入一條與異步消息對(duì)應(yīng)的異步消息發(fā)送記錄,最后在確定消息隊(duì)列接收異步消息成功后,更新異步消息發(fā)送記錄中的發(fā)送狀態(tài)的標(biāo)識(shí);消費(fèi)端設(shè)備接收消息隊(duì)列中的異步消息,并在本地消費(fèi)消息表中插入一條與異步消息對(duì)應(yīng)的異步消息消費(fèi)記錄,根據(jù)異步消息的發(fā)送狀態(tài)確定是否按照異步消息的消費(fèi)內(nèi)容執(zhí)行業(yè)務(wù)處理。本發(fā)明實(shí)施例能夠保證分布式異步數(shù)據(jù)通訊的可靠性。