栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

RocketMQ源码编译安装

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

RocketMQ源码编译安装

安装平台为需要Linux、Unix或Mac,Windows不兼容。

下载安装包:rocketmq-all-4.4.0-source-release.zip

要安装JDK和maven环境

进行解压编译:

unzip rocketmq-all-4.4.0-source-release.zip
cd rocketmq-all-4.4.0/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq

进入路径:

/distribution/target/apache-rocketmq

 启动nameServer:

[root@192 apache-rocketmq]# nohup bin/mqnamesrv &

启动成功日志:

[root@192 apache-rocketmq]# tail -100f nohup.out
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
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON

启动broker:

nohup sh bin/mqbroker -n localhost:9876 &

如果报堆内存不足,则需要修改runbroker.sh(默认配置的堆内存8g,根据机器配置修改)

#===========================================================================================
# JVM Configuration
#===========================================================================================
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"

修改后:

#===========================================================================================
# JVM Configuration
#===========================================================================================
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"

再次运行

nohup sh bin/mqbroker -n localhost:9876 &

-n 指定nameServer地址,它的默认端口是9876

broker启动后默认端口是10911

查看进程

[root@192 bin]# jps -l
90651 org.apache.rocketmq.namesrv.NamesrvStartup
91898 sun.tools.jps.Jps
91774 org.apache.rocketmq.broker.BrokerStartup

nameServer和broker启动成功。

发送消息测试:

设置nameServer地址变量

[root@192 bin]# export NAMESRV_ADDR=localhost:9876

发送消息测试:

[root@192 apache-rocketmq]#  bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

发送消息成功

消费消息测试:

 bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

关闭RocketMQ,先关broker再关nameServer

[root@192 apache-rocketmq]# ./bin/mqshutdown broker
[root@192 apache-rocketmq]# ./bin/mqshutdown namesrv

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/458942.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号