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