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 的。