[發(fā)明專利]分布式事務(wù)的消息訂閱方法、電子裝置及可讀存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201810546879.8
• 申請(qǐng)日: 2018-05-31
• 公開(kāi)（公告）號(hào): CN108874558A
• 公開(kāi)（公告）日: 2018-11-23
• 發(fā)明（設(shè)計(jì)）人: 孫志博
• 申請(qǐng)（專利權(quán)）人: 康鍵信息技術(shù)（深圳）有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F9/46
• 代理公司: 深圳市沃德知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44347
• 代理人: 高杰;于志光

1.一種電子裝置，其特征在于，所述電子裝置包括存儲(chǔ)器、處理器，所述存儲(chǔ)器上存儲(chǔ)有可在所述處理器上運(yùn)行的分布式事務(wù)的消息訂閱系統(tǒng)，所述分布式事務(wù)的消息訂閱系統(tǒng)被所述處理器執(zhí)行時(shí)實(shí)現(xiàn)如下步驟：

獲取主數(shù)據(jù)庫(kù)發(fā)送的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)發(fā)送的從數(shù)據(jù)庫(kù)日志；

將獲取的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)日志解析為消息，并根據(jù)解析的消息形成消息隊(duì)列；

將所述消息隊(duì)列中的消息通知給預(yù)先訂閱消息的業(yè)務(wù)系統(tǒng)，以將消息反饋給所述業(yè)務(wù)系統(tǒng)的用戶，便于用戶根據(jù)反饋的消息執(zhí)行下一步業(yè)務(wù)邏輯；其中，所述主數(shù)據(jù)庫(kù)日志、從數(shù)據(jù)庫(kù)日志為所述業(yè)務(wù)系統(tǒng)根據(jù)用戶指令對(duì)所述主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)進(jìn)行相應(yīng)的數(shù)據(jù)操作產(chǎn)生的數(shù)據(jù)庫(kù)日志。

2.如權(quán)利要求1所述的電子裝置，其特征在于，所述分布式事務(wù)的消息訂閱系統(tǒng)被所述處理器執(zhí)行實(shí)現(xiàn)所述獲取主數(shù)據(jù)庫(kù)發(fā)送的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)發(fā)送的從數(shù)據(jù)庫(kù)日志的步驟時(shí)，包括：

獲取主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)的位置；

根據(jù)所述主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)的位置向所述主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)發(fā)送日志獲取指令；

獲取所述主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)在進(jìn)行數(shù)據(jù)操作時(shí)產(chǎn)生的主數(shù)據(jù)庫(kù)日志、從數(shù)據(jù)庫(kù)日志；

所述將獲取的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)日志解析為消息，并根據(jù)解析的消息形成消息隊(duì)列的步驟包括：

將獲取的主數(shù)據(jù)庫(kù)日志、從數(shù)據(jù)庫(kù)日志傳遞至預(yù)先設(shè)定的內(nèi)存隊(duì)列；

將所述預(yù)先設(shè)定的內(nèi)存隊(duì)列中的主數(shù)據(jù)庫(kù)日志、從數(shù)據(jù)庫(kù)日志轉(zhuǎn)換為消息并形成消息隊(duì)列。

3.如權(quán)利要求1或2所述的電子裝置，其特征在于，預(yù)先將所述主數(shù)據(jù)庫(kù)和從數(shù)據(jù)庫(kù)對(duì)應(yīng)設(shè)置類別Topic，將所述主數(shù)據(jù)庫(kù)和從數(shù)據(jù)庫(kù)作為消息數(shù)據(jù)生產(chǎn)者Producer，將所述業(yè)務(wù)系統(tǒng)作為消息數(shù)據(jù)消費(fèi)者Consumer；所述獲取主數(shù)據(jù)庫(kù)發(fā)送的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)發(fā)送的從數(shù)據(jù)庫(kù)日志的步驟包括：

獲取消息數(shù)據(jù)生產(chǎn)者Producer發(fā)布的數(shù)據(jù)庫(kù)日志，并按對(duì)應(yīng)的類別Topic進(jìn)行保存；

所述將所述消息隊(duì)列中的消息通知給預(yù)先訂閱消息的業(yè)務(wù)系統(tǒng)的步驟包括：

將所述消息隊(duì)列中的消息通知給預(yù)先訂閱了類別Topic消息的消息數(shù)據(jù)消費(fèi)者Consumer。

4.如權(quán)利要求3所述的電子裝置，其特征在于，在所述獲取主數(shù)據(jù)庫(kù)發(fā)送的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)發(fā)送的從數(shù)據(jù)庫(kù)日志的步驟之后，所述處理器還用于執(zhí)行所述分布式事務(wù)的消息訂閱系統(tǒng)，以實(shí)現(xiàn)以下步驟：

利用分布式一致性算法Paxos將主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)日志協(xié)調(diào)到最終達(dá)成一致。

5.一種分布式事務(wù)的消息訂閱方法，其特征在于，所述分布式事務(wù)的消息訂閱方法包括：

獲取主數(shù)據(jù)庫(kù)發(fā)送的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)發(fā)送的從數(shù)據(jù)庫(kù)日志；

將獲取的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)日志解析為消息，并根據(jù)解析的消息形成消息隊(duì)列；

將所述消息隊(duì)列中的消息通知給預(yù)先訂閱消息的業(yè)務(wù)系統(tǒng)，以將消息反饋給所述業(yè)務(wù)系統(tǒng)的用戶，便于用戶根據(jù)反饋的消息執(zhí)行下一步業(yè)務(wù)邏輯；其中，所述主數(shù)據(jù)庫(kù)日志、從數(shù)據(jù)庫(kù)日志為所述業(yè)務(wù)系統(tǒng)根據(jù)用戶指令對(duì)所述主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)進(jìn)行相應(yīng)的數(shù)據(jù)操作產(chǎn)生的數(shù)據(jù)庫(kù)日志。

6.如權(quán)利要求5所述的分布式事務(wù)的消息訂閱方法，其特征在于，所述獲取主數(shù)據(jù)庫(kù)發(fā)送的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)發(fā)送的從數(shù)據(jù)庫(kù)日志的步驟包括：

獲取主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)的位置；

根據(jù)所述主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)的位置向所述主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)發(fā)送日志獲取指令；

獲取所述主數(shù)據(jù)庫(kù)、從數(shù)據(jù)庫(kù)在進(jìn)行數(shù)據(jù)操作時(shí)產(chǎn)生的主數(shù)據(jù)庫(kù)日志、從數(shù)據(jù)庫(kù)日志；

所述將獲取的主數(shù)據(jù)庫(kù)日志和從數(shù)據(jù)庫(kù)日志解析為消息，并根據(jù)解析的消息形成消息隊(duì)列的步驟包括：

將獲取的主數(shù)據(jù)庫(kù)日志、從數(shù)據(jù)庫(kù)日志傳遞至預(yù)先設(shè)定的內(nèi)存隊(duì)列；

將所述預(yù)先設(shè)定的內(nèi)存隊(duì)列中的主數(shù)據(jù)庫(kù)日志、從數(shù)據(jù)庫(kù)日志轉(zhuǎn)換為消息并形成消息隊(duì)列。