rocketmq参数配置

Love The Way You Lie 2022-05-17 00:05 502阅读 0赞

下载代码：git clone https://github.com/tgou/RocketMQ 1.  
打包：mvn -Dmaven.test.skip=trueclean package install assembly:assembly-U 2.  
该配置首先从java属性rocketmq.home.dir中获取，如果没有获取到从系统环境变量ROCKETMQ\_HOME中获取 1)  
虽然该配置是可选，但是前提是已经配置了rocketmq.home.dir或者ROCKETMQ\_HOME 2)  
rocketmqHome=/home/admin/XX 可选） i.  
该配置首先从java属性rocketmq.namesrv.addr中获取，如果没有获取到从系统环境变量NAMESRV\_ADDR中获取 1)  
该配置也可以从启动broker的参数中配置：-n "127.0.0.1:9876" 2)  
虽然该配置是可选，但是前提是已配置上述三种方法之一 3)  
namesrvAddr=127.0.0.1:9876;192.168.0.3:9876（可选） ii.  
该配置默认从系统可用地址中选择一个 1)  
在某些场景可以手动配置ip，例如程序运行在虚拟机中外部无法访问默认地址，或者用来解决docker本地ip外部无法访问的问题 2)  
brokerIP1=127.0.0.1（可选） iii.  
broker的ha地址，其它用途同上，不过一般不需要配置 1)  
brokerIP2=127.0.0.1（可选） iv.  
该选项虽然有默认值，但是线上环境最好填写，要不然集群注册会有问题 1)  
属于同一个主备配置的broker的brokerName要一样 2)  
该选项默认取当前机器地址，如果取不到默认是"DEFAULT\_BROKER" 3)  
brokerName=broker\_aaa\_bb（必填） v.  
该选项默认是"DEFAULT\_CLUSTER" 1)  
当需要通过同一个namesrv管理多个集群的时候，不同集群配置不同的值 2)  
brokerClusterName=DEFAULT\_CLUSTER（可选） vi.  
该选项默认是0，代表主 1)  
当配置主备的时候，备库需要递增，例如1,2等 2)  
brokerId=0（必填） vii.  
默认8，表示默认为每个topic创建的queue的数量 1)  
defaultTopicQueueNums=8（可选） viii.  
当topic不存在的时候自动创建topic，默认为true 1)  
线上最好关闭，有利于管理topic 2)  
autoCreateTopicEnable=true ix.  
当订阅组不存在的时候，自动创建，默认为true 1)  
线上最好关闭，便于管理消息订阅组 2)  
autoCreateSubscriptionGroup=true x.  
是否要拒绝事务消息，默认为false 1)  
当broker不希望支持事务消息的时候，可以设置为true 2)  
rejectTransactionMessage=false xi.  
是否通过域名系统获得namesrv的地址，默认为false 1)  
当为了提高namesrv地址的灵活性，可以设置为true，当打开该选项的时候，上边namesrvAddr配置中所述的都可以不配置 2)  
fetchNamesrvAddrByAddressServer=false xii.  
broker配置 a.  
默认地址为java属性的user.home + "store"，也就是存储在当前用户目录的store目录下 1)  
storePathRootDir=/home/admin/store（可选） i.  
默认地址为当前用户目录user.home + "store" + "commitlog" 1)  
storePathCommitLog=/home/admin/store/commitlog ii.  
commitlog刷盘的间隔，默认为1000毫秒，即1秒 1)  
flushIntervalCommitLog=1000（可选） iii.  
是否是定时刷盘，默认为false，也就是实时刷盘，实时刷盘是指有数据写入就会触发刷盘逻辑，如果满足刷页条件就刷盘 1)  
flushCommitLogTimed=false（可选） iv.  
何时触发删除文件，默认是凌晨4点删除文件 1)  
该时间是服务器时间，配置服务器压力最低的时间就可以 2)  
deleteWhen="04"（可选） v.  
文件保留时间，单位小时 1)  
fileReservedTime=72（可选） vi.  
默认值是1024 \* 512 = 524288，也就是512k 1)  
maxMessageSize=524288（可选） vii.  
最大被拉取的消息字节数，消息在内存，默认256k 1)  
maxTransferBytesOnMessageInMemory=（可选） viii.  
最大被拉取的消息个数，消息在内存，默认32个 1)  
maxTransferCountOnMessageInMemory=32（可选） ix.  
最大被拉取的消息字节数，消息在磁盘，默认64k 1)  
maxTransferBytesOnMessageInDisk=（可选） x.  
最大被拉取的消息个数，消息在磁盘，默认8个 1)  
maxTransferCountOnMessageInDisk=8（可选） xi.  
命中消息在内存的最大比例 1)  
accessMessageInMemoryMaxRatio=40（可选） xii.  
是否开启消息索引功能 1)  
messageIndexEnable=true（可选） xiii.  
是否使用安全的消息索引功能，即可靠模式。可靠模式下，异常宕机恢复慢，非可靠模式下，异常宕机恢复快 1)  
messageIndexSafe=false xiv.  
store存储配置 b.  
普通配置 - 该配置都写在properties文件中 3.

