分布式消息系统及其设备和协调方法

摘要

本发明公开了一种分布式消息系统及其设备和协调方法，其中协调方法包括监听在所述消息管理设备处登记的消息管理设备的相关信息；在所监听的信息发生变化时，根据相关信息发生变化的消息存储设备涉及的一个或者多个消息主题，从所述消息管理设备获取与所涉及的一个或者多个消息主题中的每个消息主题相关的消息处理设备的信息以及与所涉及的一个或者多个消息主题中的每个消息主题相关的存储分区的信息；基于所获取的消息处理设备和存储分区的信息，重新计算为所获取的每个消息处理设备分配进行消息处理的存储分区的分配结果；将所述分配结果发送给所述消息管理设备，以便更新每个消息处理设备的目标存储分区信息。

主权项

一种用于分布式消息系统的协调设备，所述分布式消息系统还包括一个或者多个存储消息的消息存储设备、一个或者多个对消息进行处理的消息处理设备和消息管理设备，其中每条消息具有相应的主题，所述消息存储设备为相应的主题建立一个或者多个存储分区，并且根据消息的主题将消息存储在相应主题的存储分区之一中；所述消息处理设备适于处理在某主题下的一个或者多个存储分区中的消息；所述消息管理设备中存储有与所述消息存储设备、消息处理设备、以及消息处理设备处理消息的目标存储分区相关的信息；所述协调设备包括：监听器，被配置为监听在所述消息管理设备处登记的消息存储设备的相关信息；第一获取器，被配置为从所述消息管理设备获取适于处理特定主题消息的消息处理设备的信息；第二获取器，被配置为从所述消息管理设备获取存储特定主题消息的消息存储设备中的存储分区的信息；分配器，被配置为在所述监听器所监听的信息发生变化时，根据相关信息发生变化的消息存储设备涉及的一个或者多个消息主题，从所述第一获取器获取与所涉及的一个或者多个消息主题中的每个消息主题相关的消息处理设备的信息以及从所述第二获取器获取与所涉及的一个或者多个消息主题中的每个消息主题相关的存储分区的信息，并基于所获取的消息处理设备和存储分区的信息，重新计算为所获取的每个消息处理设备分配进行消息处理的存储分区的分配结果；以及结果输出器，被配置为将所述分配器的分配结果输出到所述消息管理设备，以便更新每个消息处理设备的目标存储分区信息。