[發明專利]業務消息傳輸方法、裝置、計算機設備和存儲介質

在審

• 申請號: 202110954108.4
• 申請日: 2021-08-19
• 公開（公告）號: CN113656199A
• 公開（公告）日: 2021-11-16
• 發明（設計）人: 牛亮亮;趙楠;張衛;李杰;賀東賓;廖志勇;林澤南;楊超;陳冉;張彬彬
• 申請（專利權）人: 深圳華銳金融技術股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 劉羚

1.一種業務消息傳輸方法，其特征在于，應用于發送端，所述發送端部署有發送隊列和第一持久化文件，所述方法包括：

獲取業務消息；

嘗試將所述業務消息存放至所述發送隊列；

將所述業務消息存放至所述第一持久化文件；

若業務消息未成功存放至發送隊列，則后續不再嘗試將所述業務消息存放至所述發送隊列，從所述第一持久化文件讀取所述業務消息，嘗試將讀取的所述業務消息存放至所述發送隊列；

從所述發送隊列讀取所述業務消息，將讀取的所述業務消息發送至接收端，以指示所述接收端將所述業務消息存放至第二持久化文件，嘗試將接收到的所述業務消息存放至接收隊列，若業務消息未成功存放至接收隊列，則從所述第二持久化文件讀取所述業務消息，嘗試將讀取的所述業務消息存放至所述接收隊列，從所述接收隊列讀取所述業務消息，將讀取的所述業務消息發送至應用層。

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

若業務消息成功存放至發送隊列，則執行所述從所述發送隊列讀取所述業務消息的步驟及其后續步驟。

3.根據權利要求1或2所述的方法，其特征在于，所述從所述第一持久化文件讀取所述業務消息，嘗試將讀取的所述業務消息存放至所述發送隊列之后，所述方法包括：

檢測所述第一持久化文件中堆積的業務消息的數量；

當所述堆積的業務消息的數量小于預設數量閾值時，執行所述嘗試將所述業務消息存放至所述發送隊列的步驟及其后續步驟。

4.一種業務消息傳輸方法，其特征在于，應用于接收端，所述接收端部署有接收隊列和第二持久化文件，所述方法包括：

接收發送端發送的業務消息；所述發送端發送的業務消息是從發送隊列讀取得到；

將所述業務消息存放至第二持久化文件；

嘗試將所述業務消息存放至所述接收隊列；

若業務消息未成功存放至接收隊列，則從所述第二持久化文件讀取所述業務消息，嘗試將讀取的所述業務消息存放至所述接收隊列；

從所述接收隊列讀取所述業務消息，將讀取的所述業務消息發送至應用層。

5.根據權利要求4所述的方法，其特征在于，所述方法還包括：

若業務消息成功存放至接收隊列，則執行所述從所述接收隊列讀取所述業務消息，將讀取的所述業務消息發送至應用層的步驟。

6.根據權利要求4所述的方法，其特征在于，所述接收隊列中的每一條業務消息對應有各自的消息序列號，所述方法還包括：

當所述接收隊列中的業務消息的消息序列號連續時，執行所述從所述接收隊列讀取所述業務消息，將讀取的所述業務消息發送至應用層的步驟；

當所述接收隊列中的業務消息的消息序列號不連續時，從所述第二持久化文件讀取所述接收隊列中所缺失消息序列號對應的業務消息，將讀取的所述接收隊列中所缺失消息序列號對應的業務消息發送至應用層。

7.一種業務消息傳輸裝置，其特征在于，應用于發送端，所述發送端部署有發送隊列和第一持久化文件，所述裝置包括：

獲取模塊，用于獲取業務消息；

第一存儲模塊，用于嘗試將所述業務消息存放至所述發送隊列；將所述業務消息存放至所述第一持久化文件；

第一讀取模塊，用于若業務消息未成功存放至發送隊列，則后續不再嘗試將所述業務消息存放至所述發送隊列，從所述第一持久化文件讀取所述業務消息；

所述第一存儲模塊還用于嘗試將讀取的所述業務消息存放至所述發送隊列；

所述第一讀取模塊還用于從所述發送隊列讀取所述業務消息；

第一發送模塊，用于將讀取的所述業務消息發送至接收端，以指示所述接收端將所述業務消息存放至第二持久化文件，嘗試將接收到的所述業務消息存放至接收隊列，若業務消息未成功存放至接收隊列，則從所述第二持久化文件讀取所述業務消息，嘗試將讀取的所述業務消息存放至所述接收隊列，從所述接收隊列讀取所述業務消息，將讀取的所述業務消息發送至應用層。