rocketmq集群启动和下线
启动name server
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
启动broker
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
-n: name server
生产/消费测试消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
shutdown server
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv
下broker
先关掉broker的读写权限，客户端对这个节点的读写操作会报no permission异常，客户端会重试其他节点
观察该节点无读写流量后，再执行下机器操作
集群搭建
修改配置文件
配置文件目录conf
配置文件broker-a.properties
| 参数名 | 参考值 | 说明 |
|---|---|---|
| brokerClusterName | broker集群名 | |
| brokerName | broker-a | 指定master - slave集群的名称，一个rocketmq集群可以包含多个master-slave集群 |
| brokerId | 0 | 0为master，非0为slave |
| deletewhen | 04（凌晨4点） | 指定删除消息存储过期文件的时间 |
| fileReservedTime | 48（48h后过期） | 指定未发生更新的消息存储文件的保留时间 |
| brokerRole | ASYNC_MASTER（异步复制master） | |
| flushDiskType | ASYNC_FLUSH | 刷盘策略 |
| namesrvAddr | 192.168.1.1:9876;192.168.1.2:9876 | name server地址，多个之间；分割 |
| listenPort | ||
| storePathRootDir | ~/store | 默认是/store，slave可以设置成/store-s |
| storePathCommitLog | ~/store/commitlog | |
| storePathConsumeQueue | ~/store/consumequeue | |
| storePathIndex | ~/store/index | |
| storeCheckPoint | ~/store/checkpoint | |
| abortFile | ~/store/abort | |
| defaultTopicQueueNums | 默认4 | 每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡 |
| autoCreateTopicEnable | 是否允许 Broker 自动创建Topic，生产建议关闭 | |
| autoCreateSubscriptionGroup | 是否允许 Broker 自动创建订阅组，生产建议关闭 |
启动master
2个master
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a.properties -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-b.properties -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
启动slave
2个slave
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a-s.properties -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
nohup sh bin/mqbroker -c conf/2m-2s-async/broker-b-s.properties -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log