自己参考官方文档,遇到了坑,当做笔记了(个人使用的是centos6.5的)
一、启动
- 设置RocketMQ
- 消息系统:你的本地机器发送和接受消息
二、准备条件
- 64位的操作系统:Linux/Unix/Mac
- 64位JDK版本1.8+(注意把环境变量加到/etc/profile系统环境变量下)
- Maven版本3.2.x(注意把环境变量加到/etc/profile系统环境变量下)
- 使用git获取github上的rocketmq,也可以直接去官网下载然后上传到linux服务器上
- 4g以上的硬盘空间支持Broker服务
三、下载版本以及安装
- 可以选择下载 4.6.0 source release(没编译的)
https://archive.apache.org/dist/rocketmq/4.6.0/rocketmq-all-4.6.0-source-release.zip - 也可以下载 binary release(编译过的)
http://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.6.0/rocketmq-all-4.6.0-bin-release.zip - 演示的是rocketmq-all-4.6.0-source-release.zip这个版本的(注意)
unzip rocketmq-all-4.6.0-source-release.zip
cd rocketmq-all-4.6.0/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/rocketmq-4.6.0/rocketmq-4.6.0/bin(这是我安装是mqnamesrv命令所在的目录)
- 启动服务命令:sh mqnamesrv
四、启动服务
- 进入服务所在的bin目录: cd /usr/local/tools/rocketmq-all-4.6.0-source-release/distribution/target/rocketmq-4.6.0/rocketmq-4.6.0/bin
nohup sh mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success…
- 使用jobs命令查看放入后台的服务
五、启动Broker服务
- 启动之前使用命令:vim runbroker.sh(系统默认设置的太大了)
- 设置JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx256m -Xmn256m
- 在系统iptables下开放9876端口防火墙: vim /etc/sysconfig/iptables
nohup sh mqbroker -n localhost:9876 &(前提是进入了bin目录才这样使用的)
tail -f ~/logs/rocketmqlogs/broker.log
The broker[%s, 172.30.30.233:10911] boot success…
六、发送和接收消息
export NAMESRV_ADDR=localhost:9876
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= …
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt…
七、关闭服务
sh mqshutdown broker
The mqbroker(36695) is running…
Send shutdown request to mqbroker(36695) OK
sh mqshutdown namesrv
The mqnamesrv(36664) is running…
Send shutdown request to mqnamesrv(36664) OK
八、参考官网的demo配合java开发使用
- 链接直通车:http://rocketmq.apache.org/docs/simple-example/
PS:写到最后,关键要学会自己参考官方文档去练习。