一种消息消费的优化方法与终端
实质审查的生效
摘要
本发明公开了一种消息消费的优化方法与终端;根据kafka系统的存储区的数量建立数量对应的消费主线程,由每个消费主线程建立预设数量的子线程;由消费主线程向kafka系统的各个分区分别获取预设数量的消息,并根据消息的第一业务主键和预设的业务逻辑条件,对消息进行分组;由消费主线程根据分组结果将消息分配至自身的子线程进行处理;针对kafka上的每个存储均设置了一个消费主线程,跳开了kafka的设计方式,由一主线程消费一个partition中的消息,并进行分组,由多个子线程根据分组结果来对消息进行处理,提高了kafka的消费吞吐量,且能够通过调整线程数量来控制调整消息的消费速率,更加灵活多变。
基本信息
专利标题 :
一种消息消费的优化方法与终端
专利标题(英):
暂无
公开(公告)号 :
CN114490026A
申请号 :
CN202111570368.8
公开(公告)日 :
2022-05-13
申请日 :
2021-12-21
授权号 :
暂无
授权日 :
暂无
发明人 :
刘德建张海祥陈宏
申请人 :
福建天泉教育科技有限公司
申请人地址 :
福建省福州市长乐区湖南镇大鹤村(福建天棣动漫科技有限公司)
代理机构 :
福州市博深专利事务所(普通合伙)
代理人 :
张明
优先权 :
CN202111570368.8
主分类号 :
G06F9/50
IPC分类号 :
G06F9/50 G06Q30/06
IPC结构图谱
G
G部——物理
G06
计算;推算或计数
G06F
电数字数据处理
G06F9/00
程序控制装置,例如,控制单元
G06F9/06
应用存入的程序的,即应用处理设备的内部存储来接收程序并保持程序的
G06F9/46
多道程序装置
G06F9/50
资源分配,例如,中央处理单元的
法律状态
2022-05-31 :
实质审查的生效
IPC(主分类) : G06F 9/50
申请日 : 20211221
申请日 : 20211221
2022-05-13 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载