首页 > 其他分享 >2020 RocketMQ安装

2020 RocketMQ安装

时间：2022-12-29 16:33:30浏览次数：40  
标签：RocketMQ bin data local 2020 rocketmq 安装 store usr


1、安装-目录规划

cd /opt
# 上传RocketMQ二进制压缩包，到/opt目录下 或者直接wget下载
wget https://downloads.apache.org/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip 
# 验证下载是否正确
gpg --print-md SHA512 rocketmq-all-4.7.1-bin-release.zip

yum install -y unzip
unzip rocketmq-all-4.7.1-bin-release.zip
# 为了替换版本方便，创建软链
ln -s /opt/rocketmq-all-4.7.1-bin-release /usr/local/rocketmq

2、启动&停止NameServer、Broker

先启动NameServer，然后启动Broker，并向 NameServer 注册自己

################### NameServer ###################
# 启动之前根据本机内存大小，看看是否需要修改 JAVA_OPT 的内存设置
cd /usr/local/rocketmq/bin
sed -i 's/-Xms4g -Xmx4g -Xmn2g/-Xms1g -Xmx1g -Xmn512m/g' ./runserver.sh
# 启动 NameServer
nohup sh /usr/local/rocketmq/bin/mqnamesrv &
# 查看 NameServer启动日志
tail ‐f ~/logs/rocketmqlogs/namesrv.log
# 关闭 NameServer

sh /usr/local/rocketmq/bin/mqshutdown namesrv

################### Broker ###################
# 启动之前根据本机内存大小，看看是否需要修改 JAVA_OPT 的内存设置
cd /usr/local/rocketmq/bin
sed -i 's/-Xms8g -Xmx8g -Xmn4g/-Xms1g -Xmx1g -Xmn512m/g' ./runbroker.sh

# 启动 Broker
nohup sh /usr/local/rocketmq/bin/mqbroker ‐n localhost:9876 &
# 我的测试版本4.7.1，需要加上autoCreateTopicEnable=true 参数
# 否则在测试发送消息的时候会报异常
nohup sh /usr/local/rocketmq/bin/mqbroker ‐n localhost:9876 autoCreateTopicEnable=true &

# 查看 Broker 启动日志
tail -f ~/logs/rocketmqlogs/broker.log

### 2.关闭Broker
sh /usr/local/rocketmq/bin/mqshutdown broker

3、验证

查看JAVA进程，是否存在NamesrvStartup、BrokerStartup， 如果没有则查看LOG日志查找问题。

[root@RocketMQ02 local]# jps
2612 Jps
2503 BrokerStartup
2456 NamesrvStartup

发送和接收消息测试

# 设置临时环境变量
export NAMESRV_ADDR=localhost:9876
sh /usr/local/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

二、集群配置&启动

实验环境：准备两台虚拟机 131/132

2020 RocketMQ安装_线程池

1、修改 hosts

vim /etc/hosts
192.168.211.131 rocketmq-n1
192.168.211.132 rocketmq-n2
systemctl restart network

2、配置文件broker-a.properties

<<broker-a.properties>>

brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=rocketmq-n1:9876;rocketmq-n2: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=/data/rocketmq/store
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq/store/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/store/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/store/checkpoint
#abort 文件存储路径
abortFile=/data/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=SYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

3、配置文件broker-b-s.properties

<<broker-b-s.properties>>

brokerClusterName=rocketmq-cluster
brokerName=broker-b
brokerId=1
namesrvAddr=rocketmq-n1:9876;rocketmq-n2:9876
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
listenPort=11011
deleteWhen=04
fileReservedTime=120
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000
diskMaxUsedSpaceRatio=88
storePathRootDir=/data/rocketmq/store-s
storePathCommitLog=/data/rocketmq/store-s/commitlog
storePathConsumeQueue=/data/rocketmq/store-s/consumequeue
storePathIndex=/data/rocketmq/store-s/index
storeCheckpoint=/data/rocketmq/store-s/checkpoint
abortFile=/data/rocketmq/store-s/abort
maxMessageSize=65536
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH

4、配置文件broker-b.properties

<<broker-b.properties>>

brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=rocketmq-n1:9876;rocketmq-n2: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=/data/rocketmq/store
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq/store/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/store/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/store/checkpoint
#abort 文件存储路径
abortFile=/data/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=SYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

5、配置文件broker-a-s.properties

