[發明專利]一種storm數據流反壓方法以及節點

在審

• 申請號: 201810565586.4
• 申請日: 2018-06-04
• 公開（公告）號: CN108768881A
• 公開（公告）日: 2018-11-06
• 發明（設計）人: 王文慶;杜彥魁;關坤龍
• 申請（專利權）人: 鄭州云海信息技術有限公司
• 主分類號: H04L12/825
• 分類號: H04L12/825;H04L12/863
• 代理公司: 北京安信方達知識產權代理有限公司 11262
• 代理人: 王康;解婷婷

1.一種storm數據流反壓方法，其特征在于，包括：；

節點設置接收隊列和發送隊列，所述節點包括數據源讀取節點Spout和數據處理節點Bolt，所述接收隊列用于保存上游節點發送的數據流元組Tuple，所述發送隊列用于保存并向下游節點發送本節點已處理完畢的數據流元組Tuple；

節點接收到來自下游節點的過載消息后，根據下游節點接收隊列的大小自適應減小自身的發送隊列大小；以及根據減小后的發送隊列大小自適應減小自身的接收隊列大小；

節點接收到來自上游節點的過載消息后，根據上游節點發送隊列大小自適應減小自身的接收隊列大小，以及根據減小后的接收隊列大小自適應減小自身的發送隊列大小。

2.根據權利要求1所述的基于可變隊列的storm數據流反壓方法，其特征在于，還包括：

節點接收到過載解除的消息后，線性增加自身的隊列大小。

3.根據權利要求1或2所述的基于可變隊列的storm數據流反壓方法，其特征在于，還包括：

節點若從未接收到過載消息，指數增加自身的隊列大小。

4.根據權利要求1所述的基于可變隊列的storm數據流反壓方法，其特征在于，節點接收到來自下游節點的過載消息后，根據下游節點接收隊列的大小自適應減小自身的發送隊列大小；以及根據減小后的發送隊列大小自適應減小自身的接收隊列大小；節點接收到來自上游節點的過載消息后，根據上游節點發送隊列大小自適應減小自身的接收隊列大小，以及根據減小后的接收隊列大小自適應減小自身的發送隊列大小，包括：

節點接收到來自下游節點的過載消息后，將自身的發送隊列大小設置為當前發送隊列大小的一半，以及將自身的接收隊列大小設置為當前接收隊列大小的一半；

節點接收到來自上游節點的過載消息后，將自身的接收隊列大小設置為當前接收隊列大小的一半，以及將自身的發送隊列大小設置為當前發送隊列大小的一半。

5.一種storm數據流反壓節點，其特征在于，所述節點包括數據源讀取節點Spout和數據處理節點Bolt，每個節點包括：

接收隊列，用于保存上游節點發送的數據流元組Tuple；

發送隊列，用于保存并向下游節點發送本節點已處理完畢的數據流元組Tuple；

過載模塊，用于在本節點過載時產生過載消息，并發送過載消息；

調整模塊，用于接收到來自下游節點的過載消息后，根據下游節點接收隊列的大小自適應減小發送隊列大小，以及根據減小后的發送隊列大小自適應減小接收隊列大小；接收到來自上游節點的過載消息后，根據上游節點發送隊列大小自適應減小接收隊列大小，以及根據減小后的接收隊列大小自適應減小發送隊列大小。

6.根據權利要求5所述的storm數據流反壓節點，其特征在于，

調整模塊，還用于在節點接收到過載解除的消息后，線性增加節點的隊列大小。

7.根據權利要求5或6所述的storm數據流反壓節點，其特征在于，

調整模塊，還用于在節點從未接收到過載消息的情況下，指數增加節點的隊列大小。

8.根據權利要求5所述的storm數據流反壓節點，其特征在于，

調整模塊，用于接收到來自下游節點的過載消息后，將節點的發送隊列大小設置為當前發送隊列大小的一半，以及將接收隊列大小設置為當前接收隊列大小的一半；接收到來自上游節點的過載消息后，將節點的接收隊列大小設置為當前接收隊列大小的一半，以及將發送隊列大小設置為當前發送隊列大小的一半。

9.一種計算機可讀存儲介質，其特征在于，所述介質存儲有計算機可執行指令，所述計算機可執行指令被處理器執行時實現權利要求1至4中任一項所述的storm數據流反壓方法。

10.一種storm數據流反壓設備，其特征在于，包括：

存儲器，設置為存儲指令；

處理器，設置為執行所述指令，實現權利要求1至4中任一項所述的storm數據流反壓方法的步驟。