liux部署Rocketmq5.1.4
官网提供了两种下载方式, Source下载是未编译(需要自行编译)Binary 下载是已经编译好的。我选择的是已经编译好的(省事)。这里它是根据你liux 系统中的Java 版本来选择使用哪一种配置,这里我是都改了,因为我虚拟机还没能大的内存。先将下载下来的包传入liux上,上传的话可以使用(xftp,宝塔等)一系列的工具。至此liux部署Rocketmq5.1.4 就算完成了。这里我找了很多资料
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
如果有疑问,可在下方评论。主打一个解决问题。
更多推荐
所有评论(0)