[發明專利]實現線程內外雙重對賬機制的數據交換監控方法及裝置

有效

• 申請號: 201810059890.1
• 申請日: 2018-01-22
• 公開（公告）號: CN108255623B
• 公開（公告）日: 2022-03-15
• 發明（設計）人: 鄒紀根;賴旭軍;甘國輝
• 申請（專利權）人: 深圳市卓訊信息技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F11/07
• 代理公司: 北京化育知識產權代理有限公司 11833
• 代理人: 尹均利

1.實現線程內外雙重對賬機制的數據交換監控方法，其特征在于，包括：

獲取源數據庫的源表數據；

根據所述源表數據啟動數據服務進程，所述數據服務進程包括多個交換線程，其中，所述啟動數據服務進程包括所述多個交換線程將所述源表數據傳輸到目標數據庫中以生成目標表數據，并向用戶反饋所傳輸數據的總數、成功傳輸的數據以及傳輸異常的數據；

獲取每個所述交換線程傳輸預設次數后所生成的目標表數據；

將所述傳輸預設次數后所生成的目標表數據與其所對應的源表數據進行一一比對以獲取每個所述交換線程中所傳輸數據的總數、成功傳輸的數據以及傳輸異常的數據；

對每個所述交換線程中所傳輸數據的總數、成功傳輸的數據以及傳輸異常的數據進行實時日志記錄且反饋給用戶；

根據所述數據服務進程啟動監控線程以監控每個所述交換線程是否正常運行；

若存在不正常運行的交換線程，控制所述監控線程根據預設規則監控所述不正常運行的交換線程中所傳輸生成的目標表數據與其所對應的源表數據進行一一比對以生成比對結果，所述比對結果包括數據傳輸總數、成功傳輸的數據以及傳輸異常的數據；

確定所述目標表數據的比對字段，所述比對字段包括時間戳、主鍵以及唯一約束；

將所述不正常運行的交換線程中所傳輸生成的目標表數據的比對字段與其所對應的源表數據的比對字段進行一一比對以生成比對結果；

根據所述比對結果控制所述監控線程監控所述不正常運行的交換線程重新啟動以將所述傳輸異常的數據重新傳輸。

2.根據權利要求1所述的方法，其特征在于，所述根據所述源表數據啟動數據服務進程之前，還包括：

對所述數據服務進程進行配置，所述對所述數據服務進程進行配置包括根據源數據庫對所述多個交換線程的傳輸時間間隔進行配置，或根據所述源表數據對所述數據服務進程的內存大小進行配置，或根據所述源表數據對每個所述交換線程進行數據交換的數量進行配置，或根據所述源表數據對每個所述交換線程的加解密方式進行配置。

3.根據權利要求1所述方法，其特征在于，所述控制所述監控線程根據預設規則監控所述不正常運行的交換線程中所傳輸生成的目標表數據與其所對應的源表數據進行一一比對以生成比對結果之后，還包括：

將所述比對結果采用短信或郵件的方式反饋給用戶。

4.一種裝置，其特征在于，包括：

獲取模塊，所述獲取模塊用于獲取源數據庫的源表數據；

第一啟動模塊，所述第一啟動模塊用于根據所述源表數據啟動數據服務進程，所述數據服務進程包括多個交換線程，其中，所述啟動數據服務進程包括所述多個交換線程將所述源表數據傳輸到目標數據庫中以生成目標表數據，并向用戶反饋所傳輸數據的總數、成功傳輸的數據以及傳輸異常的數據；

第二啟動模塊，所述第二啟動模塊用于根據所述數據服務進程啟動監控線程以監控每個所述交換線程是否正常運行；

監控比對模塊，所述監控比對模塊用于若存在不正常運行的交換線程，控制所述監控線程根據預設規則監控所述不正常運行的交換線程中所傳輸生成的目標表數據與其所對應的源表數據進行一一比對以生成比對結果，所述比對結果包括數據傳輸總數、成功傳輸的數據以及傳輸異常的數據；

重啟模塊，所述重啟模塊用于根據所述比對結果控制所述監控線程監控所述不正常運行的交換線程重新啟動以將所述傳輸異常的數據重新傳輸。

5.根據權利要求4所述的裝置，其特征在于，所述裝置還包括配置模塊，所述配置模塊用于對所述數據服務進程進行配置，所述對所述數據服務進程進行配置包括根據源數據庫對所述多個交換線程的傳輸時間間隔進行配置，或根據所述源表數據對所述數據服務進程的內存大小進行配置，或根據所述源表數據對每個所述交換線程的數據交換數量進行配置，或根據所述源表數據對每個所述交換線程的加解密方式進行配置。