- # 所属集群名字
- brokerClusterName=rocketmq-cluster
- #broker 名字, 名字可重复, 为了管理, 每个 master 起一个名字, 他的 slave 同他, eg:Amaster 叫 broker-a, 他的 slave 也叫 broker-a
- brokerName=broker-b
- #0 表示 Master,>0 表示 Slave
- brokerId=1
- #nameServer 地址, 分号分割
- namesrvAddr=192.168.229.5:9876;192.168.229.6:9876
- # 在发送消息时, 自动创建服务器不存在的 topic, 默认创建的队列数
- defaultTopicQueueNums=4
- # 是否允许 Broker 自动创建 Topic, 建议线下开启, 线上关闭
- autoCreateTopicEnable=true
- # 是否允许 Broker 自动创建订阅组, 建议线下开启, 线上关闭
- autoCreateSubscriptionGroup=true
- #Broker 对外服务的监听端口,
- listenPort=10920
- # 删除文件时间点, 默认凌晨 4 点
- deleteWhen=04
- # 文件保留时间, 默认 48 小时
- fileReservedTime=120
- #commitLog 每个文件的大小默认 1G
- mapedFileSizeCommitLog=1073741824
- #ConsumeQueue 每个文件默认存 30W 条, 根据业务情况调整
- mapedFileSizeConsumeQueue=300000
- #destroyMapedFileIntervalForcibly=120000
- #redeleteHangedFileInterval=120000
- # 检测物理文件磁盘空间
- diskMaxUsedSpaceRatio=88
- # 存储路径
- storePathRootDir=/usr/local/rocketmq/store/broker-b-s
- #commitLog 存储路径
- storePathCommitLog=/usr/local/rocketmq/store/broker-b-s/commitlog
- # 消费队列存储路径存储路径
- storePathConsumeQueue=/usr/local/rocketmq/store/broker-b-s/consumequeue
- # 消息索引存储路径
- storePathIndex=/usr/local/rocketmq/store/broker-b-s/index
- #checkpoint 文件存储路径
- storeCheckpoint=/usr/local/rocketmq/store/checkpoint
- #abort 文件存储路径
- abortFile=/usr/local/rocketmq/store/abort
- # 限制的消息大小
- maxMessageSize=65536
- #flushCommitLogLeastPages=4
- #flushConsumeQueueLeastPages=2
- #flushCommitLogThoroughInterval=10000
- #flushConsumeQueueThoroughInterval=60000
- #Broker 的角色
- #- ASYNC_MASTER 异步复制 Master
- #- SYNC_MASTER 同步双写 Master
- #- SLAVE
- brokerRole=SLAVE
- # 刷盘方式
- #- ASYNC_FLUSH 异步刷盘
- #- SYNC_FLUSH 同步刷盘
- flushDiskType=ASYNC_FLUSH
- #checkTransactionMessageEnable=false
- # 发消息线程池数量
- #sendMessageThreadPoolNums=128
- # 拉消息线程池数量
- #pullMessageThreadPoolNums=128
4. 配置第二台机器 (192.168.229.6)
本文使用的克隆虚拟机, 可快速获取一个与原机器一样的机器, 因为完全一样, 需要更改下 Mac 地址, 如果使用静态 ip, 改下网关的配置即可, 手动重新搭建一台当然也可以
配置同上步, 更改 ip 和 broker 具体信息即可
5. 启动 nameServer
上述配置文件中指定了 commitLog, 队列, 日志等的存储路径, 创建该文件夹
节点 1 执行:
mkdir -p /usr/local/rocketmq/store/broker-a /usr/local/rocketmq/store/broker-a/nsumequeue /usr/local/rocketmq/store/broker-a/commitlog /usr/local/rocketmq/store/broker-a/index /usr/local/rocketmq/logs /usr/local/rocketmq/store/broker-b-s /usr/local/rocketmq/store/broker-b-s/nsumequeue /usr/local/rocketmq/store/broker-b-s/commitlog /usr/local/rocketmq/store/broker-b-s/index
节点 2 执行:
mkdir -p /usr/local/rocketmq/store/broker-a-s /usr/local/rocketmq/store/broker-a-s/nsumequeue /usr/local/rocketmq/store/broker-a-s/commitlog /usr/local/rocketmq/store/broker-a-s/index /usr/local/rocketmq/logs /usr/local/rocketmq/store/broker-b /usr/local/rocketmq/store/broker-b/nsumequeue /usr/local/rocketmq/store/broker-b/commitlog /usr/local/rocketmq/store/broker-b/index
2. 启动节点 1 的 nameServer(192.168.229.5)
来源: http://www.bubuko.com/infodetail-3025196.html