[發明專利]數據分發方法、裝置及存儲介質

有效

• 申請號: 201910985286.6
• 申請日: 2019-10-16
• 公開（公告）號: CN110839061B
• 公開（公告）日: 2020-11-06
• 發明（設計）人: 胡偉松
• 申請（專利權）人: 北京達佳互聯信息技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 李娜

1.一種數據分發方法，其特征在于，應用于數據分發系統，所述數據分發系統包括存儲服務器和訂閱服務器集合，所述方法執行于存儲服務器，包括：

獲取所述訂閱服務器集合中每個訂閱服務器的訂閱時間信息，所述訂閱時間信息標志所述訂閱服務器的訂閱進度；

根據每個所述訂閱服務器的訂閱時間信息，從所述訂閱服務器集合中確定第一訂閱服務器，并確定所述第一訂閱服務器的目標訂閱服務器，其中，根據每個所述訂閱服務器的訂閱時間信息，對所述訂閱服務器進行排序，得到排序結果；根據所述排序結果，從所述訂閱服務器集合中確定所述第一訂閱服務器，并確定所述第一訂閱服務器的所述目標訂閱服務器，

其中，所述排序結果為二叉樹排序結果，所述二叉樹排序結果包括：以每個所述訂閱服務器的訂閱時間信息為二叉樹的關鍵值，建立二叉樹，所述二叉樹中的每個節點對應所述訂閱服務器集合中的一個所述訂閱服務器；

通知所述第一訂閱服務器從所述目標訂閱服務器中訂閱消息。

2.根據權利要求1所述的方法，其特征在于，所述獲取所述訂閱服務器集合中每個訂閱服務器的訂閱時間信息，包括：

接收所述訂閱服務器發送的訂閱請求，根據所述訂閱服務器發送的所述訂閱請求，確定所述訂閱服務器的訂閱時間信息；或者，

接收所述訂閱服務器發送的反饋信息，根據所述訂閱服務器發送的所述反饋信息，確定所述訂閱服務器的訂閱時間信息，所述反饋信息為所述訂閱服務器從所述目標訂閱服務器中訂閱消息后，向所述存儲服務器發送的包括所述訂閱時間信息的反饋信息。

3.根據權利要求1所述的方法，其特征在于，所述排序結果為二叉樹排序結果，所述根據所述排序結果，從所述訂閱服務器集合中確定所述第一訂閱服務器，并確定所述第一訂閱服務器的所述目標訂閱服務器，包括：

確定所述二叉樹排序結果中，除二叉樹的根節點對應的所述訂閱服務器之外的其他訂閱服務器為所述第一訂閱服務器；

從所述第一訂閱服務器對應的二叉樹節點的祖先節點中，選擇部分或全部所述祖先節點對應的所述訂閱服務器，作為所述第一訂閱服務器的所述目標訂閱服務器。

4.一種數據分發方法，其特征在于，應用于數據分發系統，所述數據分發系統包括存儲服務器和訂閱服務器集合，所述方法執行于訂閱服務器，包括：

接收所述存儲服務器發送的通知，所述通知用于通知所述訂閱服務器從所述訂閱服務器的目標訂閱服務器中訂閱消息；其中，所述目標訂閱服務器為所述存儲服務器根據每個所述訂閱服務器的訂閱時間信息，從所述訂閱服務器集合中確定所述訂閱服務器后，為所述訂閱服務器確定的所述目標訂閱服務器，其中，根據每個所述訂閱服務器的訂閱時間信息，對所述訂閱服務器進行排序，得到排序結果；根據所述排序結果，從所述訂閱服務器集合中確定所述第一訂閱服務器，并確定所述第一訂閱服務器的所述目標訂閱服務器，

其中，所述排序結果為二叉樹排序結果，所述二叉樹排序結果包括：以每個所述訂閱服務器的訂閱時間信息為二叉樹的關鍵值，建立二叉樹，所述二叉樹中的每個節點對應所述訂閱服務器集合中的一個所述訂閱服務器；

根據所述通知，從所述目標訂閱服務器中訂閱消息。

5.一種數據分發裝置，其特征在于，應用于數據分發系統，所述數據分發系統包括存儲服務器和訂閱服務器集合，所述裝置設置于存儲服務器，包括：

獲取模塊，被配置為獲取所述訂閱服務器集合中每個訂閱服務器的訂閱時間信息，所述訂閱時間信息標志所述訂閱服務器的訂閱進度；

確定模塊，被配置為根據每個所述訂閱服務器的訂閱時間信息，從所述訂閱服務器集合中確定第一訂閱服務器，并確定所述第一訂閱服務器的目標訂閱服務器，其中，根據每個所述訂閱服務器的訂閱時間信息，對所述訂閱服務器進行排序，得到排序結果；根據所述排序結果，從所述訂閱服務器集合中確定所述第一訂閱服務器，并確定所述第一訂閱服務器的所述目標訂閱服務器，

其中，所述排序結果為二叉樹排序結果，所述二叉樹排序結果包括：以每個所述訂閱服務器的訂閱時間信息為二叉樹的關鍵值，建立二叉樹，所述二叉樹中的每個節點對應所述訂閱服務器集合中的一個所述訂閱服務器；

通知模塊，被配置為通知所述第一訂閱服務器從所述目標訂閱服務器中訂閱消息。