[發明專利]一種容災數據處理方法和裝置

在審

• 申請號: 202110450918.6
• 申請日: 2021-04-26
• 公開（公告）號: CN113110948A
• 公開（公告）日: 2021-07-13
• 發明（設計）人: 孫雪斐
• 申請（專利權）人: 北京京東拓先科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F11/07
• 代理公司: 北京德琦知識產權代理有限公司 11018
• 代理人: 杜志敏;宋志強

1.一種容災數據處理方法，其特征在于，所述方法包括：

向消息隊列MQ服務器發送請求；

若確定MQ服務異常，則停止向MQ服務器發送請求，并將需要發送的請求對應的數據寫入第一緩沖區；

當第一緩存區寫滿后，切換為寫入第二緩存區，并開啟新的線程將所述第一緩存區的數據刷新到磁盤中；

若確定所述MQ服務恢復正常，則停止向緩存中寫入數據；

將磁盤中存儲的數據發送給MQ服務器。

2.根據權利要求1所述的方法，其特征在于，所述確定MQ服務異常，包括：

確定第一預設時間內請求失敗的次數；

當第一預設時間內請求失敗的次數達到第一預設值時，確定所述MQ服務器異常。

3.根據權利要求1所述的方法，其特征在于，所述確定所述MQ服務恢復正常，包括：

向所述MQ服務器發送MQ服務連接請求；

當第二預設時間內發送連接請求成功的次數達到第二預設值時，確定所述MQ服務器恢復正常。

4.根據權利1所述的方法，其特征在于，所述當第一緩存區寫滿后，切換為寫入第二緩存區之后，所述方法進一步包括

第二緩存區寫滿后，切換到向第一緩存區寫數據；并開啟一個新的線程將所述第二緩存區的數據刷新到磁盤中。

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

當第一緩存區或第二緩存區未存滿，且停止向對應緩存區寫入數據時，將所述第一緩存區或所述第二緩存區中的數據刷新到磁盤中。

6.根據權利要求1-5任一項所述的方法，其特征在于，所述方法進一步包括：

將緩存區中的數據刷新到磁盤的速度大于寫數據到緩存區中的速度。

7.根據權利要求1-5任一項所述的方法，其特征在于，所述方法進一步包括：

將數據寫入第一緩存區或第二緩存區時，通過緩存單線程的方式進行數據寫入；

其中，緩存單線程的方式為針對第一緩存區或第二緩存區在同一時間通過一個線程寫入數據。

8.根據權利要求1-5任一項所述的方法，其特征在于，所述方法進一步包括：

將數據寫入第一緩存區或第二緩存區時，通過緩存分片單線程方式進行數據寫入；

其中，緩存分片單線程方式為針對第一緩存區或第二緩存區在同一時間通過不大于緩存分片數個線程寫入數據。

9.一種容災數據處理裝置，其特征在于，所述裝置包括：第一發送單元、第一確定單元、存儲單元、第二確定單元和第二發送單元；

所述第一發送單元，用于向消息隊列MQ服務器發送請求；若所述第一確定單元確定MQ服務異常，則停止向MQ服務器發送請求；

所述第一確定單元，用于確定MQ服務是否異常；

所述存儲單元，用于當所述第一確定單元確定所述MQ服務異常，則將需要發送的請求對應的數據寫入第一緩沖區；當第一緩存區寫滿后，切換為寫入第二緩存區，并開啟新的線程將所述第一緩存區的數據刷新到磁盤中；若所述第二確定單元確定所述MQ服務恢復正常，則停止向緩存中寫入數據；

所述第二確定單元，用于確定所述MQ服務是否恢復正常；

所述第二發送單元，用于當所述第二確定單元確定所述MQ服務恢復正常時，將磁盤中存儲的數據發送給MQ服務器。

10.一種電子設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述程序時實現如權利要求1-8任一項所述的方法。

11.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被處理器執行時實現權利要求1-8任一項所述的方法。