买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网恭喜福建天泉教育科技有限公司申请的专利一种消息消费的优化方法与终端获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN114490026B 。

龙图腾网通过国家知识产权局官网在2025-03-28发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202111570368.8，技术领域涉及：G06F9/50；该发明授权一种消息消费的优化方法与终端是由刘德建;张海祥;陈宏设计研发完成，并于2021-12-21向国家知识产权局提交的专利申请。

本一种消息消费的优化方法与终端在说明书摘要公布了：本发明公开了一种消息消费的优化方法与终端；根据kafka系统的存储区的数量建立数量对应的消费主线程，由每个消费主线程建立预设数量的子线程；由消费主线程向kafka系统的各个分区分别获取预设数量的消息，并根据消息的第一业务主键和预设的业务逻辑条件，对消息进行分组；由消费主线程根据分组结果将消息分配至自身的子线程进行处理；针对kafka上的每个存储均设置了一个消费主线程，跳开了kafka的设计方式，由一主线程消费一个partition中的消息，并进行分组，由多个子线程根据分组结果来对消息进行处理，提高了kafka的消费吞吐量，且能够通过调整线程数量来控制调整消息的消费速率，更加灵活多变。

本发明授权一种消息消费的优化方法与终端在权利要求书中公布了：1.一种消息消费的优化方法，其特征在于，包括步骤：S1、根据kafka系统的存储区的数量建立数量对应的消费主线程，由每个所述消费主线程建立预设数量的子线程；S2、由所述消费主线程向所述kafka系统的各个分区分别获取预设数量的消息，并根据所述消息的第一业务主键和预设的业务逻辑条件，对所述消息进行分组；步骤S2中所述根据所述消息的第一业务主键和预设的业务逻辑条件，对所述消息进行分组包括：识别所有所述消息中的第一业务主键，将所述第一业务主键相同的两条以上的所述消息归为一组并记录到重复集合中，其余消息记录至不重复集合中；S3、由所述消费主线程根据分组结果将所述消息分配至自身的所述子线程进行处理；所述步骤S3具体为：由所述消费主线程将记录在所述不重复集合中的所有消息随机分配至自身的子线程进行并发处理，同时将记录在重复集合中的所述消息以分组为单位随机分配至自身的所述子线程中，由所述子线程依照分组的所述消息中的时间信息对所述消息进行顺序处理。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人福建天泉教育科技有限公司，其通讯地址为：350212 福建省福州市长乐区湖南镇大鹤村(福建天棣动漫科技有限公司)；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。