[發明專利]訂閱消息管理方法及系統

有效

• 申請號: 201410836098.4
• 申請日: 2014-12-30
• 公開（公告）號: CN104468339B
• 公開（公告）日: 2018-03-27
• 發明（設計）人: 張文金;張宇峰;邱丹;姚鍵;潘柏宇;盧述奇
• 申請（專利權）人: 合一網絡技術（北京）有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L12/24
• 代理公司: 北京市天璽沐澤專利代理事務所(普通合伙)11532
• 代理人: 鮑曉

1.一種訂閱消息管理方法，其特征在于，包括：

針對每個訂閱用戶賬號建立一個映射，所述映射記錄相應訂閱用戶賬號的訂閱記錄；其中，所述映射為mapreduce框架中的map部分，訂閱用戶賬號的訂閱記錄通過所述映射而投影到相應的板塊中；

當訂閱用戶賬號查詢訂閱消息，則通過訂閱用戶賬號的映射選擇一個或多個處理節點；

利用所述處理節點通過所述訂閱用戶賬號的訂閱記錄，提取所述訂閱記錄對應的訂閱消息；其中，利用所述mapreduce框架中的歸并部分對所述訂閱記錄進行歸并聚合的運算，以完成訂閱消息的提??；

將所述訂閱消息反饋至訂閱用戶賬號。

2.根據權利要求1所述訂閱消息管理方法，其特征在于，所述針對每個訂閱用戶賬號建立一個映射還包括：

所述映射主從復制。

3.根據權利要求1或2所述訂閱消息管理方法，其特征在于，所述提取所述訂閱記錄對應的訂閱消息具體為：

預設提取時間，在所述提取時間對所述訂閱記錄對應的訂閱消息進行提取。

4.根據權利要求1或2所述訂閱消息管理方法，其特征在于，所述提取所述訂閱記錄對應的訂閱消息具體為：

提取全部未反饋的訂閱消息。

5.一種訂閱消息系統，其特征在于，所述系統中有多個處理節點，所述系統包括：

映射模塊，用于針對每個訂閱用戶賬號建立一個映射，所述映射記錄相應訂閱用戶賬號的訂閱記錄；其中，所述映射為mapreduce框架中的map部分，訂閱用戶賬號的訂閱記錄通過所述映射而投影到相應的板塊中；

查詢模塊，用于在訂閱用戶賬號查詢訂閱消息時，通過訂閱用戶賬號的映射選擇一個或多個處理節點；

所述處理節點用于，利用所述處理節點通過所述訂閱用戶賬號的訂閱記錄，提取所述訂閱記錄對應的訂閱消息；將所述訂閱消息反饋至訂閱用戶賬號；其中，利用所述mapreduce框架中的歸并部分對所述訂閱記錄進行歸并聚合的運算，以完成訂閱消息的提取。

6.根據權利要求5所述訂閱消息系統，其特征在于，所述針對每個訂閱用戶賬號建立一個映射還包括：

所述映射主從復制。

7.根據權利要求5或6所述訂閱消息系統，其特征在于，所述處理節點包括：

提取單元，用于預設時間范圍閾值，提取所述時間范圍閾值內產生的訂閱消息；或者提取全部未反饋的訂閱消息；

反饋單元，用于將所述訂閱消息反饋至訂閱用戶賬號。