Linux中安装RocketMQ

导读:本篇文章讲解 Linux中安装RocketMQ,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com

准备

Linux中安装RocketMQ
安装RocketMQ之前需要JDK1.8的环境支持,配置好Java环境变量。
官网下载Linux压缩包 下载
在这里插入图片描述

搭建RocketMQ

1 )将安装包压缩包移动到Linux中自己的文件夹software
在这里插入图片描述
2 )解压并移动到 /usr/local 目录下
unzip rocketmq-all-4.8.0-bin-release.zip
mv rocketmq-all-4.8.0-bin-release /usr/local

3 ) 将目录切换到 rocketmq-all-4.8.0-bin-release目录下
cd /usr/local/rocketmq-all-4.8.0-bin-release
在这里插入图片描述
4 )创建/data/logs/rocketmqlogs 目录,并修改broker 、namesrv 、 tools 的日志输出位置 为/data/logs/rocketmqlogs ,具体步骤如下

mkdir -p /data/logs/rocketmqlogs

sed -i ‘s#${user.home}/logs/#/data/logs/#g’ conf/logback_broker.xml

sed -i ‘s#${user.home}/logs/#/data/logs/#g’ conf/logback_namesrv.xml

sed -i ‘s#${user.home}/logs/#/data/logs/#g’ conf/logback_tools.xml

5 ) 设置broker分配用JVM大小
vim bin/runbroker.sh

找到如下位置,根据自身电脑配置修改大小
JAVA_OPT=“${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m”
在这里插入图片描述
保存并退出。

6 ) 设置namesrv分配用JVM大小
vim bin/runserver.sh

找到如下位置,根据自身电脑配置修改大小
JAVA_OPT=“${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m”

在这里插入图片描述

保存并退出。

7 ) 设置tools分配用JVM大小
vim bin/tools.sh

找到如下位置,根据自身电脑配置修改大小
JAVA_OPT=“${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m”
在这里插入图片描述

保存并退出。

8 ) 修改broker.conf文件
vim /usr/local/rocketmq-all-4.8.0-bin-release/conf/broker.conf

添加 namesrvAddr 和 brokerIP1 你们自己的外网IP,如果阿里云用户就用自己的阿里云地址
namesrvAddr=120.-.-.-:9876
brokerIP1=120.-.-.-
在这里插入图片描述
保存并退出

9 ) 在/etc/profile文件中配置系统环境变量,就是配置HOME
在这里插入图片描述
使用如下命令让环境变量生效
source /etc/profile

至此RocketMQ环境搭建完成

需要注意如果你是阿里云服务器还要开发对应端口

9876 10911 10909
同时关闭防火墙
systemctl stop firewalld

在这里插入图片描述

测试RocketMQ

官网已为我们准备了测试代码

1 )启动namesrv服务
nohup mqnamesrv >> /data/logs/mqnamesrv.log 2>&1 &

2 ) 启动broker服务
nohup mqbroker -n 120.-.-.-:9876 -c /usr/local/rocketmq-all-4.8.0-bin-release/conf/broker.conf autoCreateTopicEnable=true >> /data/logs/mqbroker.log 2>&1 &

这里通过-n 120.-.-.-:9876 选项将RocketMQ监听的IP和端口分别设置为 120.-.-.- 和 9876 ,/conf/broker.conf 其实是配置文件地址也可以是/conf/2m-2s-sync/broker-a.properties

控制台console: nohup java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar >> /data/logs/mqdashboard.log 2>&1 &

3 )查看namesrv和broker进程是否启动成功
直接 jsp 或者 ps -ef | grep mqnamesrv
在这里插入图片描述
可以看到以及启动成功

4 ) 测试环境RocketMQ

  1. 在命令行指定NAMESRV_ADDR的IP和端口
    export NAMESRV_ADDR=120.-.-.-:9876
    tools.sh org.apache.rocketmq.example.quickstart.Producer
    在这里插入图片描述
    产生消息后执行 tools.sh org.apache.rocketmq.example.quickstart.Consumer 进行消费

测试完毕。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/4802.html

(0)
小半的头像小半

相关推荐

极客之音——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!