rocketMQ(一)基础环境

一、安装：

启动

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 发送并接收消息了，使用消息队列

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