[發明專利]基于事件驅動的消息發布方法、裝置及系統

在審

• 申請號: 202010521046.3
• 申請日: 2020-06-10
• 公開（公告）號: CN111679922A
• 公開（公告）日: 2020-09-18
• 發明（設計）人: 姜俊秀
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/27
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 王天堯;湯在彥

1.一種基于事件驅動的消息發布方法，其特征在于，包括：

接收各個信息發布系統基于事件驅動發布的待發布消息；

將接收到的待發布消息，存儲到分布式數據庫表中；

將分布式數據庫表中存儲的待發布消息，路由至一個或多個消息隊列，其中，每個消息隊列對應一個信息獲取系統；

將各個消息隊列中的待發布消息，發送到對應的信息獲取系統。

2.如權利要求1所述的方法，其特征在于，所述方法還包括：

對待發布消息進行格式轉換。

3.如權利要求1所述的方法，其特征在于，所述方法還包括：

記錄消息發布控制表，其中，所述消息發布控制表中包含：發布每條待發布消息的信息發布系統、調用每條待發布消息的信息獲取系統、存儲每條待發布消息的分布式數據表、傳輸每條待發布消息的消息隊列。

4.如權利要求1所述的方法，其特征在于，在將接收到的待發布消息，存儲到分布式數據庫表中之前，所述方法還包括：

丟棄重復的待發布消息。

5.如權利要求1所述的方法，其特征在于，在將各個消息隊列中的待發布消息，發送到對應的信息獲取系統之后，所述方法還包括：

接收信息獲取系統返回的響應結果，其中，所述響應結果用于表征所述信息獲取系統是否成功調用接收到的待發布消息；

根據響應結果，確定是否重新發送所述待發布消息。

6.一種基于事件驅動的消息發布裝置，其特征在于，包括：

消息接收模塊，用于接收各個信息發布系統基于事件驅動發布的待發布消息；

分布式存儲模塊，用于將接收到的待發布消息，存儲到分布式數據庫表中；

路由模塊，用于將分布式數據庫表中存儲的待發布消息，路由至一個或多個消息隊列，每個消息隊列對應一個信息獲取系統；

消息發送模塊，用于將各個消息隊列中的待發布消息，發送到對應的信息獲取系統。

7.如權利要求6所述的裝置，其特征在于，所述裝置還包括：

格式轉換模塊，用于對待發布消息進行格式轉換。

8.如權利要求6所述的裝置，其特征在于，所述裝置還包括：

跟蹤訂閱模塊，用于記錄消息發布控制表，其中，所述消息發布控制表中包含：發布每條待發布消息的信息發布系統、調用每條待發布消息的信息獲取系統、存儲每條待發布消息的分布式數據表、傳輸每條待發布消息的消息隊列。

9.如權利要求6所述的裝置，其特征在于，所述消息接收模塊還用于丟棄重復的待發布消息。

10.如權利要求6所述的裝置，其特征在于，所述消息發送模塊還用于接收信息獲取系統返回的響應結果，以及根據響應結果，確定是否重新發送所述待發布消息，其中，所述響應結果用于表征所述信息獲取系統是否成功調用接收到的待發布消息。

11.一種基于事件驅動的消息發布系統，其特征在于，包括：

至少一個信息發布系統，用于發布待發布消息；

信息發布平臺，與各個信息發布系統通信，用于接收各個信息發布系統基于事件驅動發布的待發布消息，將接收到的待發布消息，存儲到分布式數據庫表中，并將分布式數據庫表中存儲的待發布消息，路由至一個或多個消息隊列，發送到對應的信息獲取系統，其中，每個消息隊列對應一個信息獲取系統；

至少一個信息獲取系統，分別與所述信息發布平臺通信，用于接收所述信息發布平臺通過消息隊列發送的待發布消息。

12.一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現權利要求1至5任一項所述基于事件驅動的消息發布方法。

13.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質存儲有執行權利要求1至5任一項所述基于事件驅動的消息發布方法的計算機程序。