CentOS 7.9 安装 rocketmq-4.9.2

一、CentOS 7.9 安装 rocketmq-4.9.2

地址：

• https://rocketmq.apache.org
  
• https://github.com/apache/rocketmq
  
• https://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip
  

 
二、下载RocketMQ

1. wget https://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip

复制代码

安装解压工具

1. yum install -y unzip zip

复制代码

解压

1. unzip rocketmq-all-4.9.2-bin-release.zip -d /opt/

复制代码

进入文件夹

1. cd /opt/rocketmq-4.9.2

复制代码

 
三、配置环境变量

将rocketmq服务加入环境变量

1. vim /etc/profile
2. export PATH=$PATH:/opt/rocketmq-4.9.2/bin
3. # 使配置文件生效
4. source /etc/profile

复制代码

 
四、按需修改启动内存

1. vim runserver.sh

复制代码

 

1. vim runbroker.sh

复制代码

 

1. vim tools.sh

复制代码

 



五、创建目录

创建日志目录

1. mkdir -p /opt/rocketmq-4.9.2/logs

复制代码

 
六、启动NameServer

1. cd /opt/rocketmq-4.9.2/bin
2. nohup sh mqnamesrv > /opt/rocketmq-4.9.2/logs/mqnamesrv.log 2>&1 &

复制代码

验证是否启动OK：

1. tail -f /opt/rocketmq-4.9.2/logs/mqnamesrv.log
2. # 输出
3. nohup: ignoring input
4. Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
5. Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
6. Java HotSpot(TM) 64-Bit Server VM warning: MaxNewSize (262144k) is equal to or greater than the entire heap (262144k).  A new max generation size of 262080k will be used.
7. The Name Server boot success. serializeType=JSON

复制代码

如果成功启动，能看到类似如下的日志
The Name Server boot success. ...
 
七、启动Broker

1. /opt/rocketmq-4.9.2/bin
2. nohup sh mqbroker -n 127.0.0.1:9876 > /opt/rocketmq-4.9.2/logs/mqbroker.log 2>&1 &

复制代码

验证是否启动OK

1. tail -f /opt/rocketmq-4.9.2/logs/mqbroker.log
2. # 输出
3. nohup: ignoring input
4. The broker[ecs-65685, 192.168.0.98:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876

复制代码

如果启动成功，能看到类似如下的日志：
The broker[itmuchcomdeMacBook-Pro.local, 192.168.43.197:10911] boot success. serializeType=JSON and name server is localhost:9876
 
八、测试

在发送/接收消息之前，需要告诉客户名称服务器的位置。
RocketMQ 提供了多种方法来实现这一点。为了简单起见，使用环境变量NAMESRV_ADDR

1. # 开启两个端口，都执行一下命令
2. export NAMESRV_ADDR=localhost:9876

复制代码

发送消息

1. # Producer 端口一执行
2. sh /opt/rocketmq-4.9.2/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

复制代码

接收消息

1. # Consumer 端口二执行
2. sh /opt/rocketmq-4.9.2/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

复制代码

 
九、安装RocketMQ控制台

1 编译源码方式
前置环境

• 64bit OS, Linux/Unix/Mac is recommended
  
• 64bit JDK 1.8+
  
• Maven 3.2.x
  

2 下载源码

1. https://github.com/apache/rocketmq-dashboard
2. git clone https://github.com/apache/rocketmq-dashboard.git

复制代码

 
3 在启动之前先修改下端口，默认的8080 已占用，一定要先修改端口，在进行编译。

1. vim src/main/resources/application.yml

复制代码

 
4 Maven spring-boot 方式启动

1. mvn spring-boot:run

复制代码

5 或者 使用Maven先build成jar包，再java -jar方式启动

1. mvn clean package -Dmaven.test.skip=true
2. java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar

复制代码

访问控制台：http://IP:8082

 
十、防火墙开启端口

1. # 关闭防火墙
2. systemctl stop firewalld
4. # 开通端口
5. firewall-cmd --zone=public --add-port=8082/tcp --permanent
6. firewall-cmd --zone=public --add-port=9876/tcp --permanent
7. firewall-cmd --zone=public --add-port=10911/tcp --permanent
9. # 配置立即生效
10. firewall-cmd --reload
12. # 重启防火墙生效
13. systemctl restart firewalld

复制代码

 
云主机需配置安全组
在入方向规则，都允许放行

• 8082：RocketMQ 控制台
  
• 9876：nameserver 中的端口
  
• 10911：broker 的端口
  

 




 


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！