Slave:
nohup bin/mqbroker -n '10.49.196.30:9876;10.49.196.31:9876;10.49.196.32:9876' -c $ROCKETMQ_HOME/conf/2m-2s-sync/broker-b-s.properties &
2.4.3、启动 Proxy
在 10.49.196.30、10.49.196.31、10.49.196.32 三台机器上分别启动 Proxy。
nohup bin/mqproxy -n '10.49.196.30:9876;10.49.196.31:9876;10.49.196.32:9876' &
3、Broker 参数说明
参数名 |
默认值 |
说明 |
listenPort |
10911 |
接受客户端连接的监听端口 |
namesrvAddr |
null |
nameServer 地址 |
brokerIP1 |
网卡的 InetAddress |
当前 broker 监听的 IP |
brokerIP2 |
跟 brokerIP1 一样 |
存在主从 broker 时,如果在 broker 主节点上配置了 brokerIP2 属性,broker 从节点会连接主节点配置的 brokerIP2 进行同步 |
brokerName |
null |
broker 的名称 |
brokerClusterName |
DefaultCluster |
本 broker 所属的 Cluser 名称 |
brokerId |
0 |
broker id, 0 表示 master, 其他的正整数表示 slave |
storePathCommitLog |
$HOME/store/commitlog/ |
存储 commit log 的路径 |
storePathConsumerQueue |
$HOME/store/consumequeue/ |
存储 consume queue 的路径 |
mapedFileSizeCommitLog |
1024 * 1024 * 1024(1G) |
commit log 的映射文件大小 |
deleteWhen |
04 |
在每天的什么时间删除已经超过文件保留时间的 commit log |
fileReservedTime |
72 |
以小时计算的文件保留时间 |
brokerRole |
ASYNC_MASTER |
SYNC_MASTER/ASYNC_MASTER/SLAVE |
flushDiskType |
ASYNC_FLUSH |
SYNC_FLUSH/ASYNC_FLUSH SYNC_FLUSH 模式下的 broker 保证在收到确认生产者之前将消息刷盘。ASYNC_FLUSH 模式下的 broker 则利用刷盘一组消息的模式,可以取得更好的性能。 |
4、RocketMQ Dashboard 部署
RocketMQ Dashboard 是 RocketMQ 的管控利器,为用户提供客户端和应用程序的各种事件、性能的统计信息,支持以可视化工具代替 Topic 配置、Broker 管理等命令行操作。
4.1、下载源码并编译
源码地址:apache/rocketmq-dashboard,下载并解压,切换至源码目录 rocketmq-dashboard-master:
mvn clean package -Dmaven.test.skip=true
4.2、运行
RocketMQ Dashboard 默认的端口为 8080,与 Proxy 端口冲突,可以修改其运行端口:
java -Dserver.port=18080 -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar
效果如下:
参考:https://rocketmq.apache.org/zh/docs/deploymentOperations/01deploy