一种基于Kafka的同步消息服务系统及实现方法
基本信息
| 申请号 | CN202010227547.0 | 申请日 | - |
| 公开（公告）号 | CN111555957A | 公开（公告）日 | 2020-08-18 |
| 申请公布号 | CN111555957A | 申请公布日 | 2020-08-18 |
| 分类号 | H04L12/58(2006.01)I | 分类 | - |
| 发明人 | 陈剑;刘航 | 申请（专利权）人 | 孩子王儿童用品股份有限公司 |
| 代理机构 | 北京市兰台律师事务所 | 代理人 | 张峰 |
| 地址 | 210000江苏省南京市麒麟科技创新园智汇路300号 | ||
| 法律状态 | - | ||
摘要
| 摘要 | 本发明公开一种基于Kafka的同步消息服务系统及实现方法，系统包括：主题管理模块，为主题分配具体的生产者代理服务节点和Cache节点，为每个主题分配唯一的密钥标识，提供主题和密钥的认证服务；消费管理模块，对消费组进行约束，为消费组分配具体的消费者代理服务节点，并为每个消费组分配唯一的密钥标识，提供消费组和接入密钥的认证服务；生产者代理模块，将分组后消息写入本地队列和Cache队列，批量将队列消息同步发送到Kafka，由核心守护线程与Kafka集群进行交互；以及，消费者代理模块，负责消费主题消息并做权限认证。此种技术方案可解决消息发送的顺序、消息消费的重复等问题，消息服务效果好。 |
