45.RocketMQ环境搭建

RocketMQ入门

• RocketMQ是阿里巴巴开源得分布式消息中间件，现在是Apache得一个顶级项目。在阿里内部使用非常广泛，已经经过了“双11”这种万亿级得消息流转。

RocketMQ环境搭建

• 接下来我们先在Linux平台下安装一个RocketMQ的服务

环境准备

• 下载RocketMQ
• http://rocketmq.apache.org/releasenotes/release-notes-4.4.0/
• 环境要求
• Linux64位操作系统
• 64bit JDK 1.8+

安装RocketMQ

• 1.上传文件到Linux系统
• 2.解压到安装目录

unzip rocketmq-a11-4.4.0-bin-release.zip
mv rocketmq-a11-4.4.0-bin-release ../rocketmq

启动RocketMQ

• 1.切换到安装目录
• 2.启动NameServer

[root@heima rocketmq]# nohup ./bin/mqnamesrv &
[1] 1467
#只要进程不报错,就应该是启动成功了,可以查看一下日志
[root@heima rocketmq]# tail -f /root/1ogs/rocketmq1ogs/namesrv.log

• 3.启动Broker

#编辑bin/runbroker.sh 和bin/runserver.sh文件，修改里面的
#JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g - Xmn4g"
#为JAVA_OPT="${JAVA_OPT} -server -Xms 256m -Xmx256m -Xmn128m"
[root@heima rocketmq]# nohup bin/mqbroker -n localhost:9876 &
[root@heima rocketmq]# tail -f /root/1ogs/rocketmqlogs/broker.1og

测试RockerMQ

• 1.测试消息发送

[root@heima rocketmq]# export NAMESRV_ADDR=localhost:9876 
[root@heima rocketmq]# bin/tools.shorg.apache.r ocketmq.example.quickstart.Producer

• 2.测试消息接收

[root@heima rocketmq] # export NAMESRV_ADDR=localhost:9876
[root@heima rocketmq]# bin/too1s.shtorg.apache.rocketmq.examp1e.quickstart.Consumer

关闭RockerMQ

[root@heima rocketmq]# bin/mqshutdown broker
[root@heima rocketmq]# bin/mqshutdown namesrv