消息系统及消息处理方法

摘要

本发明提供了一种消息系统及消息处理方法，系统包括：元数据服务器、至少一消息处理服务器以及存储服务器；所述元数据服务器包括控制中心以及路由控制模块；所述控制中心，用于将同一主题下的消费端分为多个消费组，每一消费组内至少包括一消费端，不同消费组之间消息的消费进度互相隔离；所述路由控制模块，用于根据路由表将生产端生产的同一主题下的消息路由到所述消息处理服务器中相应的分区，分区中的消息采用先进先出原则以保证消息的顺序，且一分区内的消息被一消费端消费，其中，每一消息具有唯一ID；所述消息处理服务器中接收到的消息存储在所述存储服务器中。本发明极大的提高了消息的可靠性和治理能力，具备极强的故障恢复能力。

主权项

一种消息系统，其特征在于，包括：元数据服务器、至少一消息处理服务器以及存储服务器；所述元数据服务器包括控制中心以及路由控制模块；所述控制中心，用于将同一主题下的消费端分为多个消费组，每一消费组内至少包括一消费端，不同消费组之间消息的消费进度互相隔离；所述路由控制模块，用于根据路由表将生产端生产的同一主题下的消息路由到所述消息处理服务器中相应的分区，分区中的消息采用先进先出原则以保证消息的顺序，且一分区内的消息被一消费端消费，其中，每一消息具有唯一ID；所述消息处理服务器中接收到的消息存储在所述存储服务器中。