<<broker-a-s.properties>>

brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=1
#nameServer地址，分号分割
namesrvAddr=rocketmq-n1:9876;rocketmq-n2:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=11011
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/data/rocketmq/store-s
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/store-s/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq/store-s/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/store-s/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/store-s/checkpoint
#abort 文件存储路径

abortFile=/data/rocketmq/store-s/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

6、启动集群

# 关闭
mkdir /data/rocketmq/store -p
mkdir /data/rocketmq/store/commitlog -p
mkdir /data/rocketmq/store/consumequeue -p
mkdir /data/rocketmq/store/index -p

mkdir /data/rocketmq/store-s -p
mkdir /data/rocketmq/store-s/commitlog -p
mkdir /data/rocketmq/store-s/consumequeue -p
mkdir /data/rocketmq/store-s/index -p

cd /usr/local/rocketmq/conf/2m-2s-sync
sh /usr/local/rocketmq/bin/mqshutdown broker
sh /usr/local/rocketmq/bin/mqshutdown namesrv

nohup /usr/local/rocketmq/bin/mqnamesrv &   # 启动NameServer

nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-a.properties &
nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-b-s.properties & 

nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-a-s.properties &
nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-b.properties &

tail -f ~/logs/rocketmqlogs/broker.log


bash /usr/local/rocketmq/bin/mqadmin clusterlist -n 192.168.211.131:9876;192.168.211.132:9876
bash /usr/local/rocketmq/bin/mqadmin clusterlist -n rocketmq-n1:9876;rocketmq-n2:9876


标签：RocketMQ,bin,data,local,2020,rocketmq,安装,store,usr
From： https://blog.51cto.com/u_14724733/5978355

相关文章

  • docker compose安装与使用
    简介之前使用docker时，写完一个项目之后需要定义一个dockerfile，再通过dockerbuild生成一个镜像，并通过dockerrun执行；都是通过手动操作，用于单个容器，非常麻烦，现在想要的效......
  • ubuntu安装docker
    1.先卸载旧版，如果没有的话，就不用执行了，直接第二步。apt-getremovedockerdocker-enginedocker.iocontainerdrunc2.在终端输入aptupdateapt-getinstallca-certifi......
  • 1.Django安装和运行
    一、安装DjangoDjango框架是用Python语言开发的，只需要执行命令pipinstalldjango验证：python-mdjango--version>4.1.4切换到项目文件下，执行命令djang......
  • IDEA中给源码添加自己注释——private-notes插件安装使用
    一、前言我们在空闲之余喜欢研究一些经典框架的源码，发现没办法把自己的注释添加上。会给出提示：Fileisread-only很烦，但是为了安全考虑也是没有办法的！这是一个大佬就写......
  • Mac——Mac 安装apt-get
    MAC系统版本：10.13和Linux系统不同的是，Mac系统默认是不带有apt-get软件包工具的，所以要想在Mac上使用上方便的apt-get就需要自己来安装它。一、安装fink使用apt-get首先......
  • 安装virtualbox及ubuntu
    https://www.virtualbox.org/wiki/Downloads https://releases.ubuntu.com/bionic/下载一个iso然后按步骤安装。  最后修改网络模式  如果使用xshell，需要......
  • Python 安装pythoncom库和pyHook
    首先这个用pipinstall安装很麻烦，所以找了一点资料--https://sourceforge.net/projects/pywin32/files/pywin32/ 这里面下载pythoncom安装包直接安装https://www.lfd.u......
  • 随笔（十三）『docker安装redis』
    1、进入虚拟机vagrantssh2、切换为rootsuroot3、拉取redis镜像dockerpullredis4、创建实体并启动4.1）mkdir-p/mydata/redis/conf4.2）touch/mydata/redis......
  • Maven外部包的安装
    C:\software\apache-maven-3.6.2\bin>mvninstall:install-file-DgroupId=com.dm-DartifactId=DmJdbcDriver-Dversion=1.8-Dpackaging=jar-Dfile=C:\zhbwork\DMsoft\d......
  • Mac——Mac命令行安装brew工具，然后就可以用brew安装其他软件或者安装包
    1、安装brew:curl -LsSf http://github.com/mxcl/homebrew/tarball/master | sudo tar xvz -C/usr/local --strip 1或者ruby-e"$(curl-fsSLhttps://raw.gi......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99