一种基于Kafka消息中间件的双向通信系统及方法

摘要

本发明公开了一种基于Kafka消息中间件的双向通信系统及方法，其系统包括发布者、订阅者、Kafka集群以及数据库；发布者和订阅者都包含Kafka生产者和Kafka消费者，且都具有向Kafka集群发布和从Kafka集群接收消息的能力；其方法基于该系统，包括发布者处理过程和订阅者处理过程，其中发布者处理过程包括发布者初始化、发布者的消息上传以及发布者的消息下发的步骤；订阅者处理过程包括订阅者的初始化、订阅者的消息上传以及订阅者的消息下发的步骤；本发明提供的这种系统及方法实现了基于Kafka消息中间件的双向通信；可应用于需要反方向通信的环境进行双向的数据采集与控制。

主权项

一种基于Kafka消息中间件的双向通信系统，其特征在于，包括发布者、订阅者、Kafka集群以及数据库；所述发布者和订阅者均包含Kafka生产者和Kafka消费者，且均具有向Kafka集群发布和从Kafka集群接收消息的能力；所述发布者用于与消息流进行通信、向Kafka集群发布上传消息、从Kafka集群接收下发消息；所述订阅者用于与其他应用程序通信，获取或者生成下发消息、向Kafka集群发布下发消息、从Kafka集群接收上传消息；所述数据库用于存储消息流标识与发布者标识之间的映射关系。