一種基于Kafka的同步消息服務(wù)系統(tǒng)及實現(xiàn)方法
基本信息
| 申請?zhí)?/td> | CN202010227547.0 | 申請日 | - |
| 公開（公告）號 | CN111555957A | 公開（公告）日 | 2020-08-18 |
| 申請公布號 | CN111555957A | 申請公布日 | 2020-08-18 |
| 分類號 | H04L12/58(2006.01)I | 分類 | - |
| 發(fā)明人 | 陳劍;劉航 | 申請（專利權(quán)）人 | 孩子王兒童用品股份有限公司 |
| 代理機構(gòu) | 北京市蘭臺律師事務(wù)所 | 代理人 | 張峰 |
| 地址 | 210000江蘇省南京市麒麟科技創(chuàng)新園智匯路300號 | ||
| 法律狀態(tài) | - | ||
摘要
| 摘要 | 本發(fā)明公開一種基于Kafka的同步消息服務(wù)系統(tǒng)及實現(xiàn)方法，系統(tǒng)包括：主題管理模塊，為主題分配具體的生產(chǎn)者代理服務(wù)節(jié)點和Cache節(jié)點，為每個主題分配唯一的密鑰標(biāo)識，提供主題和密鑰的認證服務(wù)；消費管理模塊，對消費組進行約束，為消費組分配具體的消費者代理服務(wù)節(jié)點，并為每個消費組分配唯一的密鑰標(biāo)識，提供消費組和接入密鑰的認證服務(wù)；生產(chǎn)者代理模塊，將分組后消息寫入本地隊列和Cache隊列，批量將隊列消息同步發(fā)送到Kafka，由核心守護線程與Kafka集群進行交互；以及，消費者代理模塊，負責(zé)消費主題消息并做權(quán)限認證。此種技術(shù)方案可解決消息發(fā)送的順序、消息消費的重復(fù)等問題，消息服務(wù)效果好。?? |
