[發(fā)明專利]一種多節(jié)點撮合訂單的方法、系統(tǒng)及設備

在審

• 申請?zhí)枺?/td>: 202210610532.1
• 申請日: 2022-05-31
• 公開（公告）號: CN115204965A
• 公開（公告）日: 2022-10-18
• 發(fā)明（設計）人: 徐鴻杰
• 申請（專利權(quán)）人: 杭州隆埠科技有限公司
• 主分類號: G06Q30/06
• 分類號: G06Q30/06;G06F16/25;G06F9/54
• 代理公司: 上海百一領御專利代理事務所(普通合伙) 31243
• 代理人: 楊顏顏

1.一種多節(jié)點撮合訂單的方法，其中，所述方法包括：

獲取多個待處理訂單請求，將多個待處理訂單請求轉(zhuǎn)入多個代理服務中，通過所述多個代理服務對所述多個待處理請求進行并行預處理得到多個消息類型的訂單；

將所有消息類型的訂單放入第一流處理消息隊列中，將每個第一流處理消息隊列中的消息類型的訂單發(fā)送至多個撮合引擎；

通過所述多個撮合引擎對所述消息類型的訂單進行撮合處理，得到成交信息，將所述成交信息放入第二流處理消息隊列中；

將第二流處理消息隊列中的成交信息進行去重處理，得到去重后的成交信息，將去重后的成交信息寫入數(shù)據(jù)庫，完成訂單撮合處理。

2.根據(jù)權(quán)利要求1所述的方法，其中，所述通過所述多個代理服務對所述多個待處理請求進行并行預處理得到多個消息類型的訂單，包括：

獲取所有待處理訂單的訂單參數(shù)，通過所述多個代理服務對所述訂單參數(shù)進行并行校驗，得到通過校驗的訂單；

將通過校驗的訂單對應的格式轉(zhuǎn)成消息類型，得到消息類型的訂單。

3.根據(jù)權(quán)利要求1所述的方法，其中，將每個第一流處理消息隊列中的消息類型的訂單發(fā)送至多個撮合引擎，包括：

基于第一流處理消息隊列的廣播機制將每個第一流處理消息隊列中的消息類型的訂單發(fā)送至多個撮合引擎。

4.根據(jù)權(quán)利要求1所述的方法，其中，所述通過所述多個撮合引擎對所述消息類型的訂單進行撮合處理，得到成交信息，包括：

使用所述多個撮合引擎匹配所述消息類型的訂單，當存在成交的訂單時，根據(jù)成交的訂單對應的信息生成成交信息。

5.根據(jù)權(quán)利要求4所述的方法，其中，將第二流處理消息隊列中的成交信息進行去重處理，包括：

使用冪等隊列對第二流處理消息隊列中的成交信息進行去重處理。

6.根據(jù)權(quán)利要求5所述的方法，其中，根據(jù)成交的訂單對應的信息生成成交信息，包括：

根據(jù)成交的訂單對應的信息生成成交訂單唯一標識碼。

7.根據(jù)權(quán)利要求6所述的方法，其中，使用冪等隊列對第二流處理消息隊列中的成交信息進行去重處理，包括：

獲取單一成交信息時判斷在冪等隊列中是否存在所述成交信息對應的訂單唯一標識碼，若是，則拋棄所述成交信息；

若否，則在冪等隊列中存儲所述成交信息對應的訂單唯一標識碼。

8.根據(jù)權(quán)利要求1所述的方法，其中，所述將去重后的成交信息寫入數(shù)據(jù)庫之前，還包括：

根據(jù)去重后的成交信息確定對應的二進制日志文件。

9.根據(jù)權(quán)利要求1所述的方法，其中，所述第一流處理消息隊列包括KAFKA，所述第二流處理消息隊列包括KAFKA。

10.一種用于多節(jié)點撮合訂單的系統(tǒng)，其中，所述系統(tǒng)包括至少一個代理服務、至少兩個撮合引擎、去重模塊和數(shù)據(jù)庫，其中，

所述至少一個代理服務獲取多個待處理訂單請求，對所述多個待處理請求進行并行預處理得到多個消息類型的訂單，將所有消息類型的訂單放入第一流處理消息隊列中，將每個第一流處理消息隊列中的消息類型的訂單發(fā)送至所述撮合引擎；

所述至少兩個撮合引擎獲取第一流處理消息隊列中的消息類型的訂單，對所述消息類型的訂單進行撮合處理，得到成交信息，將所述成交信息放入第二流處理消息隊列中；

所述去重模塊獲取所述第二流處理消息隊列中的成交信息，將所述成交信息進行去重處理，得到去重后的成交信息，以使得所述數(shù)據(jù)庫獲取所述去重后的成交信息；

所述數(shù)據(jù)庫獲取所述去重后的成交信息，完成訂單撮合處理。

11.根據(jù)權(quán)利要求10所述的系統(tǒng)，其中，所述系統(tǒng)還包括日志模塊，其中，

所述日志模塊根據(jù)去重后的成交信息確定對應的二進制日志文件。