RocketMQ 安装及快速入门

发表于

安装条件

64位操作系统，建议使用 Linux / Unix / Mac

64位JDK 1.8+

Maven 3.2.x

下载和构建

从www.apache.org/dyn/closer.…下载源码版本，执行以下命令来解压源码并构建二进制文件。

1
2
3
4
shell复制代码  > unzip rocketmq-all-4.9.2-source-release.zip
  > cd rocketmq-all-4.9.2/
  > mvn -Prelease-all -DskipTests clean install -U
  > cd distribution/target/rocketmq-4.9.2/rocketmq-4.9.2

1. 启动mqnamesrv

启动命令
1
bash复制代码nohup sh bin/mqnamesrv &

或者加上输出日志

1
bash复制代码nohup sh bin/mqnamesrv  >  ~/logs/rocketmq/logs/namesrv.log &
停止命令
1
bash复制代码nohup sh bin/mqshutdown namesrv

2. 启动broker

修改broker.conf文件

新增一行,填写安装的rocketmq机器的ip地址

1
ini复制代码brokerIP1=XX.XXX.XXX.XXX

注意，下面的ip地址以及端口请填写你安装的rocketmq机器的ip地址及端口。

1
bash复制代码nohup sh bin/mqbroker -c conf/broker.conf  -n xxx.xx.xx.xx:9876 autoCreateTopicEnable=true  >  ~/logs/rocketmqlogs/broker.log &

autoCreateTopicEnable=true 是允许自动创建topic

停止命令

1
bash复制代码nohup sh bin/mqshutdown broker

3. 发送消息

1
2
3
bash复制代码export NAMESRV_ADDR=localhost:9876
​
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

4. 接受消息

1
bash复制代码sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

本文转载自: 掘金

开发者博客 – 和开发相关的 这里全都有

0%