在线精品99_中国九九盗摄偷拍偷看_91免费版在线观看_91.app_91高清视频在线_99热最新网站

如何实现Rocketmq拉取pull消息分页数目测试

164次阅读
没有评论

共计 1750 个字符,预计需要花费 5 分钟才能阅读完成。

这篇文章主要介绍了如何实现 Rocketmq 拉取 pull 消息分页数目测试,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让丸趣 TV 小编带着大家一起了解一下。

一   机器部署

1、机器组成

7 台机器,均为 16G 内存

每台服务器均有 4 个 CPU,2 核

2、运行环境配置

3、刷盘方式

每台机器 master 机器均采用异步刷盘方式

二   性能评测

1、评测目的

  测试 pull 消费模式,单次批量拉消息最大条数。

2、评测指标

  批量拉取消息最大条数 msgExtSize

  自定义配置   最大拉取条数  maxNums

3、评测逻辑

 (1)先发送 10000 条消息,等待消息全部发送完毕,然后启动 consumer 端消费消息。

 (2)配置 maxNums 的值分别为  1、3、5、8、16、20、24、27、31、32、33、34、35、36、54、80、100,然后对比每次拉取消息的 msgExtSize 条数。

 (3)记录每次批量拉取消息的最大条数,即可测试出批量拉消息最大条数。

 (4)步骤 3 找出批量拉消息最大条数后,在这个数值前后再设置连续数字,进一步验证此数值。

4、评测过程

 (1)第一组:开启 20 个线程,每个线程发送 3000 条数据,总共向 topic 名称为  “pullTest”发送 60W 条消息(消息量越多越好,consumer 端消费速率很快,故发送消息的数据量越多越好,这样以便于看出效果)。

  消息发送如下:

  设置 maxNums= 1 的消费记录,输出的 msgExtSize=1

  设置 maxNums= 3 的消费记录,输出的 msgExtSize=2

  设置 maxNums= 5 的消费记录,输出的 msgExtSize=4

  设置 maxNums= 8 的消费记录,输出的 msgExtSize=7

设置 maxNums=16 的消费记录,输出的 msgExtSize=15

  设置 maxNums=20 的消费记录,输出的 msgExtSize=19

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=24 的消费记录,输出的 msgExtSize=23

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=27 的消费记录,输出的 msgExtSize=26

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=32 的消费记录,输出的 msgExtSize=31

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=36 的消费记录,输出的 msgExtSize=32

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=54 的消费记录,输出的 msgExtSize=32

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=80 的消费记录,输出的 msgExtSize=32

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=100 的消费记录,输出的 msgExtSize=32

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  分析以上各条件的测试数据可知:  批量拉消息最大条数的条数是 32。

 (2)第二组:在拉取消息的最大条数   前后的数字,细粒度的再次测试。

  设置 maxNums=33 的消费记录,输出的 msgExtSize=32

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=34 的消费记录,输出的 msgExtSize=32

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=35 的消费记录,输出的 msgExtSize=32

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  设置 maxNums=31 的消费记录,输出的 msgExtSize=30

如何实现 Rocketmq 拉取 pull 消息分页数目测试

  进一步分析测试数据,批量拉消息最大条数的条数是 32。

  分析结果如下:

自定义最大拉取数
(期望) 批量拉消息最大条数
(实际)1132548716152019242327263130323133323432353236325432803210032

二   评测结果

 1、如下测试结论,基于消息存储于内存的场景(而非消息存储于磁盘的场景)。

  在 Pull 消费场景下,令  maxA =  自定义最大拉取条数, maxB= 实际批量拉消息最大条数,  则得出如下结论:

 (1)若 maxA = 1,  则 maxB = 1

 (2)若 maxA  = 32,  则  maxB = maxA – 1

 (3)若 maxA   32,  则 maxB = 32 

 2、查阅 RocketMQ 配置文件,如果消息存储于磁盘,则实际批量拉消息最大条数是为 8(并非期望的数值 32),奈何此种测试场景不太好重现,暂未测试,留待后续进一步重现测试。

感谢你能够认真阅读完这篇文章,希望丸趣 TV 小编分享的“如何实现 Rocketmq 拉取 pull 消息分页数目测试”这篇文章对大家有帮助,同时也希望大家多多支持丸趣 TV,关注丸趣 TV 行业资讯频道,更多相关知识等着你来学习!

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-08-16发表,共计1750字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)
主站蜘蛛池模板: 日本免费人成视频播放 | 女人一级毛片免费观看 | 久久久久久久国产免费看 | 免费日本一区 | 精品一区二区三区电影 | 国产成人av大片大片在线播放 | 2021国产精品视频 | 亚洲免费二区三区 | 黄动漫在线 | 99精品视频在线观看免费 | 亚洲成人高清在线观看 | 少妇粉嫩小泬喷水视频www | 一级毛片在线 | 美女很黄很黄是免费的 | 久久久精品3d动漫一区二区三区 | 国产青草视频在线观看 | 韩国乱码伦视频免费 | 久久99国产一区二区三区 | 伦理片高清在线观看网站 | 成人毛片一区二区 | 亚洲性另类 | 日韩电影一二三区 | 性无码一区二区三区在线观看 | 欧美大杳蕉视频在线观看 | 成人免费毛片一区二区三区 | 久久66haose精品 | 亚洲最新网站 | 国产精品视频99 | 亚洲影院在线观看 | 久久午夜神器 | 国模冰莲极品自慰人体 | 国产精品成人99一区无码 | 成在线人视频免费视频 | 亚洲婷婷五月综合狠狠爱 | 9久热久re爱免费精品视频 | 亚洲视频在线免费播放 | 日本久久爱 | 亚洲狠狠婷婷综合久久久久网站 | 成人国产精品久久久免费 | 国产乱子伦精品免费无码专区 | 成年人视频在线免费看 |