将消息从消息源传送至订阅接收者

摘要

许多场景涉及基于在多个接收者与消息源之间建立的订阅，将来自多个消息源的消息传送给接收者。接收者可分布式地被分配给一个或多个消息服务器，这一个或多个消息服务器独立地操作或作为互操作的消息服务器组的一部分。各个消息服务器可产生订阅过滤器，指示至少一个被分配的接收者订阅相应的消息源，并且在接收来自消息源的消息时，可利用该订阅过滤器来确定是否丢弃该消息或存储该消息以用于传送。互操作的消息服务器也可交换订阅过滤器，且在接收来自任何消息源的消息时，消息服务器可利用其它消息服务器的订阅过滤器来确定哪些其它消息服务器被分配以至少一个订阅接收者，并且可将该消息仅重新发送至这样的消息服务器。

主权项

一种对具有处理器和消息存储的消息服务器进行配置以将由消息源产生的消息分别传送至被分配给所述消息服务器的至少一个接收者的方法，各个接收者具有接收者概况，所述接收者概况标识由接收者订阅的消息源，所述方法包括：产生订阅过滤器，所述订阅过滤器指示对于各个消息源是否有至少一个接收者订阅所述消息源；在接收到来自消息源的消息时：检查所述订阅过滤器以确定是否有至少一个接收者订阅所述消息源，以及在根据所述订阅过滤器确定有至少一个接收者订阅所述消息源时：将所述消息存储在所述消息存储中，以及将订阅所述消息源的接收者与所述消息相关联；以及在接收到来自接收者的接收消息的接收请求时：从所述消息存储检索与所述接收者相关联的至少零个检索到的消息，以及将检索到的消息呈现给所述接收者。