ToB企服应用市场:ToB评测及商务社交产业平台

标题: CentOS 7.9 安装 rocketmq-4.9.2 [打印本页]
作者: 农民    时间: 2022-10-8 10:58
标题: CentOS 7.9 安装 rocketmq-4.9.2
一、CentOS 7.9 安装 rocketmq-4.9.2

地址：

 
二、下载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 编译源码方式
前置环境
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
复制代码
 
云主机需配置安全组
在入方向规则，都允许放行
 




 


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



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4