RocketMQ的安装

安装前环境:

  • Linux/Windows 10
  • JDK8
  • RocketMQ
  • Maven(如果是源码需要编译)

Linux下安装

1.下载RocketMQ

2.解压并编译

1
2
3
4
5
6
## 解压
> unzip rocketmq-all-4.9.0-source-release.zip
> cd rocketmq-all-4.9.0/
## 编译源码
> mvn -Prelease-all -DskipTests clean install -U
> cd distribution/target/rocketmq-4.9.0/rocketmq-4.9.0

3.启动NameServer

1
2
3
> nohup sh bin/mqnamesrv &
> tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...

4.启动broker

1
2
3
> nohup sh bin/mqbroker -n localhost:9876 &
> tail -f ~/logs/rocketmqlogs/broker.log 
The broker[%s, 172.30.30.233:10911] boot success...

5.测试生产/消费消息

1
2
3
4
5
6
7
8
## 定义环境变量 NameServer的地址
> 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...

6.关闭MQ服务

1
2
3
4
5
6
7
> 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

Windows下安装

1.设置以下环境变量

1
2
ROCKETMQ_HOME="D:\rocketmq"
NAMESRV_ADDR="localhost:9876"

2.开启NameServer和Broker

1
2
3
4
## 开启NameServer
.\bin\mqnamesrv.cmd
## 开启Broker(重新开一个命令窗口)
.\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

3.测试生产/消费消息

1
2
.\bin\tools.cmd  org.apache.rocketmq.example.quickstart.Producer
.\bin\tools.cmd  org.apache.rocketmq.example.quickstart.Consumer

4.关闭服务,只需要关闭命令窗口或者ctrl+c