快速开始

这个快速开始指南,详细介绍了设置RocketMQ消息系统在你本地机器去发送和接受消息。

必备

下列软件假定安装:

1、64位操作系统,推荐Linux/unix/macos

2、64位JDK1.8+

3、Maven 3.2.x

4、Git

下载构建

点击这里下载4.2.0源代码,你也可以下载二进制版本从这儿

现在运行下列命令,去解压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

results matching ""

    No results matching ""