添加hosts信息【四台机器】

vim /etc/hosts

192.168.119.130 rocketmq-nameserver1

192.168.119.130 rocketmq-master1

192.168.119.131 rocketmq-nameserver2

192.168.119.131 rocketmq-master2

192.168.119.132 rocketmq-nameserver3

192.168.119.132 rocketmq-master1-slave

192.168.119.133 rocketmq-nameserver4

192.168.119.133 rocketmq-master2-slave

解压/usr/local/software 下的 rocketmq-all-4.4.0-bin-release.zip

unzip rocketmq-all-4.4.0-bin-release.zip

mv rocketmq-all-4.4.0-bin-release ../rocketmq

创建存储路径【四台机器】

mkdir -p /usr/local/rocketmq/store

mkdir -p /usr/local/rocketmq/store/commitlog

mkdir -p /usr/local/rocketmq/store/consumequeue

mkdir -p /usr/local/rocketmq/store/index

mkdir -p /usr/local/rocketmq/logs

当然我这里偷懒了，直接放一起执行，用英文逗号隔开

mkdir -p /usr/local/rocketmq/store;mkdir -p /usr/local/rocketmq/store/commitlog;mkdir -p  /usr/local/rocketmq/store/consumequeue;mkdir -p  /usr/local/rocketmq/store/index;mkdir -p  /usr/local/rocketmq/logs

broker-a.properties、broker-b.properties 配置如下：

#所属集群名字

brokerClusterName=rocketmq-cluster

#broker 名字，注意此处不同的配置文件填写的不一样

brokerName=broker-a

#0 表示 Master，>0 表示 Slave

brokerId=0

#nameServer 地址，分号分割

namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876

#在发送消息时，自动创建服务器不存在的 topic，默认创建的队列数

defaultTopicQueueNums=4

#是否允许 Broker 自动创建 Topic，建议线下开启，线上关闭

autoCreateTopicEnable=false

#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭

autoCreateSubscriptionGroup=true

#Broker 对外服务的监听端口

listenPort=10911

#删除文件时间点，默认凌晨 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

#commitLog 存储路径

storePathCommitLog=/usr/local/rocketmq/store/commitlog

#消费队列存储路径存储路径

storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

#消息索引存储路径

storePathIndex=/usr/local/rocketmq/store/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=SYNC_MASTER

#刷盘方式

#- ASYNC_FLUSH 异步刷盘

#- SYNC_FLUSH 同步刷盘

flushDiskType=ASYNC_FLUSH

#checkTransactionMessageEnable=false

#发消息线程池数量

#sendMessageThreadPoolNums=128

#拉消息线程池数量

#pullMessageThreadPoolNums=128

broker-a-s.properties、broker-b-s.properties 配置如下：

#所属集群名字

brokerClusterName=rocketmq-cluster

#broker 名字，注意此处不同的配置文件填写的不一样，与 Master 通过 brokerName 来配对

brokerName=broker-b

#0 表示 Master，>0 表示 Slave

brokerId=1

#nameServer 地址，分号分割

namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876;rocketmq-nameserver3:9876;rocketmq-nameserver4:9876

#在发送消息时，自动创建服务器不存在的 topic，默认创建的队列数

defaultTopicQueueNums=4

#是否允许 Broker 自动创建 Topic，建议线下开启，线上关闭

autoCreateTopicEnable=true

#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭

autoCreateSubscriptionGroup=true

#Broker 对外服务的监听端口

listenPort=10911

#删除文件时间点，默认凌晨 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

#commitLog 存储路径

storePathCommitLog=/usr/local/rocketmq/store/commitlog

#消费队列存储路径存储路径

storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

#消息索引存储路径

storePathIndex=/usr/local/rocketmq/store/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

将配置好的四个配置文件复制到其他的3台服务器并覆盖

scp broker-a.properties broker-a-s.properties broker-b.properties broker-b-s.properties 192.168.119.131:/usr/local/rocketmq/conf/2m-2s-sync/

如图所示

修改bin下面的runserve.sh和runbroker.sh的jvm内存大小。建议1g或2g

分别启动四台机器的Nameserver

nohup sh bin/mqnamesrv &

分别启动四台机器的broker

192.168.119.130 rocketmq-nameserver1

192.168.119.131 rocketmq-nameserver2

192.168.119.132 rocketmq-master1-slave

192.168.119.133 rocketmq-master2-slave

nohup sh bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-a.properties >/dev/null 2>&1 &

nohup sh bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-b.properties >/dev/null 2>&1 &

nohup sh bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-a-s.properties >/dev/null 2>&1 &

nohup sh bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-b-s.properties >/dev/null 2>&1 &

至此，环境搭建ok

最新文章

  1. 插入排序 － C语言
  2. 【ASP.NET 进阶】定时执行任务实现 (定时读取和修改txt文件数字内容，无刷新显示结果)
  3. [原] Android持续优化 - 提高流畅度
  4. postgresql - mac 启动 关闭 postgresql
  5. cocos2d-x游戏循环与调度
  6. centos install（160112更新）
  7. Java字节转换类实现
  8. git与svn的区别-小结一下
  9. X-Plane飞行模拟器购买安装
  10. 关于 Unchecked cast from Iterator to Iterator String 提示
  11. Django:之CMDB资源系统
  12. 【bird-java】分布式服务间的事件总线EventBus
  13. SpringBoot的自动配置原理
  14. Ueditor注意的地方
  15. 如何在eclipse添加SVN菜单
  16. VC_窗口exe_printf信息
  17. git 命令篇
  18. 2018.4.23 《深入理解Java虚拟机：JVM高级特性与最佳实践》笔记
  19. 20190415 OSX系统安装和配置maven
  20. 【LeetCode】76. Minimum Window Substring

热门文章

  1. java容器之HashMap
  2. python基础数据类型语法
  3. AppScan 10安装使用
  4. Dubbo的反序列化安全问题-Hessian2
  5. Typecho 反序列化漏洞 分析及复现
  6. Java测试开发--Set、Map、List三种集合（四）
  7. 美化CMD
  8. [loj2977]巧克力
  9. vue闪现问题，出现{{xxx}}解决方法
  10. Codeforces 575A - Fibonotci