rocketMQ(一)基础环境

我会带着你远行 2023-08-17 16:05 80阅读 0赞

一、安装：

[http://rocketmq.apache.org/dowloading/releases/][http_rocketmq.apache.org_dowloading_releases]

[https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip][https_www.apache.org_dyn_closer.cgi_path_rocketmq_4.5.1_rocketmq-all-4.5.1-bin-release.zip]

启动

1.3.2 启动消患队列服务

启动单机的消息队列服务比较简单，不需要写配置文件，只需要依次启动

本机的NameServer 和B roker 即可。

启动NameServer:

> nohup sh bin/mqnamesrv &

> tail \- f ~/Logs / rocketmqLogs / namesrv . Log

The Name Server boot success . ..

启动B roker :

> nohup sh bin/mqbroker n localhost : 9876&

> tail \-f ~/ Logs/rocketmqLogs/broker . Log

The broker\[%s, 192.168.0.233 : 10911\] boot success .. .

1.3.3 用命令行发送和接收消息

为了快速展示发送和接收消息，本节展示的是用命令行发送和接收消息，

实际上就是运行写好的demo 程序，后续我们可以参考这些demo 来写自己的发

送和接收程序。

运行示例程序，发送和接收消息：

>export NAMESRV ADDR=localhost : 9876

> sh bin/tools . sh org .apache .roc ketmq.example . quickstart.Producer

SendResult \[sendStatus=SEND OK, msgid=

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

ConsumeMessageThread 主d Receive New Messages : \[MessageExt . ..

1.3.4 关闭消息队列

消息队列被启动后，如果不主动关闭， 则会一直在后台运行，占用系统资

源。我们有专门用来关闭NameServ er 和Broker 的命令。

关闭NameServer 和Broker:

> sh bin/mqshutdown broker

The mqbroker (36695) i s running ...

Send shutdown request to mqbroker (36695 ) OK

> sh bin/mqshutdown namesrv

The mqnames r v (36664 ) is runn 工口g ...

Send shutdown request t o mqnamesrv (36664) OK

恭喜，现在你已经能够使用RocketMQ 发送并接收消息了，使用消息队列

的基本功能就是这么简单。

相关资料

Mac下查看已安装的jdk版本及其安装目录：

[https://blog.csdn.net/caoxiaohong1005/article/details/73611424/][https_blog.csdn.net_caoxiaohong1005_article_details_73611424]

在Mac中如何正确地设置JAVA\_HOME

[https://blog.csdn.net/a158123/article/details/79684499][https_blog.csdn.net_a158123_article_details_79684499]

rocketmq4.2.0 - 服务安装， web管理界面安装

[https://blog.csdn.net/changerzhuo\_319/article/details/81513821][https_blog.csdn.net_changerzhuo_319_article_details_81513821]

转载于:https://www.cnblogs.com/zhimingxin/p/11217370.html

[http_rocketmq.apache.org_dowloading_releases]: http://rocketmq.apache.org/dowloading/releases/
[https_www.apache.org_dyn_closer.cgi_path_rocketmq_4.5.1_rocketmq-all-4.5.1-bin-release.zip]: https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip
[https_blog.csdn.net_caoxiaohong1005_article_details_73611424]: https://blog.csdn.net/caoxiaohong1005/article/details/73611424/
[https_blog.csdn.net_a158123_article_details_79684499]: https://blog.csdn.net/a158123/article/details/79684499
[https_blog.csdn.net_changerzhuo_319_article_details_81513821]: https://blog.csdn.net/changerzhuo_319/article/details/81513821