一種基于消息隊(duì)列的分布式事務(wù)處理方法及系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN201911404579.7 申請(qǐng)日 -
公開（公告）號(hào) CN111158933A 公開（公告）日 2020-05-15
申請(qǐng)公布號(hào) CN111158933A 申請(qǐng)公布日 2020-05-15
分類號(hào) G06F9/54 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 王海峰 申請(qǐng)（專利權(quán)）人 易票聯(lián)支付有限公司
代理機(jī)構(gòu) 廣州嘉權(quán)專利商標(biāo)事務(wù)所有限公司 代理人 譚英強(qiáng);黎揚(yáng)鵬
地址 510000 廣東省廣州市海珠區(qū)廣州大道南368號(hào)11樓
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種基于消息隊(duì)列的分布式事務(wù)處理方法及系統(tǒng)，方法包括：對(duì)發(fā)送的消息進(jìn)行順序編號(hào)；將發(fā)送的消息及其順序編號(hào)寫入發(fā)送日志；發(fā)送消息給服務(wù)端，使服務(wù)端獲取消息的順序編號(hào)并與第一數(shù)據(jù)庫(kù)中存儲(chǔ)的順序編號(hào)進(jìn)行比較，當(dāng)二者的順序編號(hào)不連續(xù)則確定缺漏的起始順序編號(hào)和結(jié)束順序編號(hào)，當(dāng)二者的順序編號(hào)連續(xù)則將消息發(fā)送給消息隊(duì)列；根據(jù)起始順序編號(hào)和結(jié)束順序編號(hào)從發(fā)送日志中獲取缺漏數(shù)據(jù)，并將缺漏數(shù)據(jù)發(fā)送給服務(wù)端。本發(fā)明利用了發(fā)送日志和在第一數(shù)據(jù)庫(kù)這一非關(guān)系型數(shù)據(jù)庫(kù)中存儲(chǔ)的順序編號(hào)來(lái)保證消息發(fā)送成功，從而確保了消息隊(duì)列與業(yè)務(wù)系統(tǒng)的數(shù)據(jù)一致性，也簡(jiǎn)化了業(yè)務(wù)系統(tǒng)的開發(fā)過程。本發(fā)明可廣泛應(yīng)用于計(jì)算機(jī)技術(shù)領(lǐng)域。