快速开始
这个快速开始指南,详细介绍了设置RocketMQ消息系统在你本地机器去发送和接受消息。
必备
下列软件假定安装:
1、64位操作系统,推荐Linux/unix/macos
2、64位JDK1.8+
3、Maven 3.2.x
4、Git
下载构建
现在运行下列命令,去解压4.2.0源码,和构建二进制。
unzip rocketmq-all-4.2.0-source-release.zip
cd rocketmq-all-4.2.0/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq
启动name server
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
启动代理
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
发送和接受消息
在发送和接受消息之前,我们必须告诉客户端name server的位置。RocketMQ提供多种方式获得,简单的办法就是使用环境变量NAMESRV_ADDR
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
关闭服务
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv