[發明專利]一種用戶在線狀態快速查詢方法及系統

在審

• 申請號: 201810049529.0
• 申請日: 2018-01-18
• 公開（公告）號: CN108304504A
• 公開（公告）日: 2018-07-20
• 發明（設計）人: 王偉;王豐;葉天虹;羅偉東
• 申請（專利權）人: 吉浦斯信息咨詢（深圳）有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京酷愛智慧知識產權代理有限公司 11514
• 代理人: 劉坦

本發明屬于移動互聯網技術領域，具體涉及一種用戶在線狀態快速查詢方法及系統，包括以下步驟：管理單元接收用戶狀態數據并經過計算得到分片地址；存儲單元根據分片地址找到對應的分片存儲模塊并對用戶狀態數據進行存儲；智能代理單元向管理單元發起請求并獲取分片地址；智能代理單元接收查詢請求，將查詢請求直接發送給分片地址相對應的分片存儲模塊，并獲取分片存儲模塊反饋的用戶狀態數據；智能單元對用戶狀態數據進行匯總得到匯總數據，并將匯總數據反饋給反饋給在線消息下發單元。本發明相比于傳統的數據庫系統或緩存技術，本發明能在有限的時間內滿足每秒百萬級的查詢請求，查詢時間更短、查詢效率更高，提升了查詢性能。

技術領域

本發明屬于移動互聯網技術領域，具體涉及一種用戶在線狀態快速查詢方法及系統。

背景技術

在移動互聯網中，針對數以億計的終端app用戶(下面簡稱用戶)，消息推送已經成為了一種促進用戶活躍的重要手段，而對于推送系統，很大程度上依賴于這些用戶的在線狀態。如何從這數億的用戶中快速確認出他們的在線狀態，以進行針對性的處理，從而進行即時的消息推送，所以一定程度上，是否能快速確認出用戶的在線狀態，成了推送中影響消息即時送達率的一個重要因素。對于此，一般的做法是使用傳統數據庫加索引的方式或者使用較成熟的緩存系統如redis或memcache，但隨著推送目標用戶量的增長，這些傳統的技術已經遠遠不能滿足現行高速查詢的要求了。

發明內容

針對現有技術中的缺陷，本發明提供了一種用戶在線狀態快速查詢方法及系統，相比于傳統的數據庫系統或緩存技術，本發明能在有限的時間內滿足每秒百萬級的查詢請求，查詢時間更短、查詢效率更高，提升了查詢性能。

第一方面，本發明提供了一種用戶在線狀態快速查詢方法，包括以下步驟：

管理單元接收用戶狀態數據，根據第一hash規則對用戶狀態數據進行計算得到分片地址；

存儲單元根據分片地址找到對應的分片存儲模塊，分片存儲模塊根據第二hash規則對用戶狀態數據進行存儲；

智能代理單元向管理單元發起請求，獲取管理單元反饋的分片地址；

智能代理單元接收在線消息下發單元發起的查詢請求，將查詢請求直接發送給分片地址相對應的分片存儲模塊；

分片存儲模塊根據第二hash規則將查詢請求所請求的用戶狀態數據反饋給智能代理單元；

智能單元對用戶狀態數據進行匯總得到匯總數據，并將匯總數據反饋給反饋給在線消息下發單元，在線消息下發單元通過匯總數據確定是否進行在線發送。

優選地，所述用戶狀態數據包括用戶ID和用戶在線狀態數據。

優選地，所述存儲單元包括若干分片存儲模塊，每個分片存儲模塊存儲有若干用戶狀態數據。

第二方面，本發明提供了一種用戶在線狀態快速查詢系統，適用于第一方面所述的用戶在線狀態快速查詢方法，包括：

管理單元，用于接收用戶狀態數據，根據第一hash規則對用戶狀態數據進行計算得到分片地址；用于接收管理單元的請求并向管理單元反饋分片地址；

存儲單元，用于根據分片地址找到對應的分片存儲模塊，分片存儲模塊根據第二hash規則對用戶狀態數據進行存儲；用于根據第二hash規則將查詢請求所請求的用戶狀態數據反饋給智能代理單元；

智能代理單元，用于向管理單元發起請求，獲取管理單元反饋的分片地址；用于接收在線消息下發單元發起的查詢請求，將查詢請求直接發送給分片地址相對應的分片存儲模塊，并接收分片存儲模塊反饋的用戶狀態數據；用于對用戶狀態數據進行匯總得到匯總數據，并將匯總數據反饋給反饋給在線消息下發單元，在線消息下發單元通過匯總數據確定是否進行在線發送。