一种消息分发装置及方法

摘要

本发明的主要目的在于提出一种消息分发装置及方法，旨在解决现有技术中基于Kafka系统的消息消费速率受限的问题，该方法包括：从Kafka系统中读取消息；将读取到的消息划分为多组消息；创建多个子线程；将分组后的多组消息分别发送至各子线程，该方案提高了消息的处理效率。

主权项

一种消息分发装置，其特征在于，所述装置包括：读取模块，用于从消息系统中读取消息；划分模块，用于将读取到的消息划分为多组消息；创建模块，用于创建多个子线程；发送模块，用于将所述多组消息分别发送至各子线程。