|
| 1 | +# RocketMQ 安装部署 |
| 2 | + |
| 3 | +<!-- TOC depthFrom:2 depthTo:3 --> |
| 4 | + |
| 5 | +- [环境要求](#环境要求) |
| 6 | +- [下载解压](#下载解压) |
| 7 | +- [启动 Name Server](#启动-name-server) |
| 8 | +- [启动 Broker](#启动-broker) |
| 9 | +- [收发消息](#收发消息) |
| 10 | +- [关闭服务器](#关闭服务器) |
| 11 | + |
| 12 | +<!-- /TOC --> |
| 13 | + |
| 14 | +## 环境要求 |
| 15 | + |
| 16 | +- 推荐 64 位操作系统:Linux/Unix/Mac |
| 17 | +- 64bit JDK 1.8+ |
| 18 | +- Maven 3.2.x |
| 19 | +- Git |
| 20 | + |
| 21 | +## 下载解压 |
| 22 | + |
| 23 | +进入官方下载地址:http://rocketmq.apache.org/release_notes/release-notes-4.2.0/ |
| 24 | + |
| 25 | +建议选择 binary 版本。 |
| 26 | + |
| 27 | +解压到本地: |
| 28 | + |
| 29 | +```sh |
| 30 | +> unzip rocketmq-all-4.2.0-source-release.zip |
| 31 | +> cd rocketmq-all-4.2.0/ |
| 32 | +``` |
| 33 | + |
| 34 | +## 启动 Name Server |
| 35 | + |
| 36 | +```sh |
| 37 | +> nohup sh bin/mqnamesrv & |
| 38 | +> tail -f ~/logs/rocketmqlogs/namesrv.log |
| 39 | +The Name Server boot success... |
| 40 | +``` |
| 41 | + |
| 42 | +## 启动 Broker |
| 43 | + |
| 44 | +```sh |
| 45 | +> nohup sh bin/mqbroker -n localhost:9876 & |
| 46 | +> tail -f ~/logs/rocketmqlogs/broker.log |
| 47 | +The broker[%s, 172.30.30.233:10911] boot success... |
| 48 | +``` |
| 49 | + |
| 50 | +## 收发消息 |
| 51 | + |
| 52 | +执行收发消息操作之前,不许告诉客户端命名服务器的位置。在 RocketMQ 中有多种方法来实现这个目的。这里,我们使用最简单的方法——设置环境变量 `NAMESRV_ADDR` : |
| 53 | + |
| 54 | +```sh |
| 55 | +> export NAMESRV_ADDR=localhost:9876 |
| 56 | +> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer |
| 57 | +SendResult [sendStatus=SEND_OK, msgId= ... |
| 58 | + |
| 59 | +> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer |
| 60 | +ConsumeMessageThread_%d Receive New Messages: [MessageExt... |
| 61 | +``` |
| 62 | +
|
| 63 | +## 关闭服务器 |
| 64 | +
|
| 65 | +```sh |
| 66 | +> sh bin/mqshutdown broker |
| 67 | +The mqbroker(36695) is running... |
| 68 | +Send shutdown request to mqbroker(36695) OK |
| 69 | + |
| 70 | +> sh bin/mqshutdown namesrv |
| 71 | +The mqnamesrv(36664) is running... |
| 72 | +Send shutdown request to mqnamesrv(36664) OK |
| 73 | +``` |
0 commit comments