RocketMQ快速入门（翻译）

快速入门

快速入门是一个详细的使用说明，在本机设置RocketMQ消息系统来发送和接收消息。

前提条件

需要安装下面软件：

1,64位系统，推荐Linux/Unix/Mac
2,64位JDK 1.8以上
3, Maven 3.2.x
4,Git

下载和构建发行版

现在执行下面命令解压和构建

> unzip rocketmq-all-4.3.0-source-release.zip
> cd rocketmq-all-4.3.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

启动 Broker

> 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

关闭服务

//先关闭broker
> sh bin/mqshutdown broker

> sh bin/mqshutdown namesrv