手把手Linux安装RocketMQ教程

手把手Linux安装RocketMQ教程

• 1.下载rocketmq安装包
• 2.创建目录并将压缩包上传至服务器
• 3.配置RocketMQ
• 4.启动RocketMQ
• 5.关闭RocketMQ
• 6.测试RocketMQ
• 7.mqadmin查看服务状态
• 8.配置启动脚本
• • 1.namesrv脚本
  • 2.broker脚本
  • 3.单脚本启动
  • 4.单脚本停止
• 待完善
• • 1.开启自启动配置
  • 2.安装rocketmq-dashboard：

1.下载rocketmq安装包

下载各版本rocketmq安装包: https://archive.apache.org/dist/rocketmq/

2.创建目录并将压缩包上传至服务器

1. 创建多级目录:

mkdir -p /opt/rocketmq

2. 上传压缩包：

rz

3. 解压压缩包：

unzip /data/install/rocketmq-all-4.9.4-bin-release.zip

3.配置RocketMQ

1. 修改runserver.sh启动脚本的内存值，如机器内存较大可适当配置高一点

#xms，xmx，xmn修改为2g
vi rocketmq-all-4.9.4-bin-release/bin/runserver.sh

2. 修改runbroker.sh启动脚本的内存值，如机器内存较大可适当配置高一点
   可选：MaxDirectMemorySize修改为1g：可以使用最大内存大小

#xms，xmx，xmn修改为2g
vi rocketmq-all-4.9.4-bin-release/bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g"

4. JAVA_HOME如果取环境变量配置可不修改，也可手动修改为自己目录
5. 新增broker.conf配置信息
vi rocketmq-all-4.9.4-bin-release/conf/broker.conf
新增如下配置

#生产环境不建议开启自动创建topic，并且在集群使用中可能会出现问题
autoCreateTopicEnable=true
namesrvAddr = localhost:9876
#brokerIP1=外网IP地址 可不配
brokerIP1 = localhost

6. 创建日志目录：

 mkdir -p /data/logs/rocketmq

4.启动RocketMQ

1. 启动namesrv服务

nohup sh /app/rocketmq/rocketmq-all-4.9.4-bin-release/bin/mqnamesrv > /app/rocketmq/logs/rocketmq/nameserver.log &

2. 启动broker服务

nohup sh /app/rocketmq/rocketmq-all-4.9.4-bin-release/bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true > /app/rocketmq/logs/rocketmq/broker.log & 

3. 执行jps，或者ps命令 正常应该能看到NamesrvStaup 和 BrokerStartup进程
4. 如启动未开启自动创建topic需手动创建

sh  bin/mqadmin updateTopic -n localhost:9876  -c DefaultCluster  -t  topic1
sh  bin/mqadmin updateTopic -n localhost:9876  -c DefaultCluster  -t  topic2

5.关闭RocketMQ

1. 关闭namesrv服务

/app/rocketmq/rocketmq-all-4.9.4-bin-release/bin/mqshutdown namesrv

2. 关闭broker服务

/app/rocketmq/rocketmq-all-4.9.4-bin-release/bin/mqshutdown broker 

6.测试RocketMQ

1. 修改 bin/tools.sh 文件，设置环境变量：export NAMESRV_ADDR=localhost:9876
2. 发送：./tools.sh org.apache.rocketmq.example.quickstart.Producer
3. 消费：./tools.sh org.apache.rocketmq.example.quickstart.Consumer

7.mqadmin查看服务状态

• 查看集群基本信息
  sh mqadmin clusterList -n localhost:9876
• 查看消费者组的详细信息：
  sh mqadmin consumerProgress -n localhost:9876 -g YourConsumerGroup
• 查看特定主题的消息队列数量：
  sh mqadmin queueInfo -n localhost:9876 -t YourTopic
• 查看集群的Broker状态：
  sh mqadmin brokerStatus -n localhost:9876 -b 127.0.0.1:10911
• 查看所有消费者的详细信息：
  sh mqadmin csm -n localhost:9876
• 查看所有生产者的详细信息：
  sh mqadmin prt -n localhost:9876
• 查看特定主题的消息队列详细信息：
  sh mqadmin mqInfo -n localhost:9876 -t YourTopic
• 查看所有topic :
  sh mqadmin topicList -n 192.168.1.23:9876
• topic路由信息:　
  sh mqadmin topicRoute –n 192.168.208.190:9876 –t test111

8.配置启动脚本

1.namesrv脚本

vim startSrv

#写入如下内容：
nohup sh ./bin/mqnamesrv  >  ./logs/rocketmq/namesrv.log  & tail  -f  ./logs/rocketmq/namesrv.log

启动nameServer: sh startSrv

2.broker脚本

vim startBroker

#写入如下内容：
nohup sh bin/mqbroker -n  localhost:9876  >  ./logs/rocketmqlogs/broker.log   & tail  -f  ./logs/rocketmqlogs/broker.log

启动broke: sh startBroker

3.单脚本启动

vim mqStart

#!/bin/sh
export JAVA_HOME=/opt/java/jdk1.8.0_131/

nohup sh /opt/rocketmq-4.3.2/bin/mqnamesrv > /opt/rocketmq-4.3.2/logs/rocketmqlogs/namesrv.log  2>&1 &

echo "Start Name Server End"

nohup sh /opt/rocketmq-4.3.2/bin/mqbroker -n localhost:9876 > /opt/rocketmq-4.3.2/logs/rocketmqlogs/broker.log  2>&1  &

echo "Start  Broker End"

4.单脚本停止

vim mqStop

#!/bin/sh
sh /opt/rocketmq-4.3.2/bin/mqshutdown broker &
sh /opt/rocketmq-4.3.2/bin/mqshutdown namesrv
echo "Please wait process to exit! check it type jps"

待完善

1.开启自启动配置

1.将namesrv服务将给systemctl控制
2.将broker服务将给systemctl控制
3.使用systemctl 方式启动测试

2.安装rocketmq-dashboard：

有运维页面，驾驶舱，集群页面，主题页面，消费者页面，生产者页面，发布管理页面，消息查询页面等，为开发和运维提供了强大的监控功能