准备
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
- 在命令行指定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