RocketMQ 安装

安装命令

git clone -b develop https://github.com/apache/incubator-rocketmq.git
cd incubator-rocketmq
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq  -- apache-rocketmq这个目录可能有出入，进入到你下载的目录下面

broker启动时，默认要获取8G内存，如果服务器内存不够，将启动失败。

需要修改三个文件,target目录下.

目的是修改mq使用内存大小，按照你实例的情况进行修改

runbroker.sh -- 启动broker需要

runserver.sh -- 启动namesrv需要

tool.sh - 使用example的例子的时候 用到

JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn521m"

设置rocketmq的环境变量

echo "ROCKETMQ_HOME=`pwd`" >> ~/.bash_profile
source ~/.bash_profile 

结果 (/root文件夹下用 ls -al命令查看)

PATH=$PATH:$HOME/bin
export PATH
ROCKETMQ_HOME=/usr/local/rockemq-source/RocketMQ-3.5.8/devenv  -- 参考，是你编译好的目录 target

启动

## 进入到distribution/target/apache-rocketmq/.../bin 目录下

## 启动navme server
nohup sh mqnamesrv &
tail -f tail -f nohup.out -- 查看是否启动成功
The Name Server boot success...

## 启动broker
nohup sh nohup sh mqbroker -n 127.0.0.1:9876 & 
tail -f tail -f nohup.out -- 查看是否启动成功
The broker[%s, 172.30.30.233:10911] boot success...

注意，如果没有设置好内存，那么会报错。

发送和接受消息 examples

## 在发送/接收消息之前，我们需要告诉客户名称服务器的位置。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

关闭

关闭nameserver broker
cd /usr/local/rocketmq/bin
sh mqshutdown namesrv
sh mqshutdown broker

常用命令

查看集群情况 ./mqadmin clusterList -n 127.0.0.1:9876
查看 broker 状态 ./mqadmin brokerStatus -n 127.0.0.1:9876 -b 172.20.1.138:10911 (注意换成你的 broker 地址)
查看 topic 列表 ./mqadmin topicList -n 127.0.0.1:9876
查看 topic 状态 ./mqadmin topicStatus -n 127.0.0.1:9876 -t MyTopic (换成你想查询的 topic)
查看 topic 路由 ./mqadmin topicRoute -n 127.0.0.1:9876 -t MyTopic