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

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

10多年的塔什库尔干塔吉克网站建设经验,针对设计、前端、开发、售后、文案、推广等六对一服务,响应快,48小时及时工作处理。营销型网站的优势是能够根据用户设备显示端的尺寸不同,自动调整塔什库尔干塔吉克建站的显示方式,使网站能够适用不同显示终端,在浏览器中调整网站的宽度,无论在任何一种浏览器上浏览网站,都能展现优雅布局与设计,从而大程度地提升浏览体验。成都创新互联公司从事“塔什库尔干塔吉克网站设计”,“塔什库尔干塔吉克网站推广”以来,每个客户项目都认真落实执行。

一 机器部署

1、机器组成

7台机器,均为16G内存

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

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

2、运行环境配置

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

3、刷盘方式

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

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

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

二 性能评测

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端消费速率很快,故发送消息的数据量越多越好,这样以便于看出效果)。

    消息发送如下:

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

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

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

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

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

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

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

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

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

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

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

       设置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。

    分析结果如下:

自定义最大拉取数
(期望)
批量拉消息最大条数
(实际)
11
32
54
87
1615
2019
2423
2726
3130
3231
3332
3432
3532
3632
5432
8032
10032

二 评测结果

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

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

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

    (2)若maxA <= 32, 则 maxB = maxA - 1

    (3)若maxA > 32, 则maxB = 32 

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

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


新闻标题:如何实现Rocketmq拉取pull消息分页数目测试
本文来源:http://pwwzsj.com/article/jecpej.html