1、下载
下载地址：http://rocketmq.apache.org/release_notes/
执行命令：wget http://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.6.0/rocketmq-all-4.6.0-bin-release.zip
unzip rocketmq-all-4.6.0-bin-release.zip
下载完解压可用
带source字样的需要自己下载maven编译。
二、配置
1、配置文件解析
# Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You under the Apache License, Version 2.0 # (the "License"); you may not use this file except in compliance with # the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. #brokerClusterName=DefaultCluster #brokerName=broker-a #brokerId=0 #deleteWhen=04 #fileReservedTime=48 #brokerRole=ASYNC_MASTER #flushDiskType=ASYNC_FLUSH #所属集群名字 brokerClusterName=rocketmq-cluster #broker名字，注意此处不同的配置文件填写的不一样 brokerName=broker-a #0 表示 Master，>0 表示 Slave brokerId=0 #nameServer地址，分号分割 namesrvAddr=nameserver1:9876;nameserver2:9876 #在发送消息时，自动创建服务器不存在的topic，默认创建的队列数 defaultTopicQueueNums=4 #是否允许 Broker 自动创建Topic，建议线下开启，线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 listenPort=10911 haListenPort=10912 #删除文件时间点，默认凌晨 4点 deleteWhen=04 #文件保留时间，默认 48 小时 fileReservedTime=18 #commitLog每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 #ConsumeQueue每个文件默认存30W条，根据业务情况调整 mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000 #redeleteHangedFileInterval=120000 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/home/rocketMQ/ZHF/rocketMQ-2m2s/store #commitLog 存储路径 storePathCommitLog=/home/rocketMQ/ZHF/rocketMQ-2m2s/store/commitlog #消费队列存储路径存储路径 storePathConsumeQueue=/home/rocketMQ/ZHF/rocketMQ-2m2s/store/consumequeue #消息索引存储路径 storePathIndex=/home/rocketMQ/ZHF/rocketMQ-2m2s/store/index #checkpoint 文件存储路径 storeCheckpoint=/home/rocketMQ/ZHF/rocketMQ-2m2s/store/checkpoint #abort 文件存储路径 abortFile=/home/rocketMQ/ZHF/rocketMQ-2m2s/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 #强制指定本机IP，需要根据每台机器进行修改。官方介绍可为空，系统默认自动识别，但多网卡时IP地址可能读取错误 brokerIP1=192.168.162.235
三、部署
1、计划
服务器三台(每台服务器启动两个broker实例)：
192.168.244.128 nameServer1 broker1-master broker3-slave 192.168.244.130 nameServer2 broker2-master broker1-slave 192.168.244.131 nameServer3 broker3-master broker2-slave2、创建目录如下
/zjl/program/rocketmq/store/store-m /zjl/program/rocketmq/store/store-m/commitlog /zjl/program/rocketmq/store/store-m/consumerqueue /zjl/program/rocketmq/store/store-m/index/zjl/program/rocketmq/store/store-s /zjl/program/rocketmq/store/store-s/commitlog /zjl/program/rocketmq/store/store-s/consumerqueue /zjl/program/rocketmq/store/store-s/index3、Broker配置文件
1）192.168.244.128 broker1-master.conf
View CodebrokerClusterName = DefaultCluster brokerName = broker1 brokerId = 0 namesrvAddr = 192.168.244.128:9876;192.168.244.130:9876;192.168.244.131:9876 defaultTopicQueueNums = 4 autoCreateTopicEnable = false autoCreateSubscriptionGroup = false listenPort = 10911 haListenPort = 10912 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH diskMaxUsedSpaceRatio = 88 storePathRootDir = /zjl/program/rocketmq/store/store-m storePathCommitLog = /zjl/program/rocketmq/store/store-m/commitlog storePathConsumeQueue = /zjl/program/rocketmq/store/store-m/consumerqueue storePathIndex = /zjl/program/rocketmq/store/store-m/index storeCheckpoint = /zjl/program/rocketmq/store/store-m/checkpoint abortFile = /zjl/program/rocketmq/store/store-m/abort maxMessageSize = 65536 brokerIP1 = 192.168.244.128