# CentOS安装rocketmq
# 1. RocketMQ快速入门
RocketMQ是阿里巴巴2016年MQ中间件，使用Java语言开发，在阿里内部，RocketMQ承接了例如“双11”等高并发场景的消息流转，能够处理万亿级别的消息。
# 1.1 准备工作
# 1.1.1 下载RocketMQ
RocketMQ版本：4.4.0
# 1.1.2 环境要求
- Linux64位系统
- JDK1.8(64位)
- 源码安装需要安装Maven 3.2.x
# 1.1.3 常用插件安装命令
解压文件 yum install -y unzip zip
windows 需要向centos服务器上传文件 yum -y install lrzsz
1
2
2
# 1.2 安装RocketMQ
# 1.2.1 安装步骤
本教程以二进制包方式安装
# 1.2.1.1 通过rz 把下载好的压缩文件上传到指定centos目录下面
# 1.2.1.2.解压rocket4.4压缩包
unzip -d /usr/software rocketmq-all-4.4.0-bin-release.zip
1
2
2
# 1.2.2 目录介绍
- benchmark :rocketmq的一些代码示例
- bin：启动脚本，包括shell脚本和CMD脚本
- conf：实例配置文件 ，包括broker配置文件、logback配置文件等
- lib：依赖jar包，包括Netty、commons-lang、FastJSON等
# 1.3 启动RocketMQ
- 启动NameServer
# 1.启动NameServer
nohup sh bin/mqnamesrv &
# 2.查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log
1
2
3
4
2
3
4
- 启动Broker
# 1.启动Broker
nohup sh bin/mqbroker -n localhost:9876 &
# 2.查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log
1
2
3
4
2
3
4
问题描述：
RocketMQ默认的虚拟机内存较大，启动Broker如果因为内存不足失败，需要编辑如下两个配置文件，修改JVM内存大小
# 编辑runbroker.sh和runserver.sh修改默认JVM大小
vi runbroker.sh
vi runserver.sh
1
2
3
2
3
- 参考设置：
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
# 1.4 测试RocketMQ
# 1.4.1 发送消息
# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.使用安装包的Demo发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
1
2
3
4
2
3
4
# 1.4.2 接收消息
# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
1
2
3
4
2
3
4
# 1.5 关闭RocketMQ
# 1.关闭NameServer
sh bin/mqshutdown namesrv
# 2.关闭Broker
sh bin/mqshutdown broker
1
2
3
4
2
3
4