-
安装命令
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
RocketMQ 安装
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- [if !supportLists]1 [endif]手册 [if !supportLists]1.1 [endi...
- windows下的RocketMQ的安装 1 下载 选择合适版本下载官方下载地址此次下载为Binary版本 2 安...
