消息處理方法及系統的製作方法
2023-04-30 04:35:16
消息處理方法及系統的製作方法
【專利摘要】本申請公開了消息處理方法及系統，其中，所述方法包括：獲取當前用戶的用戶標識信息；根據所述用戶標識信息獲取發送給該當前用戶的非系統消息的相關信息；所述非系統消息為以點對點的方式發送給當前用戶的消息；獲取公共存儲區保存的發送給該當前用戶的系統消息，並提取各條系統消息對應的發送時間；所述系統消息為以群發的方式發送給當前用戶的消息；根據獲取到的所述非系統消息的相關信息、系統消息及其對應的發送時間，對所述非系統消息以及系統消息進行聚合，根據聚合的結果返回發送給當前用戶的消息的信息。通過本申請，實現了非系統消息與系統消息的統一展現，避免了因數據不準確而給用戶造成的幹擾。
【專利說明】消息處理方法及系統
【技術領域】
[0001]本申請涉及數據處理【技術領域】，特別是涉及消息處理方法及系統。
【背景技術】
[0002]在一些大型的購物類等網站中，網站管理員通常需要向用戶發送一些消息，例如通知用戶升級的消息、購買了某商品的消息、在一段時間內購買了多少件商品的統計消息，等等。最初這些消息通常是以點對點形式向目標用戶發布的私有消息、通知、提醒等，這種消息由於具有個性化用戶通知的特點，因此，被稱為非系統消息，在存儲層中是一對一存儲在關係型資料庫中。
[0003]但是，在向用戶發送消息的過程中，經常會存在一些需要發送給多個用戶甚至是全部用戶的消息，例如，某大型的商品促銷消息等等，這類消息屬於全局型的消息。雖然也可以採用點對點的形式向用戶發送非系統消息，但是現在大型網際網路公司的用戶群體一般都在百萬、千萬級以上級別，當向大規模用戶發送點對點的非系統消息時，數據的送達延時會非常大，無法滿足網際網路快速的業務發展現狀；同時，如果數據內容重複，則會產生大量的冗餘數據，非常佔用系統資源。
[0004]由此，系統消息便應運而生了。所謂系統消息，就是網站管理者以信息廣播形式向目標用戶發布的公開的消息、公告、通知、提示等。這種系統消息具有群發性、高可達性等消息特性。並且，只需要在數據層的公共存儲區中存儲一份，不需要一對一存儲在各個用戶的關係型資料庫中，還可對其展現進行統一地管理。
[0005]當然，雖然系統消息具有很多優點，但是，非系統消息也是不可替代的，對於同一用戶而言，可能既會收到系統消息也會收到非系統消息。但是，由於兩者消息的存儲方式等存在差異，導致用戶數據不準確，給用戶造成幹擾，因此，如何在用戶層進行消息處理和展現，是需要解決的技術問題。
【發明內容】
[0006]本申請提供了消息處理方法及系統，提供了在非系統消息與系統消息並存的情況下，消息展現過程的處理方案，實現了非系統消息與系統消息的統一展現，避免了因數據不準確而給用戶造成的幹擾。
[0007]本申請提供了如下方案:
[0008]一種消息處理方法，包括:
[0009]獲取當前用戶的用戶標識信息；
[0010]根據所述用戶標識信息獲取發送給該當前用戶的非系統消息的相關信息；所述非系統消息為以點對點的方式發送給當前用戶的消息；
[0011]獲取公共存儲區保存的發送給該當前用戶的系統消息，並提取各條系統消息對應的發送時間；所述系統消息為以群發的方式發送給當前用戶的消息；
[0012]根據獲取到的所述非系統消息的相關信息、系統消息及其對應的發送時間，對所述非系統消息以及系統消息進行聚合，根據聚合的結果返回發送給當前用戶的消息的信
肩、O
[0013]—種消息處理系統,包括:
[0014]用戶標識信息獲取單元，用於獲取當前用戶的用戶標識信息；
[0015]非系統消息相關信息獲取單元，用於根據所述用戶標識信息獲取發送給該當前用戶的非系統消息的相關信息；所述非系統消息為以點對點的方式發送給當前用戶的消息；
[0016]系統消息相關信息獲取單元，用於獲取公共存儲區保存的發送給該當前用戶的系統消息，並提取各條系統消息對應的發送時間；所述系統消息為以群發的方式發送給當前用戶的消息；
[0017]消息聚合單元，用於根據獲取到的所述非系統消息的相關信息、系統消息及其對應的發送時間，對所述非系統消息以及系統消息進行聚合，根據聚合的結果返回發送給當前用戶的消息的信息。
[0018]根據本申請提供的具體實施例，本申請公開了以下技術效果:
[0019]通過本申請，在需要向用戶展現與系統發送的消息相關的信息時，一方面，可以根據用戶標識信息獲取到發送給該用戶的非系統消息的相關信息；另一方面，可以從公共存儲區中獲取到發送給該用戶的系統消息的信息，並從中提取出每條系統消息的發送時間，這樣，就可以根據這些信息對非系統信息以及系統消息進行聚合，並根據聚合後的結果返回用於展現發送給當前用戶的消息的相關數據，以便在客戶端對發送給當前用戶的消息的情況進行展現，避免因數據不準確而給用戶造成的幹擾。可見，本申請實施例提供了在非系統消息與系統消息並存的情況下，消息展現過程的處理方案，實現了非系統消息與系統消息的統一展現。
[0020]具體在進行非系統消息與系統消息的聚合時，可以分別統計出當前用戶未讀的非系統消息的數量，以及當前用戶未讀的系統消息的數量，並根據這兩方面的信息統計出當前用戶未讀的消息總數，以便客戶端將該消息總數展現給用戶。
[0021]或者，也可以分別獲取到最近發送給當前用戶的一條非系統消息，以及最近發送給當前用戶的一條系統消息，然後比對這兩條消息的發送時間，將發送時間距離當前時刻較近者確定為最近發送給當前用戶的一條消息，並返回，以便客戶端將其展現給用戶。
[0022]再者，還可以根據發送給當前用戶的各條非系統消息以及系統消息各自對應的發送時間，將非系統消息以及系統消息放在一起進行統一的排序，以便客戶端按照此順序進行各條消息的展現。
[0023]當然，實施本申請的任一產品並不一定需要同時達到以上所述的所有優點。
【專利附圖】
【附圖說明】
[0024]為了更清楚地說明本申請實施例或現有技術中的技術方案，下面將對實施例中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖僅僅是本申請的一些實施例，對於本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其他的附圖。
[0025]圖1是本申請實施例提供的方法的流程圖；
[0026]圖2是本申請實施例提供的另一方法的流程圖；[0027]圖3是本申請實施例提供的第一系統的示意圖；
[0028]圖4是本申請實施例提供的第二系統的示意圖；
[0029]圖5是本申請實施例提供的第三系統的示意圖；
[0030]圖6是本申請實施例提供的第四系統的示意圖。
【具體實施方式】
[0031 ] 下面將結合本申請實施例中的附圖,對本申請實施例中的技術方案進行清楚、完整地描述，顯然，所描述的實施例僅僅是本申請一部分實施例，而不是全部的實施例。基於本申請中的實施例，本領域普通技術人員所獲得的所有其他實施例，都屬於本申請保護的範圍。
[0032]首先需要說明的是，在本申請實施例中，發送給用戶的系統消息是保存在數據層的公共存儲區，所謂的公共存儲區可以是一種Key/Value結構數據的解決方案，它默認支持基於內存和文件的兩種存儲方式，分別和通常所說的緩存和持久化存儲對應。
[0033]對於非系統消息與系統消息而言，消息的存儲格式會有所不同，例如，非系統消息的存儲格式一般如表1所示，括號中的內容為對對應欄位的解釋:
[0034]表1
[0035]
【權利要求】
1.一種消息處理方法，其特徵在於，包括: 獲取當前用戶的用戶標識信息； 根據所述用戶標識信息獲取發送給該當前用戶的非系統消息的相關信息；所述非系統消息為以點對點的方式發送給當前用戶的消息； 獲取公共存儲區保存的發送給該當前用戶的系統消息，並提取各條系統消息對應的發送時間；所述系統消息為以群發的方式發送給當前用戶的消息； 根據獲取到的所述非系統消息的相關信息、系統消息及其對應的發送時間，對所述非系統消息以及系統消息進行聚合，根據聚合的結果返回發送給當前用戶的消息的信息。
2.根據權利要求1所述的方法，其特徵在於，還包括: 獲取公共存儲區記錄的當前用戶上次查詢時刻的時間點； 所述根據所述用戶標識信息獲取發送給該當前用戶的非系統消息的相關信息包括: 根據所述用戶標識信息獲取該當前用戶的未讀非系統消息的數量； 所述根據獲取到的所述非系統消息的相關信息、系統消息及其對應的發送時間，對所述非系統消息以及系統消息進行聚合包括: 將發送時間晚於所述上次查詢時刻的時間點的系統消息確定為該當前用戶未讀的系統消息，並統計出當前用戶的未讀系統消息的數量； 取所述當前用戶的未讀非系統消息的數量與未讀系統消息的數量之和作為當前用戶未讀消息的條目總數，返回所述未讀消息的條目總數。
3.根據權利要求2所述的方法，其特徵在於，所述根據所述用戶標識信息獲取該當前用戶的未讀非系統消息的數量包括: 根據所述用戶標識信息在對應的關係型資料庫中獲取該當前用戶的非系統消息的信息； 根據各條非系統消息的狀態欄位信息，獲取處於未讀狀態的非系統消息； 通過統計處於未讀狀態的非系統消息的數量，確定該當前用戶的未讀非系統消息的數量。
4.根據權利要求2所述的方法，其特徵在於，所述根據所述用戶標識信息獲取該當前用戶的未讀非系統消息的數量包括: 根據所述用戶標識信息查詢公共存儲區中為該用戶設置的未讀消息計數器的值； 將所述未讀消息計數器的值確定為該當前用戶的未讀非系統消息的數量。
5.根據權利要求2所述的方法，其特徵在於，還包括: 將當前時刻的時間點保存到所述公共存儲區。
6.根據權利要求1所述的方法，其特徵在於，所述根據所述用戶標識信息獲取發送給該當前用戶的非系統消息的相關信息包括: 根據公共存儲區中為該當前用戶預留的最近一條消息的存儲區中保存的信息，獲取最近發送給當前用戶的一條非系統消息，並獲取該條非系統消息的發送時間Tl ； 所述根據獲取到的所述非系統消息的相關信息、系統消息及其對應的發送時間，對所述非系統消息以及系統消息進行聚合包括: 將發送時間距離當前時刻最近的系統消息確定為最近發送給當前用戶的一條系統消息，並記錄所述最近發送給當前用戶的一條系統消息的發送時間T2 ；比較Tl與T2，將距離當前時刻較近者對應的消息確定為最近發送給當前用戶的一條消息，返回所述最近發送給當前用戶的一條消息的提示信息。
7.根據權利要求1所述的方法，其特徵在於，所述根據所述用戶標識信息獲取發送給該當前用戶的非系統消息的相關信息包括: 根據所述用戶標識信息查詢該當前用戶的關係型資料庫，獲取發送給該當前用戶的各條非系統消息及各自對應的發送時間； 所述根據獲取到的所述非系統消息的相關信息、系統消息及其對應的發送時間，對所述非系統消息以及系統消息進行聚合包括: 將各條非系統消息以及各條系統消息加入到同一消息集合中； 按照發送時間對所述消息集合中的各條消息進行排序，返回按照發送時間排序後的各條消息。
8.根據權利要求1至6任一項所述的方法，其特徵在於，所述獲取公共存儲區保存的發送給該當前用戶的系統消息包括: 根據當前用戶的用戶標識信息，獲取公共存儲區保存的發送給該當前用戶的系統消息
9.一種消息處理系統，其特徵在於，包括: 用戶標識信息獲取單元，用於獲取當前用戶的用戶標識信息； 非系統消息相關信息獲取單元，用於根據所述用戶標識信息獲取發送給該當前用戶的非系統消息的相關信息；所述非系統消息為以點對點的方式發送給當前用戶的消息； 系統消息相關信息獲取單元，用於獲取公共存儲區保存的發送給該當前用戶的系統消息，並提取各條系統消息對應的發送時間；所述系統消息為以群發的方式發送給當前用戶的消息； 消息聚合單元，用於根據獲取到的所述非系統消息的相關信息、系統消息及其對應的發送時間，對所述非系統消息以及系統消息進行聚合，根據聚合的結果返回發送給當前用戶的消息的信息。
10.根據權利要求9所述的系統，其特徵在於，還包括: 時間點查詢單元，用於獲取公共存儲區記錄的當前用戶上次查詢時刻的時間點； 所述非系統消息相關信息獲取單元包括: 未讀非系統消息數量獲取子單元，用於根據所述用戶標識信息獲取該當前用戶的未讀非系統消息的數量； 所述消息聚合單元包括: 未讀系統消息數量獲取子單元，用將發送時間晚於所述上次查詢時刻的時間點的系統消息確定為該當前用戶未讀的系統消息，並統計出當前用戶的未讀系統消息的數量； 未讀消息總數確定子單元，用於取所述當前用戶的未讀非系統消息的數量與未讀系統消息的數量之和作為當前用戶未讀消息的條目總數，返回所述未讀消息的條目總數。
【文檔編號】H04L12/58GK103944799SQ201310020034
【公開日】2014年7月23日 申請日期:2013年1月18日 優先權日:2013年1月18日
【發明者】邱鵬, 李令龍 申請人:阿里巴巴集團控股有限公司