rocketMq - 神奇的32

简介: 概述    这篇文章主要是把push模式下consumer批量拉取消息数量单此最多32条的问题,这个问题是和组内的一个同事一起排查问题的时候得出的结论,我同事负责发现这个问题,我负责定位这个问题。

概述

    这篇文章主要是把push模式下consumer批量拉取消息数量单此最多32条的问题,这个问题是和组内的一个同事一起排查问题的时候得出的结论,我同事负责发现这个问题,我负责定位这个问题。


问题描述

    问题描述细节可以参考这篇文章,在push模式下consumer每次拉取的数目不超过32个:Rocketmq拉取pull消息分页数目测试,我这边把这篇文章的核心的测试结果贴出来。

img_13aa3112731f27c3f1d745d0acf88c2e.png
拉取数据量测试


拉取过程分析

    1、首先把数据拉取的过程分析一下,基本上把consumer端拉取和broker处理拉取的代码已经贴出来了。

    2、在代码最后部分我们把核心的数字32列出来了。


img_34928cdbf6437e89a3d540a950f79d09.png
client端拉取代码


img_815f3f10780b878a15bc944a68709ec5.png
broker注册的消费者


img_7ee60cd13777488981b7d4a28ecd9034.png
拉取过程-1


img_de12d1778710ea9f90a469e6e987eebd.png
拉取过程-2


img_c706c8422ee5c9272fb2dfefc9b4d8cd.png
拉取过程-3


img_2a35b36d3ba82706e506730119803abe.png
拉取过程-4
img_1a67358d9b6dd1edfa6b91421cd2d1d8.png
拉取过程-5


配置参数

    据说broker的配置参数有这个选项,但是事实上据说没效果,我本身没试过。

img_067b29be9d424605d117a3ad3753eeb2.png
相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
5月前
|
消息中间件 存储 Dubbo
RocketMQ(二)
RocketMQ(二)
|
6月前
|
消息中间件 Java 大数据
RocketMQ
【8月更文挑战第29天】RocketMQ
99 15
|
9月前
|
消息中间件 监控 API
RocketMQ 5.0
RocketMQ 5.0 是一款分布式消息中间件,由阿里巴巴开源,提供了高性能、高可靠、高可扩展性的消息传递服务。它采用发布/订阅模式,支持多种消息协议,如 JMS、MQTT 等,可用于构建企业级应用的异步消息处理、系统解耦、流量削峰等场景。
174 4
|
7月前
|
消息中间件 Java RocketMQ
【RocketMQ系列九】SpringCloudStream整合RocketMQ
【RocketMQ系列九】SpringCloudStream整合RocketMQ
524 1
|
9月前
|
消息中间件 Apache RocketMQ
RocketMQ
RocketMQ “【5月更文挑战第24天】”
72 2
|
8月前
|
消息中间件 Java API
详解RocketMQ使用
详解RocketMQ使用
108 0
|
消息中间件 存储 JSON
RocketMQ使用总结
RocketMQ使用总结
211 0
|
消息中间件 负载均衡 Java
RocketMQ6
RocketMQ是一款分布式消息中间件,广泛应用于企业级架构中的异步消息传递、数据流处理、日志收集与传输等场景。RocketMQ 6是RocketMQ的最新版本,相比于旧版本,它具有更高的性能、更好的稳定性和更丰富的功能,支持更多的协议和特性。
121 0
|
消息中间件 存储 运维
RocketMq
RocketMq
130 0
|
消息中间件 存储 缓存
RocketMQ参数约束和建议
Apache RocketMQ 系统中存在很多自定义参数和资源命名,您在使用 Apache RocketMQ 时建议参考如下说明规范系统设置,避对某些具体参数设置不合理导致应用出现异常。
275 0

热门文章

最新文章