[發明專利]數據轉發方法及裝置

有效

• 申請號: 201410016446.3
• 申請日: 2014-01-14
• 公開（公告）號: CN103701938A
• 公開（公告）日: 2014-04-02
• 發明（設計）人: 徐寅斐;陳鵬
• 申請（專利權）人: 百度在線網絡技術（北京）有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京銘碩知識產權代理有限公司 11286
• 代理人: 張川緒;張云珠

技術領域

本申請涉及一種訂閱數據轉發方法及裝置，尤其涉及一種根據下游訂閱需求構建級聯轉發結構的技術。

背景技術

目前Bigpipe（大管道技術）是網絡服務中普遍采用的一種分布式消息傳輸系統，主要采用的是P/S（Primary/Slave的簡寫，主/從）集群實現數據轉發，由于這種p/s集群的出口帶寬是固定的，因此限制了能夠同時發起的訂閱量，當下游訂閱量突然變大時，很容易導致每個下游分配到的帶寬不足，從而造成數據訂閱的不斷延遲。

為滿足下游的大量訂閱需求，現有技術也提供了一些解決方案，例如在Bigpipe的p/s下面下掛多層common?broker（代理服務器）來實現大規模數據的轉發，但是，由于下游的訂閱需求是隨時變化的，而這種數據轉發結構是固定的，不能隨著訂閱需求的改變進行相應的調整，因此，這種數據轉發策略不能實現common?broker資源的合理分配，反而會造成大量的common?broker處于閑置狀態，造成機器資源的浪費。

發明內容

本發明的目的在于提供一種數據轉發的方法和裝置，本發明不僅能夠實現大規模訂閱數據的轉發，而且能夠在數據轉發同時，有效克服因為帶寬不足導致的數據訂閱的延遲。

根據本發明的一方面，提供一種在服務器中分配轉發信息的方法，所述方法包括：獲取任意一條訂閱數據的訂閱量；確定轉發該訂閱數據的轉發節點的扇出量；根據獲取的訂閱量及確定的扇出量，構建該訂閱數據的級聯轉發控制信息，所述級聯轉發控制信息包括至少一組轉發節點，并且相鄰兩組轉發節點之間為上下游級聯關系；將該訂閱數據的指示信息及該訂閱數據的級聯轉發控制信息分配給該訂閱數據的級聯轉發控制信息所包括的轉發節點，以便所述轉發節點按照該訂閱數據的級聯轉發控制信息轉發該訂閱數據。

優選地，在將該訂閱數據的指示信息及該訂閱數據的級聯轉發控制信息分配給該訂閱數據的級聯轉發控制信息所包括的轉發節點以前，所述方法還包括：監測該訂閱數據的級聯轉發控制信息所包括的轉發節點之中是否存在發生異常的轉發節點；如果該訂閱數據的級聯轉發控制信息所包括的轉發節點之中存在發生異常的轉發節點，則將發生異常的轉發節點更換為該訂閱數據的級聯轉發控制信息所包括的轉發節點之外的另一正常的轉發節點，以更新該訂閱數據的級聯轉發控制信息。

優選地，所述異常為以下情況之一：宕機、下架、假死、網絡故障、掛機及停機。

優選地，所述將該訂閱數據的指示信息及該訂閱數據的級聯轉發控制信息分配給該訂閱數據的級聯轉發控制信息所包括的轉發節點的具體步驟包括：將該訂閱數據的指示信息及該訂閱數據的級聯轉發控制信息存儲至預置的元信息映射表中，所述元信息映射表用于存儲轉發節點對應的訂閱數據的指示信息以及該訂閱數據的級聯轉發控制信息，以便轉發節點獲取對應的訂閱數據的指示信息以及該訂閱數據的級聯轉發控制信息；或者，將該訂閱數據的指示信息及該訂閱數據的級聯轉發控制信息發送至公共服務器，所述公共服務器用于存儲轉發節點對應的訂閱數據的指示信息以及該訂閱數據的級聯轉發控制信息，以便轉發節點獲取對應的訂閱數據的指示信息以及該訂閱數據的級聯轉發控制信息。

根據本發明的另一方面，提供一種在服務器中分配轉發信息的裝置，所述裝置包括：訂閱量獲取單元，用于獲取任意一條訂閱數據的訂閱量；扇出量獲取單元，用于確定轉發該訂閱數據的轉發節點的扇出量；級聯信息構建單元，用于根據獲取的訂閱量及確定的扇出量，構建該訂閱數據的級聯轉發控制信息，所述級聯轉發控制信息包括至少一組轉發節點，并且相鄰兩組轉發節點之間為上下游級聯關系；級聯信息分配單元，用于將該訂閱數據的指示信息及該訂閱數據的級聯轉發控制信息分配給該訂閱數據的級聯轉發控制信息所包括的轉發節點，以便所述轉發節點按照該訂閱數據的級聯轉發控制信息轉發該訂閱數據。

優選地，所述方法還包括：級聯信息更新單元，用于在將該訂閱數據的指示信息及該訂閱數據的級聯轉發控制信息分配給該訂閱數據的級聯轉發控制信息所包括的轉發節點以前，監測該訂閱數據的級聯轉發控制信息所包括的轉發節點之中是否存在發生異常的轉發節點；如果該訂閱數據的級聯轉發控制信息所包括的轉發節點之中存在發生異常的轉發節點，則將發生異常的轉發節點更換為該訂閱數據的級聯轉發控制信息所包括的轉發節點之外的另一正常的轉發節點，以更新該訂閱數據的級聯轉發控制信息。

優選地，所述異常為以下情況之一：宕機、下架、假死、網絡故障、掛機及停機。