1.首先打开Rocketmq官网)

官网地址: rocketmq

截图
官网提供了两种下载方式, Source下载是未编译(需要自行编译)Binary 下载是已经编译好的。我选择的是已经编译好的(省事)。

liux安装

这里我使用的是centos7
先将下载下来的包传入liux上,上传的话可以使用(xftp,宝塔等)一系列的工具。将压缩包上传上去后可以使用

unzip rocketmq-all-5.1.4-bin-release

解压完之后进入bin 中
在这里插入图片描述
这里是个坑要注意 打开 runbroker.sh

vi runbroker.sh

在这里插入图片描述
这里将8g改为512m
在这里插入图片描述
改完之后

:wq  //退出编辑

然后在打开 runserver.sh
在这里插入图片描述
这里它是根据你liux 系统中的Java 版本来选择使用哪一种配置,这里我是都改了,因为我虚拟机还没能大的内存
在这里插入图片描述
改完保存完之后。接着看官方文档

在这里插入图片描述

//启动NameServer
nohup sh bin/mqnamesrv &
//验证namesrv是否启动成功
tail -f ~/logs/rocketmqlogs/namesrv.log

在这里插入图片描述
这里就算NameServer启动成功了
继续看文档
在这里插入图片描述

// 先启动broker
nohup sh bin/mqbroker -n localhost:9876 --enable-proxy &
// 验证broker是否启动成功, 比如, broker的ip是192.168.1.2 然后名字是broker-a
tail -f ~/logs/rocketmqlogs/proxy.log 

在这里插入图片描述
到这里就算启动成功了
在这里插入图片描述
接着测试

export NAMESRV_ADDR=localhost:9876
 sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
 SendResult [sendStatus=SEND_OK, msgId= ...

在这里插入图片描述
这样就算是发送成功了

// An highlighted block
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
 ConsumeMessageThread_%d Receive New Messages: [MessageExt...

在这里插入图片描述
这样相当于收到成功
接着测试下一项,这里是个大坑。接着往下看
在这里插入图片描述
打开你的项目引入maven依赖
这里我引入是
在这里插入图片描述
引入后 回到liux 通过mqadmin创建 Topic

sh bin/mqadmin updatetopic -n localhost:9876 -t TestTopic -c DefaultCluster

执行完成后 将官网上的实例拿下来放到代码里
在这里插入图片描述
这里就会出现

在这里插入图片描述
找不到包。这里我找了很多资料。(官方有点懒)
引入
在这里插入图片描述
将版本回退到5.0.5,这时候测试用例就不爆红了
在这里插入图片描述
然后启动在这里插入图片描述
成功发送
在这里插入图片描述
成功消费
至此liux部署Rocketmq5.1.4 就算完成了。最后如果起不来请查看自己的Java 环境。
在这里插入图片描述
没有jdk 环境的清参考
链接: linux安装jdk8
如果有疑问,可在下方评论。主打一个解决问题。

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