Apache 官网: http://rocketmq.apache.org/

RocketMQ 的 Github 地址:

• English：https://github.com/apache/rocketmq/tree/master/docs/en

• 中文：https://github.com/apache/rocketmq/tree/master/docs/cn

下载源文件

点击 此处 下载 4.7.1 版本的源文件,你也可以在 这里 直接下载二进制文件

解压并构建二进制文件

先说一下,需要以下环境:

• 64bit OS, Linux/Unix/Mac
• 64bit JDK 1.8+
• Maven 3.2.x
• Git
• 4G 及以上内存用于 Broker server

解压下载的源文件

unzip rocketmq-all-4.7.1-source-release.zip

进入解压的目录

cd rocketmq-all-4.7.1-source-release

构建安装

mvn -Prelease-all -DskipTests clean install -U

提醒一下:
默认的 maven 源下载 jar 包很慢,看我 这篇文章 一分钟搞定

启动服务

进入工作目录

cd distribution/target/rocketmq-4.7.1/rocketmq-4.7.1

启动 Name Server

nohup sh bin/mqnamesrv &

可以查看日志文件

tail -f ~/logs/rocketmqlogs/namesrv.log

namesrv

启动 Broker server

nohup sh bin/mqbroker -n localhost:9876 &

查看日志

tail -f ~/logs/rocketmqlogs/broker.log

brokersrv

启动 Broker server 很可能出错, 具体解决办法 .

查看启动的服务

在日志文件夹下输入 jps 即可

checksrv

发送/接收消息

在发送/接收消息之前，我们需要告诉客户端名称服务器的位置。RocketMQ 提供了多种方法来实现这一目标。为简单起见，我们使用环境变量

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

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

关掉 Server

> sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK

> sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK

The_End