技术:rocketmq4.2
运行环境:centos7.3
demo功能:提供说明rocketmq安装过程
修改配置 ./conf/namesrv.conf
kvConfigPath=/data/namesrv/kvConfig.properties
修改日志配置 ./conf/logback_namesrv.xml
/data/rocketmq/logs/rocketmqlogs/namesrv_default.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/namesrv_default.%i.log.gz
1
5
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/namesrv.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/namesrv.%i.log.gz
1
5
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
0
true
%d{yyy-MM-dd HH\:mm\:ss,SSS} %p %t - %m%n
UTF-8
启动2台
nohup ./bin/mqnamesrv -c ./conf/namesrv.conf > /dev/null 2>&1 &
注意执行: /bin/os.sh (对于os参数优化)
新建异步模式配置:async.properties
brokerName=rocketmq-broker-1
brokerId=0
brokerRole=ASYNC_MASTER ### 同步:brokerRole=SYNC_MASTER
namesrvAddr=127.0.0.1:9876;127.0.0.2:9876
flushDiskType=ASYNC_FLUSH
fileReservedTime=168
deleteWhen=04
autoCreateTopicEnable=false
storePathCommitLog=/data/rocketmq/commitlog
rejectTransactionMessage=true
storePathRootDir=/data/rocketmq
cleanFileForciblyEnable=true
autoCreateSubscriptionGroup=false
brokerClusterName=rocketmq-cluster-1
brokerIP1=192.168.1.101
日志配置(master, slave 可以配置一样)
./conf/logback_broker.xml
/data/rocketmq/logs/rocketmqlogs/broker_default.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/broker_default.%i.log.gz
1
10
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/broker.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/broker.%i.log.gz
1
20
128MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/protection.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/protection.%i.log.gz
1
10
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/watermark.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/watermark.%i.log.gz
1
10
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/store.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/store.%i.log.gz
1
10
128MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/remoting.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/remoting.%i.log.gz
1
10
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/storeerror.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/storeerror.%i.log.gz
1
10
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/transaction.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/transaction.%i.log.gz
1
10
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/lock.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/lock.%i.log.gz
1
5
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/filter.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/filter.%i.log.gz
1
10
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p %t - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/stats.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/stats.%i.log.gz
1
5
100MB
%d{yyy-MM-dd HH:mm:ss,GMT+8} %p - %m%n
UTF-8
/data/rocketmq/logs/rocketmqlogs/commercial.log
true
/data/rocketmq/logs/rocketmqlogs/otherdays/commercial.%i.log.gz
1
10
500MB
true
%d{yyy-MM-dd HH\:mm\:ss,GMT+8} %p %t - %m%n
UTF-8
编写启动脚本
nohup sh ./bin/mqbroker -c ./async.properties > /dev/null 2>&1 &
启动2台
新建异步配置文件
brokerName=broker-1 ## 一组 master 和 slave 的名字一样
brokerId=1
brokerRole=SLAVE
namesrvAddr=127.0.0.1:9876;127.0.0.2:9876
flushDiskType=ASYNC_FLUSH ## 磁盘还是需要异步
fileReservedTime=168
deleteWhen=04
autoCreateTopicEnable=false
storePathCommitLog=/data/rocketmq/commitlog
rejectTransactionMessage=true
storePathRootDir=/data/rocketmq
cleanFileForciblyEnable=true
autoCreateSubscriptionGroup=false
brokerClusterName=rocketmq-cluster-1
brokerIP1=192.168.1.102
启动脚本
nohup sh ./bin/mqbroker -c ./async.properties > /dev/null 2>&1 &
启动2台
欢迎添加微信,互相学习↑↑↑ -_-
白老虎
programming is not only to solve problems, ways to think
grafana 级连 菜单 templating (variables) 配置
rocketmq 集群搭建 (2master + 2slave + 2namesrv)
AI 机器人 抓取 微信 聊天中的 百度网盘 分享地址和密码