1.一種對具有處理器和消息存儲的消息服務器進行配置以將由消息源產
生的消息分別傳送至被分配給所述消息服務器的至少一個接收者的方法,各個
接收者具有接收者概況,所述接收者概況標識由接收者訂閱的消息源,所述方
法包括:
產生訂閱過濾器,所述訂閱過濾器指示對于各個消息源是否有至少
一個接收者訂閱所述消息源;
在接收到來自消息源的消息時:
檢查所述訂閱過濾器以確定是否有至少一個接收者訂閱所述消
息源,以及
在根據所述訂閱過濾器確定有至少一個接收者訂閱所述消息源
時:
將所述消息存儲在所述消息存儲中,以及
將訂閱所述消息源的接收者與所述消息相關聯;以及
在接收到來自接收者的接收消息的接收請求時:
從所述消息存儲檢索與所述接收者相關聯的至少零個檢索到的
消息,以及
將檢索到的消息呈現給所述接收者。
2.如權利要求1所述的方法,其特征在于:
所述消息服務器包括社交網絡中的社交網絡服務器;
所述消息源包括編寫至少一個消息的社交網絡的第一用戶;以及
所述接收者包括社交網絡的第二用戶,所述的社交網絡的第二用戶訂閱
所述第一用戶的消息。
3.如權利要求1所述的方法,其特征在于,在接收來自接收者的訂閱消息
源的訂閱請求時:
更新所述接收者的接收者概況,以標識被所述接收者訂閱的消息源;以
及
更新所述訂閱過濾器以指示是否有至少一個接收者訂閱所述消息源。
4.如權利要求3所述的方法,其特征在于,所述訂閱過濾器包括布隆過濾
器,指示是否有至少一個接收者訂閱消息源。
5.如權利要求4所述的方法,其特征在于,更新所述訂閱過濾器以指示是
否有至少一個接收者訂閱所述消息源包括:向所述布隆過濾器中插入所述消息
源,以指示有至少一個接收者訂閱所述消息源。
6.如權利要求4所述的方法,其特征在于,在接收來自接收者的取消訂閱
消息源的取消訂閱請求時:
更新所述接收者的接收者概況,以標識所述消息源未被所述接收者訂
閱;以及
基于所述消息服務器的接收者概況,重新產生所述布隆過濾器。
7.如權利要求4所述的方法,其特征在于,在接收從消息服務器移除接收
者的移除請求時:
移除所述接收者的接收者概況,以及
基于所述消息服務器的接收者概況,重新產生所述布隆過濾器。
8.如權利要求1所述的方法,其特征在于:
所述消息服務器被包括在消息服務器組中;
各個接收者被分配給所述消息服務器組中的消息服務器;以及
所述消息服務器組的消息服務器共享分配映射,指示各個接收者向所述
消息服務器組中的消息服務器的分配。
9.如權利要求8所述的方法,其特征在于,在接收來自接收者的接收消息
的接收請求時:
使用所述分配映射,標識所述接收者被分配至的接收者消息服務器;
如果所述接收者消息服務器包括所述消息服務器,則:
從所述消息存儲檢索與所述接收者相關聯的至少零個檢索到的消
息,以及
將檢索到的消息呈現給所述接收者;以及
如果所述接收者消息服務器不包括所述消息服務器,則將所述接收請求
轉發給所述接收者消息服務器。
10.如權利要求8所述的方法,其特征在于,在接收將新接收者添加至
所述消息服務器的添加請求時:
產生新接收者概況,所述新接收者概況標識由所述新接收者訂閱的消息
源;以及
更新所述分配映射,指示所述新接收者分配至所述消息服務器。
11.如權利要求10所述的方法,其特征在于:
基于預測的由接收者訂閱的消息源的共享組,各個接收者被分配給所述
消息服務器組的消息服務器;以及
在接收將新接收者添加至消息服務器的添加請求時:
標識接收者消息服務器,所述新接收者可與被分配給所述接收者消
息服務器的接收者共享預測的消息源的共享組;
如果所述接收者消息服務器包括所述消息服務器,則:
產生新接收者概況,所述新接收者概況標識由所述新接收者訂
閱的消息源,以及
更新所述分配映射,指示所述新接收者分配至所述消息服務器;
以及
如果所述接收者消息服務器不包括所述消息服務器,則將所述添加
請求轉發給所述接收者消息服務器。
12.如權利要求11所述的方法,其特征在于,預測所預測的由被分配
給消息服務器組的所述接收者訂閱的消息源的共享組包括:
對于各個接收者,確定至少一個人口學統計學特征,所述人口學統計學
特征預測可由所述接收者訂閱的消息源;以及
將共享至少一個人口學統計學特征的接收者分配給消息服務器。
13.如權利要求8所述的方法,其特征在于:
在接收來自第二消息服務器的第二訂閱過濾器時,存儲所述第二消息服
務器的第二訂閱過濾器;以及
在接收來自消息源的消息時,對于各個第二訂閱過濾器:
檢查所述第二訂閱過濾器以確定是否有被分配給所述第二消息服
務器的至少一個接收者訂閱所述消息源;以及
在根據所述第二訂閱過濾器確定有被分配給所述第二消息服務器
的至少一個接收者訂閱所述消息源時,將所述消息轉發至所述第二消息服務
器。
14.如權利要求13所述的方法,其特征在于,在產生所述訂閱過濾器
時,將所述訂閱過濾器發送至所述消息服務器組的至少另一個消息服務器。
15.一種配置成將由消息源產生的消息分別傳送至被分配給消息服務
器的至少一個接收者的系統,各個接收者訂閱至少一個消息源,所述系統包括:
消息存儲,配置成存儲消息;
接收者概況存儲,配置成存儲接收者概況,所述接收者概況標識由各個
接收者訂閱的消息源;
訂閱過濾器,指示對于各個消息源是否有至少一個接收者訂閱所述消息
源;
消息接收組件,配置成在接收來自消息源的消息時:
檢查所述訂閱過濾器以確定是否有至少一個接收者訂閱所述消息
源,以及
在根據所述訂閱過濾器確定有至少一個接收者訂閱所述消息源時:
將所述消息存儲在所述消息存儲中,以及
將訂閱所述消息源的接收者與所述消息相關聯;以及
消息呈現組件,配置成在接收來自接收者的接收消息的接收請求時:
從所述消息存儲檢索與所述接收者相關聯的至少零個檢索到的消
息,以及
將檢索到的消息呈現給所述接收者。
展開