← 返回列表
消息管理方法、装置、电子设备及计算机可读取存储介质
摘要文本
本申请提供一种消息管理方法、装置、电子设备及计算机可读取存储介质，涉及网络计算技术领域。该方法应用于多泳道的Kafka集群中，多泳道包括主泳道和至少一个分支泳道；主泳道中部署有主生产方和主消费方，分支泳道部署有更新生产方，或，分支泳道部署有更新生产方和更新消费方，或，分支泳道部署有更新消费方；方法包括：基于每个泳道中的代理程序进行字节码增强，以确定每个泳道的标签信息；通过与Kafka集群连接的控制面程序，确定主消费方对应的主代理程序订阅的主题信息；通过主生产方和/或更新生产方，根据相应的标签信息输出生产消息；通过主代理程序，根据主题信息对生产消息进行管理。
申请人信息
- 申请人:南京研利科技有限公司; 上海收钱吧互联网科技股份有限公司
- 申请人地址:211300 江苏省南京市高淳区经济开发区双高路89号1幢2072室
- 发明人: 南京研利科技有限公司; 上海收钱吧互联网科技股份有限公司
专利详细信息
| 项目 | 内容 |
|---|---|
| 专利名称 | 消息管理方法、装置、电子设备及计算机可读取存储介质 |
| 专利类型 | 发明申请 |
| 申请号 | CN202410015537.9 |
| 申请日 | 2024/1/5 |
| 公告号 | CN117527880A |
| 公开日 | 2024/2/6 |
| IPC主分类号 | H04L67/141 |
| 权利人 | 南京研利科技有限公司; 上海收钱吧互联网科技股份有限公司 |
| 发明人 | 陈灏; 陆家靖; 徐豪 |
| 地址 | 江苏省南京市高淳区经济开发区双高路89号1幢2072室; 上海市普陀区中江路879弄26号楼306室 |
专利主权项内容
1.一种消息管理方法，其特征在于，所述方法应用于多泳道的Kafka集群中，所述多泳道包括主泳道和至少一个分支泳道；所述主泳道中部署有主生产方和主消费方，所述分支泳道部署有更新生产方，或，所述分支泳道部署有更新生产方和更新消费方，或，所述分支泳道部署有更新消费方；所述方法包括：基于每个所述泳道中的代理程序进行字节码增强，以确定每个所述泳道的标签信息；通过与所述Kafka集群连接的控制面程序，确定所述主消费方对应的主代理程序订阅的主题信息；其中，所述主题信息包括队列主题与对应的所述消费方所处的所述泳道的所述标签信息之间的映射关系；通过所述主生产方和/或所述更新生产方，根据相应的所述标签信息输出生产消息；通过所述主代理程序，根据所述主题信息对所述生产消息进行管理。