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

有效

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

技術領域

本申請涉及數據集成和數據優化領域，具體地說，涉及一種訂閱消息管理方法及系統。

背景技術

當前很多網絡服務方都會通過在不同平臺上建立客戶端的方式提供網絡服務。用戶以賬號登陸到客戶端中，便可以使用網絡服務方提供的各種功能。而多數的客戶端中，均含有訂閱消息這一項功能。

訂閱消息，是提供網絡服務的一方與用戶進行信息交流的重要手段之一。用戶可自行選擇訂閱客戶端中的某些功能板塊，一旦訂閱的板塊中有信息更新，即可將更新的信息通過訂閱消息的形式反饋給用戶。這樣即方便了用戶及時的獲悉這些功能板塊的信息更新情況，同時也為客戶端提供了更廣泛的信息推廣渠道。

客戶端中的訂閱消息系統，往往有兩種常見的機制。一種是推送式，也就是當產生訂閱消息之后，系統即推送給用戶，供用戶查看。不過這種方式的推送時間一般都是即時的，可能在用戶不便或不想瀏覽訂閱消息的時候進行推送，對用戶產生騷擾。所以這種方式很多用戶不愿接受。另一種是拉取式，即用戶按照自己的習慣定期查閱訂閱消息。一旦用戶進行查閱，即立刻將一定時間范圍內的訂閱消息向用戶反饋。這種方式查閱的時間將由用戶自行掌握，更加迎合多數用戶的需求。

不過現有技術存在的區別在于，傳統的拉取式訂閱消息系統，均由服務器統一集中的進行消息處理；隨著用戶數量和訂閱數量增加，服務器的處理訂閱消息的時間會大大的延長，無法快速穩定的向用戶反饋訂閱消息，使得用戶體驗嚴重下降。

發明內容

有鑒于此，本申請所要解決的技術問題是提供了一種訂閱消息管理方法和訂閱消息系統，將訂閱消息系統建立在mapreduce框架之下，并行處理大量的訂閱消息，解決了服務器處理性能下降的問題。

為了解決上述技術問題，本申請有如下技術方案：

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

針對每個訂閱用戶賬號建立一個映射，所述映射記錄相應訂閱用戶賬號的訂閱記錄；

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

利用所述處理節點通過所述訂閱用戶賬號的訂閱記錄，提取所述訂閱記錄對應的訂閱消息；

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

優選地，其中，所述針對每個訂閱用戶賬號建立一個映射還包括：

所述映射主從復制。

優選地，其中，所述提取所述訂閱記錄對應的訂閱消息具體為：

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

優選地，其中，所述提取所述訂閱記錄對應的訂閱消息具體為：

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

為了解決上述技術問題，本申請還有如下技術方案：

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

映射模塊，用于針對每個訂閱用戶賬號建立一個映射，所述映射記錄相應訂閱用戶賬號的訂閱記錄；

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

所述處理節點用于，利用所述處理節點通過所述訂閱用戶賬號的訂閱記錄，提取所述訂閱記錄對應的訂閱消息；將所述訂閱消息反饋至訂閱用戶賬號。

優選地，其中，所述針對每個訂閱用戶賬號建立一個映射還包括：

所述映射主從復制。

優選地，其中，

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

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

與現有技術相比，本申請所述的方法和系統，達到了如下效果：

（1）將訂閱消息機制建立在mapreduce框架之下，實現多個處理節點并行處理訂閱消息，提高了訂閱消息的處理性能；

（2）通過設置不同的訂閱消息提取方式，豐富了用戶體驗。

當然，實施本申請的任一產品必不一定需要同時達到以上所述的所有技術效果。

附圖說明

此處所說明的附圖用來提供對本申請的進一步理解，構成本申請的一部分，本申請的示意性實施例及其說明用于解釋本申請，并不構成對本申請的不當限定。在附圖中：

圖1為本申請實施例所述方法流程圖；

圖2為本申請實施例所述系統結構示意圖。

具體實施方式