ROCKET-MQ安装和配置

港控/mmm° 2022-04-10 03:51 410阅读 0赞

## 下载 ##

[w][]get [https://www.apache.org/dyn/closer.cgi?path=incubator/rocketmq/4.1.0-incubating/rocketmq-all-4.1.0-incubating-bin-release.zip][https_www.apache.org_dyn_closer.cgi_path_incubator_rocketmq_4.1.0-incubating_rocketmq-all-4.1.0-incubating-bin-release.zip]

## 安装 ##

1.先安装JDK1.8+

2.解压[rocketmq-all-4.1.0-incubating-bin-release.zip][https_www.apache.org_dyn_closer.cgi_path_incubator_rocketmq_4.1.0-incubating_rocketmq-all-4.1.0-incubating-bin-release.zip]

unzip ./[rocketmq-all-4.1.0-incubating-bin-release][https_www.apache.org_dyn_closer.cgi_path_incubator_rocketmq_4.1.0-incubating_rocketmq-all-4.1.0-incubating-bin-release.zip].zip -d ./

![20181224170659201.png][]

3.重命名文件夹

mv ./rocketmq-all-4.1.0-incubating/ ./rocketmq-4.1.0

## 配置 ##

一.**基础配置**

1.配置JAVA环境变量，在/etc/profile文件的最后 加入如下代码

\#set java environment  
JAVA\_HOME=/opt/jdk8  
JRE\_HOME=/opt/jdk8/jre  
PATH=$PATH:$JAVA\_HOME/bin:$JRE\_HOME/bin  
CLASSPATH=.:$JAVA\_HOME/lib/dt.jar:$JAVA\_HOME/lib/tools.jar:$JRE\_HOME/lib  
export JAVA\_HOME JRE\_HOME PATH CLASSPATH

2.配置rocket-mq环境变量，在/etc/profile文件的最后 加入如下代码

\#set rocket-mq env  
export ROCKETMQ\_HOME=/opt/rocketmq-4.1.0  
export PATH=$PATH:$ROCKETMQ\_HOME/bin

3.执行下面命令使得环境变量生效

source /etc/profile

4.修改rocket-mq内存配置，主要修改./bin/runserver.sh & ./bin/runbroker.sh 运行脚本

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70][]

5.在 /ect/hosts 配置nameserve hosts

![20181224170735640.png][]

**二.ROCKET-MQ配置多master无slave**

1.进入ROCKETMQ\_HOME

![20181224170757943.png][]

2.用mkdir 创建2个目录分别是logs、data

3.进入conf目录

![2018122417081648.png][]

4.修改 ./2m-noslave/broker-a.properties 文件

#所属集群名字
    
    brokerClusterName=ddyunf-mq-cluster
    
    #broker名字，注意此处不同的配置文件填写的不一样
    
    brokerName=broker-a
    
    #0 表示 Master，>0 表示 Slave
    
    brokerId=0
    
    #nameServer地址，分号分割
    
    namesrvAddr=5mq.ddyunf.com: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=/opt/rocketmq-4.1.0/data/store
    
    #commitLog 存储路径
    
    storePathCommitLog=/opt/rocketmq-4.1.0/data/store/commitlog
    
    #消费队列存储路径存储路径
    
    storePathConsumeQueue=/opt/rocketmq-4.1.0/data/store/consumequeue
    
    #消息索引存储路径
    
    storePathIndex=/opt/rocketmq-4.1.0/data/store/index
    
    #checkpoint 文件存储路径
    
    storeCheckpoint=/opt/rocketmq-4.1.0/data/store/checkpoint
    
    #abort 文件存储路径
    
    abortFile=/opt/rocketmq-4.1.0/data/store/abort
    
    
    
    
    
    #限制的消息大小
    
    maxMessageSize=65536
    
    
    
    #flushCommitLogLeastPages=4
    
    #flushConsumeQueueLeastPages=2
    
    #flushCommitLogThoroughInterval=10000
    
    #flushConsumeQueueThoroughInterval=60000
    
    #Broker 的角色
    
    #- ASYNC_MASTER 异步复制Master
    
    #- SYNC_MASTER 同步双写Master
    
    #- SLAVE
    
    brokerRole=ASYNC_MASTER
    
    
    
    #刷盘方式
    
    #- ASYNC_FLUSH 异步刷盘
    
    #- SYNC_FLUSH 同步刷盘
    
    flushDiskType=ASYNC_FLUSH
    
    #checkTransactionMessageEnable=false
    
    #发消息线程池数量
    
    #sendMessageThreadPoolNums=128
    
    #拉消息线程池数量
    
    #pullMessageThreadPoolNums=128

5.启动name-server

noohup sh mqnamesrv &

6.查看 nameservre启动日志

tail -500f ./logs/namesrv.log

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70 1][]

或者 使用jps 命令

jps

![2018122417084589.png][]

7.启动broker

nohup sh mqbroker -c ./conf/2m-noslave/broker-a.properties > /dev/null 2>&1 &

8.查看broker的启动日志

tail -500f ./logs/broker.log

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70 2][]

[w]: http://rocketmq.apache.org/dowloading/releases/
[https_www.apache.org_dyn_closer.cgi_path_incubator_rocketmq_4.1.0-incubating_rocketmq-all-4.1.0-incubating-bin-release.zip]: https://www.apache.org/dyn/closer.cgi?path=incubator/rocketmq/4.1.0-incubating/rocketmq-all-4.1.0-incubating-bin-release.zip
[20181224170659201.png]: /images/20220403/356982e59643480388ee79f817595d35.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70]: /images/20220403/c0eaf90dff634b10a5c4331d4028d4b6.png
[20181224170735640.png]: /images/20220403/11e7df7c656a436d808973ab07973901.png
[20181224170757943.png]: /images/20220403/289b4ab96a214dd48350dcded31f6847.png
[2018122417081648.png]: /images/20220403/678b1228a7eb44eb809371b8696f13cc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70 1]: /images/20220403/ec311e7d19704bcfae0169cc54a05aeb.png
[2018122417084589.png]: /images/20220403/eafe92f2638d4256ba8ed83a28ed7bbd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70 2]: /images/20220403/128d943ad39b4a9681876f1bfe78224c.png