Preface
快速入门
系统要求
- 64bit OS, 官方建议Linux/Unix/Mac
- JDK 1.8+
- Maven 3.2.x
- Git
- Broker服务需要 4g+ 的磁盘空间
下载与安装
当前版本源码下载
发行版下载
解压
1
2
3
4
| > unzip rocketmq-all-4.4.0-source-release.zip
> cd rocketmq-all-4.4.0/
> mvn -Prelease-all -DskipTests clean install -U
> cd distribution/target/apache-rocketmq
|
Maven的安装
从官方下载 Maven的binary ，直接解压。
将解压缩出来的 /bin 目录添加到 ~/.bash_profile ，然后 source ~/.bash_profile 之后就可以使用 mvn 指令了。
启动Name Server
1
2
3
| > nohup sh bin/mqnamesrv &
> tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...
|
启动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...
|
发送和接受消息
首先，得告诉终端 name server得地址。RocketMQ提供了很多方法来获取这个。最简单的是通过环境变量 NAMESRV_ADDR ：
1
2
3
4
5
6
| > 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...
|
关闭服务
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
|
Golang的RocketMQ-client
rocketmq-client-go 这个是目前github上最多star的项目 。
根据 文档 描述，他应该是需要依赖rocketmq-client-cpp 的。