[發明專利]數據傳輸方法、裝置、計算機系統及可讀存儲介質

有效

• 申請號: 202110186763.X
• 申請日: 2021-02-10
• 公開（公告）號: CN112953769B
• 公開（公告）日: 2022-10-11
• 發明（設計）人: 康棟山;張健雯;霍華仔;萬旭
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: H04L41/0803
• 分類號: H04L41/0803;H04L67/566
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 孫蕾

1.一種數據傳輸方法，應用于應用服務器，包括：

向至少兩個消息隊列服務器中的一個消息隊列服務器發送報文；

在接收到由所述消息隊列服務器發送的用于標識所述報文發送失敗的信息的情況下，采用輪詢的方式向所述至少兩個消息隊列服務器中的其他消息隊列服務器發送所述報文，直至接收到用于標識所述報文發送成功的信息為止；

按照預設時間間隔，分別向所述至少兩個消息隊列服務器進行收報操作；

在所述至少兩個消息隊列服務器中的其中一個消息隊列服務器中獲取目標報文；以及

在所述消息隊列服務器中的數據被多個所述應用服務器中的其中一個應用服務器獲取的情況下，在所述消息隊列服務器中刪除所述數據，以使所述多個應用服務器中的其他應用服務器不能獲取所述數據；

其中，所述至少兩個消息隊列服務器中的數據采用分布式文件共享的方式存儲。

2.根據權利要求1所述的方法，其中，在所述向至少兩個消息隊列服務器中的一個消息隊列服務器發送報文之前，所述方法還包括：

在所述應用服務器與所述至少兩個消息隊列服務器之間分別建立網絡連接。

3.根據權利要求2所述的方法，其中，所述在所述應用服務器與至少兩個消息隊列服務器之間分別建立網絡連接包括：

判斷所述網絡連接是否正常；

在所述網絡連接正常的情況下，確定所述應用服務器與所述至少兩個消息隊列服務器之間分別建立的網絡正常；

在所述網絡連接不正常的情況下，重新執行建立網絡連接操作直至所述網絡連接正常。

4.根據權利要求2所述的方法，其中，所述應用服務器包括多個；

所述在所述應用服務器與所述至少兩個消息隊列服務器之間分別建立網絡連接包括：

在多個所述應用服務器中的每個應用服務器與所述至少兩個消息隊列服務器之間，采用笛卡爾積交叉連接的方式分別建立網絡連接。

5.根據權利要求1所述的方法，還包括：

獲取用戶終端發送的用于處理報文的請求；其中，所述請求中攜帶所述報文；

響應于所述請求，執行所述向所述至少兩個消息隊列服務器中的一個消息隊列服務器發送報文的操作。

6.一種數據傳輸裝置，包括：

發送模塊，用于向至少兩個消息隊列服務器中的一個消息隊列服務器發送報文；

輪詢模塊，用于在接收到由所述消息隊列服務器發送的用于標識所述報文發送失敗的信息的情況下，采用輪詢的方式向所述至少兩個消息隊列服務器中的其他消息隊列服務器發送所述報文，直至接收到用于標識所述報文發送成功的信息為止；

收報模塊，用于按照預設時間間隔，分別向至少兩個消息隊列服務器進行收報操作；

報文獲取模塊，用于在至少兩個消息隊列服務器中的其中一個消息隊列服務器中獲取目標報文；以及

刪除模塊，用于在消息隊列服務器中的數據被多個應用服務器中的其中一個應用服務器獲取的情況下，在消息隊列服務器中刪除數據，以使多個應用服務器中的其他應用服務器不能獲取數據；

其中，至少兩個消息隊列服務器中的數據采用分布式文件共享的方式存儲。

7.一種計算機系統，包括：

一個或多個處理器；

存儲器，用于存儲一個或多個程序，

其中，當所述一個或多個程序被所述一個或多個處理器執行時，使得所述一個或多個處理器實現權利要求1至5中任一項所述的方法。

8.一種計算機可讀存儲介質，其上存儲有可執行指令，該指令被處理器執行時使處理器實現權利要求1至5中任一項所述的方法。