RocketMq部分参数实验

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了RocketMq部分参数实验相关的知识,希望对你有一定的参考价值。

参考技术A 实验拍摄的图片就不放了

(1)  pullBatchSize :单次从每个队列中拉取消息的条数(故单次拉取的总数为 pullBatchSize*master总数*该taopic的队列数,以本次实验为例,实验中用到的topic 在每台服务器共有16个写队列,集群共有3台master,所以单次拉取的总数约为 32X3X16=1536条),若要加大这个值则一点更要修改参数:(单次拉取消息数量)maxTransferCountOnMessageInMemory,默认值为32;还可能涉及到修改:(注:若消息量过大,则可以考虑修改

maxTransferBytesOnMessageInMemory:一次服务端消息拉取,消息在内存中传输允许的最大传输字 节,默认为256K

maxTransferBytesOnMessageInDisk:一次服务消息端消息拉取,消息在磁盘中传输允许的最大字 节, 默认为64K

maxTransferCountOnMessageInDisk:一次消息服务端消息拉取,消息在磁盘中传输允许的最大条 数, 默认为8条)

(2)  PullInterval :两次拉取之间的间隔时间(测试中设为10s)

(3)  consumeThreadMin :最小拉取线程数

(4)  consumeThreadMax :最大拉取线程数(实验中发现,线程数并未在最小拉取线程数和最大拉取线程数之间,而是大约等于最小线程数)

(5)  consumeMessageBatchMaxSize :每次传入messageListener#consumeMessage中的消息的条数,被pullBatchSize限制,并且这些消息中要是有一条处理失败,则全部失败

RocketMQ(16)——Name Server可配置参数介绍

Name Server可配置参数介绍

Name Server是通过RocketMQ的bin目录下的mqnamesrv指令启动的,之前介绍的都是不带任何参数直接启动的,实际上该指令还可以带一些参数。通过mqnamesrv -h可以查看mqnamesrv指令可以配置的一些参数。

$ bin/mqnamesrv -h
usage: mqnamesrv [-c <arg>] [-h] [-n <arg>] [-p]
 -c,--configFile <arg>    Name server config properties file
 -h,--help                Print help
 -n,--namesrvAddr <arg>   Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
 -p,--printConfigItem     Print all config item

从上面的可以看到,主要可以通过-c指定一个配置文件,而该配置文件中可配置的内容可以通过mqnamesrv -p打印出来,它是通过日志输出的方式打印出来的,去除日志相关信息外的日志内容即可配置信息如下。

rocketmqHome=/home/elim/dev/tools/rocketmq4.5.0
kvConfigPath=/home/elim/namesrv/kvConfig.json
configStorePath=/home/elim/namesrv/namesrv.properties
productEnvName=center
clusterTest=

以上是关于RocketMq部分参数实验的主要内容,如果未能解决你的问题,请参考以下文章

rocketmq那些事儿之集群环境搭建

Day312.RocketMQ集群进行OS内核&JVM参数的调整 -RocketMQ

RocketMQ部分数据消费不了问题排查

详解RocketMQ不同类型的消费者

Rocketmq

Rocketmq