[發明專利]分布式系統以及用于該系統的流量分配方法和裝置

有效

• 申請號: 201810821660.4
• 申請日: 2018-07-24
• 公開（公告）號: CN108924244B
• 公開（公告）日: 2022-02-25
• 發明（設計）人: 代俊
• 申請（專利權）人: 阿里巴巴（中國）有限公司
• 主分類號: H04L67/5682
• 分類號: H04L67/5682;H04L67/563;H04L67/55;H04L43/10;H04L45/02
• 代理公司: 北京展翼知識產權代理事務所(特殊普通合伙) 11452
• 代理人: 屠長存

1.一種用于分布式推薦系統的流量分配方法，所述分布式推薦系統包括管理節點和多個服務節點，該方法包括：

以用戶分組為單位，將用戶分配給所述多個服務節點；

所述管理節點接收分別來自所述多個服務節點的心跳報告，所述心跳報告包括分配給所述服務節點且已在本地緩存用戶相關緩存數據的用戶分組的用戶分組信息；

所述管理節點根據所述心跳報告，生成用戶分配表，所述用戶分配表用于記錄所述多個服務節點和分配給各個服務節點的用戶分組的對應關系；

響應于存在連接狀態發生變化的服務節點，所述管理節點基于所述用戶分配表，以用戶分組為單位，對至少一個服務節點重新分配用戶，

其中，所述連接狀態發生變化的服務節點包括先前不可用而所述管理節點當前收到其心跳報告的新服務節點，所述管理節點將所分配的用戶分組數量最多的第一服務節點的部分用戶分組分配給所述新服務節點，并將所述部分用戶分組的用戶的用戶相關緩存數據，遷移到所述新服務節點。

2.根據權利要求1所述的方法，其中，還包括：

所述管理節點根據所述心跳報告，確定該心跳報告對應的服務節點的連接狀態是否發生變化。

3.根據權利要求2所述的方法，其中，所述連接狀態發生變化的服務節點包括：

先前可用而在預定時間期間內所述管理節點未收到其心跳報告的服務節點。

4.根據權利要求3所述的方法，其中，所述對至少一個服務節點重新分配用戶的步驟包括：

將當前未分配服務節點的用戶分組，分配給當前所分配的用戶分組數量最少的服務節點。

5.根據權利要求3所述的方法，其中，所述對至少一個服務節點重新分配用戶的步驟包括：

將被分配給至少兩個服務節點的用戶分組分配給所述至少兩個服務節點中當前分配的用戶分組數量最少的服務節點。

6.根據權利要求1所述的方法，其中，所述對至少一個服務節點重新分配用戶的步驟包括：

所述管理節點將所分配的用戶分組數量較多的第一服務節點的部分用戶分組分配給所分配的用戶分組數量較少的第二服務節點。

7.根據權利要求1所述的方法，其中，所述分布式推薦系統還包括多個路由節點，所述路由節點用于向所述服務節點轉發用戶服務請求，所述方法還包括：

將所述用戶分配表發送給所述路由節點，所述路由節點基于更新后的所述用戶分配表轉發所述用戶服務請求。

8.根據權利要求1所述的方法，其中，所述用戶分組信息是用戶標識相應的用戶哈希值。

9.一種用于分布式推薦系統的流量分配裝置，所述分布式推薦系統包括管理節點和多個服務節點，該流量分配裝置設置在所述管理節點，該流量分配裝置包括：

用戶分配裝置，用于以用戶分組為單位，將用戶分配給所述多個服務節點；

心跳接收裝置，用于接收分別來自所述多個服務節點的心跳報告，所述心跳報告包括分配給所述服務節點且已在本地緩存用戶相關緩存數據的用戶分組的用戶分組信息；

分配表生成裝置，用于根據所述心跳報告，生成用戶分配表，所述用戶分配表用于記錄所述多個服務節點和分配給各個服務節點的用戶分組的對應關系；

用戶分配裝置，用于響應于存在連接狀態發生變化的服務節點，所述管理節點基于所述用戶分配表，以用戶分組為單位，對至少一個服務節點重新分配用戶，

其中，所述連接狀態發生變化的服務節點包括先前不可用而所述管理節點當前收到其心跳報告的新服務節點，該流量分配裝置還包括數據遷移裝置，用于將所分配的用戶分組數量最多的第一服務節點的部分用戶分組分配給所述新服務節點，并將所述部分用戶分組的用戶的用戶相關緩存數據，遷移到所述新服務節點。