在分布式消息处理系统中的消息管理设备和方法

摘要

本发明公开了一种在分布式消息处理系统中的消息管理设备和方法。其中消息管理方法包括：接收消息处理设备发送的消息处理请求，所述消息处理请求至少包括所请求处理消息的主题；查询与所述消息处理请求中的主题相对应的存储分区信息，并将所查询到的存储分区信息发送给相应消息处理设备；以及处理来自消息处理设备的消息位置查询请求，查询与该消息位置查询请求中的存储分区相对应的存储分区的当前要处理消息的位置信息、并发送给相应消息处理设备；以及处理来自消息处理设备的消息位置更新请求，基于所述消息位置更新请求中的消息大小，更新与所述消息位置更新请求中的存储分区相对应的存储分区的当前要处理消息的位置信息。

主权项

一种在分布式消息处理系统中的消息管理设备，该分布式消息处理系统还包括一个或多个消息存储设备和一个或多个消息处理设备，其中每条消息具有相应的主题，所述消息存储设备为相应主题建立一个或者多个存储分区，并且根据消息的主题将消息存储在相应主题的存储分区之一中，所述消息管理设备包括：消息分布状态存储器，被配置为至少存储每个消息存储设备中有关存储分区的信息、以及每个存储分区中有关消息处理设备当前要处理的消息的位置信息；传输接口，被配置为接收消息处理设备发送的消息处理请求，所述消息处理请求至少包括所请求处理消息的主题；分区状态查询器，被配置为在所述消息分布状态存储器中查询与所述消息处理请求中的主题相对应的存储分区信息，并经由所述传输接口将所查询到的存储分区信息发送给相应消息处理设备；以及消息位置管理器，被配置为处理通过所述传输接口接收的、来自消息处理设备的消息位置查询请求，从所述消息分布状态存储器中获取与该消息位置查询请求中的存储分区相对应的存储分区的当前要处理消息的位置信息、并经由所述传输接口发送给相应消息处理设备；以及被配置为处理通过所述传输接口接收的、来自消息处理设备的消息位置更新请求，基于所述消息位置更新请求中的消息大小，更新所述消息分布状态存储器中、与所述消息位置更新请求中的存储分区相对应的存储分区的当前要处理消息的位置信息。