RocketMQ安装及快速入门

发表于 | 分类于

安装条件

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

64位JDK 1.8+

Maven 3.2.x

下载和构建

从https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.2/rocketmq-all-4.9.2-source-release.zip下载源码版本，执行以下命令来解压源码并构建二进制文件。

1
2
3
4
  > 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
nohup sh bin/mqnamesrv &

或者加上输出日志

1
nohup sh bin/mqnamesrv  >  ~/logs/rocketmq/logs/namesrv.log &
停止命令
1
nohup sh bin/mqshutdown namesrv

2. 启动broker

修改broker.conf文件

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

1
brokerIP1=XX.XXX.XXX.XXX

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

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

autoCreateTopicEnable=true 是允许自动创建topic

停止命令

1
nohup sh bin/mqshutdown broker

3. 发送消息

1
2
3
export NAMESRV_ADDR=localhost:9876

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

4. 接受消息

1
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer