公开(公告)号：CN106293968B

公开(公告)日：2019-05-10

申请号：CN201610630955.4

申请日：2016-08-04

Applicant: 华中科技大学

Inventor： 王非 ,  谢青松

IPC: G06F9/54

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

公开(公告)号：CN106293968A

公开(公告)日：2017-01-04

申请号：CN201610630955.4

申请日：2016-08-04

Applicant: 华中科技大学

Inventor： 王非 ,  谢青松

IPC: G06F9/54

CPC classification number: G06F9/546

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