[發明專利]基于狀態管理的數據推送方法、裝置和系統

有效

• 申請號: 201410815587.1
• 申請日: 2014-12-24
• 公開（公告）號: CN104601668B
• 公開（公告）日: 2019-01-18
• 發明（設計）人: 都海峰;張帥
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京邦信陽專利商標代理有限公司 11012
• 代理人: 金璽

1.一種基于狀態管理的數據推送方法，其特征在于，所述方法包括：

a.采集各個推送線程的狀態；具體包括：

a1.以預定周期向各推送服務器發送狀態查詢指令；

a2.接收各推送服務器反饋的推送線程的狀態；

b.當任何一個推送線程的狀態異常時，對該推送線程進行故障恢復，具體包括：

將異常的推送線程從第一推送服務器轉移到第二推送服務器上，并在第二推送服務器上重啟所述異常停止的推送服務，所述第一推送服務器為正在執行異常的推送線程的推送服務器；其中，在第二推送服務器上重啟所述異常停止的推送服務為：從上一次的成功推送狀態繼續推送數據。

2.根據權利要求1所述的方法，其特征在于，推送線程的狀態異常包括以下的任意一種：

(1)發出狀態查詢指令后，在規定時間內未收到推送線程的狀態反饋，則將推送線程標記為異常待定狀態，如果在重發狀態查詢指令預定次數后仍然無法得到反饋，則認定推送線程狀態異常；

(2)對源數據庫或目的數據庫無法操作。

3.根據權利要求1所述的方法，其特征在于，在第二推送服務器上重啟所述推送服務后，取消第一服務器上由于異常停止的推送線程。

4.根據權利要求1所述的方法，其特征在于，在步驟b中，故障恢復包括：采集各個第二服務器的負載，將異常的推送線程從第一推送服務器轉移到負載最小的第二推送服務器上，并在該第二推送服務器上重啟所述異常停止的推送服務，所述第一推送服務器為正在執行異常的推送線程的推送服務器。

5.一種基于狀態管理的穩定數據推送裝置，其特征在于，所述裝置包括：狀態采集模塊、故障恢復模塊，

狀態采集模塊用于采集各個推送線程的狀態；其包括狀態查詢子模塊和狀態接收子模塊，所述狀態查詢子模塊用于以預定周期向各推送服務器發送狀態查詢指令；所述狀態接收子模塊用于接收各推送服務器反饋的推送線程的狀態；

故障恢復模塊用于任何一個推送線程的狀態異常時，對該推送線程進行故障恢復；其包括線程轉移子模塊，用于將異常的推送線程從第一推送服務器轉移到第二推送服務器上并在第二推送服務器上重啟所述異常停止的推送服務，所述第一推送服務器為正在執行異常的推送線程的推送服務器；其中，在第二推送服務器上重啟所述異常停止的推送服務為：從上一次的成功推送狀態繼續推送數據。

6.根據權利要求5所述的裝置，其特征在于，故障恢復模塊包括負載分析子模塊：所述負載分析子模塊用于采集各個第二服務器的負載，將異常的推送線程從第一推送服務器轉移到負載最小的第二推送服務器上，并在該第二推送服務器上重啟所述異常停止的推送服務，所述第一推送服務器為正在執行異常的推送線程的推送服務器。

7.一種基于狀態管理的數據推送系統，其特征在于，所述系統包括管理服務器、推送服務器，

推送服務器用于執行從源數據庫向目的數據庫的推送線程；

管理服務器包括狀態采集模塊、故障恢復模塊，其中：

狀態采集模塊用于采集各個推送線程的狀態；其包括狀態查詢子模塊、狀態接收子模塊，所述狀態查詢子模塊用于以預定周期向各推送服務器發送狀態查詢指令；所述狀態接收子模塊用于接收各推送服務器反饋的推送線程的狀態；

故障恢復模塊用于當任何一個推送線程的狀態異常時，對該推送線程進行故障恢復；其包括線程轉移子模塊，線程轉移子模塊用于將異常的推送線程從第一推送服務器轉移到第二推送服務器上并在第二推送服務器上重啟所述異常停止的推送服務，所述第一推送服務器為正在執行異常的推送線程的推送服務器；其中，在第二推送服務器上重啟所述異常停止的推送服務為：從上一次的成功推送狀態繼續推送數據。

8.根據權利要求7所述的系統，其特征在于，故障恢復模塊包括負載分析子模塊：所述負載分析子模塊用于采集各個第二服務器的負載，將異常的推送線程從第一推送服務器轉移到負載最小的第二推送服務器上，并在該第二推送服務器上重啟所述異常停止的推送服務，所述第一推送服務器為正在執行異常的推送線程的推送服務器。