打包与配置  
  
分区 rocketmq 的第 1 页  
是否使用安全的消息索引功能，即可靠模式。可靠模式下，异常宕机恢复慢，非可靠模式下，异常宕机恢复快 1)  
如果不设置，则从NameServer获取Master HA服务地址 1)  
haMasterAddress=127.0.0.1（可选） xv.  
默认是ASYNC\_MASTER，异步复制master 1)  
还有SYNC\_MASTER - 同步双写master；SLAVE - slave服务器 2)  
brokerRole=ASYNC\_MASTER（可选） xvi.  
默认是ASYNC\_FLUSH，异步刷盘 1)  
还有SYNC\_FLUSH，同步刷盘 2)  
flushDiskType=ASYNC\_FLUSH（可选） xvii.  
磁盘空间超过90%警戒水位，自动开始删除文件 1)  
cleanFileForciblyEnable=true xviii.  
分区 rocketmq 的第 2 页  
export ROCKETMQ\_HOME=/home/rocketmq a.  
将bin目录下的文件设置为可执行，chmod +x mq\* b.  
设置环境变量 1.  
配置jvm参数，在runserver.sh中 a.  
运行 nohup mqnamesrv& b.  
线上日志要配置监控 c.  
启动namesrv 2.  
配置jvm参数，在runbroker.sh中 a.  
调整配置文件，根据需求是多m还是ms结构，其中nameSrv的地址可以配置在配置文件  
中，也可以写到运行命令中  
b.  
运行 nohup sh mqbroker -n "127.0.0.1:9876" -c ../conf/2m-noslave/broker-a.properties& c.  
事务启动运行nohup sh mqbroker -n "127.0.0.1:9876" -c ../conf/2m-noslave/broker-  
a.properties -tc ../conf/rocketmq.yaml &  
d.  
CREATE TABLE \`t\_transaction\` (  
\`id\` bigint(20) unsigned NOT NULL AUTO\_INCREMENT,  
\`broker\_name\` varchar(50) NOT NULL,  
\`offset\` bigint(20) unsigned NOT NULL,  
\`producer\_group\` varchar(50) NOT NULL,  
\`gmt\_create\` datetime NOT NULL,  
PRIMARY KEY (\`id\`),  
KEY \`bpo\_idx\` (\`broker\_name\`,\`producer\_group\`,\`offset\`),  
KEY \`bpg\_idx\` (\`broker\_name\`,\`producer\_group\`,\`gmt\_create\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8  
也需要修改rocketmq.yaml配置中的brokerName，跟对应的broker一样  
其中事务消息需要去数据库建表 e.  
启动broker 3.  
安装  
2015年10月22日 15:12  
分区 rocketmq 的第 3 页  
sh $\{ROCKETMQ\_HOME\}/bin/tools.sh com.alibaba.rocketmq.example.quickstart.Producer a.  
sh $\{ROCKETMQ\_HOME\}/bin/tools.sh  
com.alibaba.rocketmq.example.transaction.TransactionProducer  
b.  
sh $\{ROCKETMQ\_HOME\}/bin/tools.sh com.alibaba.rocketmq.example.quickstart.Consumer c.  
运行例子 1.  
测试  
2015年10月22日 16:57  
分区 rocketmq 的第 4 页  
The most commonly used mqadmin commands are: 1.  
updateTopic Update or create topic  
deleteTopic Delete topic from broker and NameServer.  
updateSubGroup Update or create subscription group  
deleteSubGroup Delete subscription group from broker.  
updateBrokerConfig Update broker's config  
topicRoute Examine topic route info  
topicStatus Examine topic Status info  
brokerStatus Fetch broker runtime status data  
queryMsgById Query Message by Id  
queryMsgByKey Query Message by Key  
queryMsgByOffset Query Message by offset  
printMsg Print Message Detail  
producerConnection Query producer's socket connection and client version  
consumerConnection Query consumer's socket connection, client version and subscription  
consumerProgress Query consumers's progress, speed  
consumerStatus Query consumer's internal data structure  
cloneGroupOffset clone offset from other group.  
clusterList List all of clusters  
topicList Fetch all topic list from name server  
updateKvConfig Create or update KV config.  
deleteKvConfig Delete KV config.  
wipeWritePerm Wipe write perm of broker in all name server  
resetOffsetByTime Reset consumer offset by timestamp(without client restart).  
updateOrderConf Create or update or delete order conf  
cleanExpiredCQ Clean expired ConsumeQueue on broker.  
startMonitoring Start Monitoring  
checkMsg Check Message Store  
statsAll Topic and Consumer tps stats  
syncDocs Synchronize wiki and issue to github.com  
See 'mqadmin help <command>' for more information on a specific command.  
按照msgId查询消息：mqadmin queryMsgById -i 0A00020F00002A9F000000000000D352-n  
127.0.0.1:9876  
2.  
下载代码：git clone https://github.com/tgou/rocketmq-console a.  
配置config.properties中的namesrv地址 b.  
打包：mvn clean package -Dmaven.test.skip=true c.  
放到web容器中运行 d.  
安装web管理界面 3.  
运维  
2015年10月22日 17:09  
分区 rocketmq 的第 5 页  
事务日志表设计 1.  
设计要点 2.  
dispatch的时候如果是prepare的事务消息，插入db（可以批量提高性能，需要考虑db不可用如何处理） ○  
位置在DefaultMessageStore的doDispatch方法中 ○  
prepare事务日志插入 •  
dispatch的时候如果是rollback事务消息，删除db事务日志 ○  
位置在DefaultMessageStore的doDispatch方法中 ○  
rollback事务日志删除 •  
同上 ○  
commit事务日志删除 •  
遍历当前broker的XX秒之内的prepare事务日志，并通过offset拿到该消息的详情，通过producer\_group拿到机器ip进行回查 ○  
每个broker单线程定时程序回查prepare事务日志 ○  
check事务回查 •  
由于requestDispatch中的消息消费顺序跟commitLog的顺序是一样的，所以在每次事务日志成功写入db之后更新当前事务日志的checkpoint（此处可以进行批量处  
理之后再记录checkpoint）  
○  
事务日志回滚的时候，拿到所有checkpoint的最小值进行recovery，重新走dispatch流程 ○  
事务日志redo •  
○ 由于recover消息的代码是在BrokerController的load期间进行的，所以初始化db的代码要在load的时候加载，而不能放到start的时候加载  
• 事务消息恢复  
属性名 类型 长度 备注  
id long 表主键，应用中不使用  
broker\_name varchar 50 配置文件里的brokerName，一定要配置，而且不要改  
offset bigint broker内commitLog的offset  
producer\_group varchar 50 生产者配置的group，不要轻易修改，如果更改也要进行版本兼容，要不然事务回查会有问题  
gmt\_create datetime 日志创建时间  
事务设计  
2015年10月19日 16:12  
分区 rocketmq 的第 6 页