Docker安装RocketMQ详细教程

---

---

简介

• 什么是RocketMQ
  RocketMQ是一款分布式、队列模型的消息中间件,是阿里巴巴集团自主研发的专业消息中间件,借鉴参考了JMS规范的MQ实现,更参考了优秀的开源消息中间件KAFKA,实现了业务消峰、分布式事务的优秀框架。
• 版本查询
  docker镜像地址:https://hub.docker.com/r/apache/rocketmq

1. 需要安装的包

• namesrv 充当的角色为注册中心，broker 向 namesrv 注册。
  相当于路由消息的提供者，生产者(Producer)或消费者(Customer)可以通过Name Server查找各主题对应的Broker IP列表，多个Name Server实例组成集群，但相互独立，没有信息交换。支持Broker的动态注册与发现。
• rmqbroker 负责存储消息、转发消息。
  Broker Server在RocketMQ系统中负责接收从生产者(Producer)发送来的消息并存储、同事为消费者的拉取请求做准备。Borker Server也存储消息相关的元数据，包括消费者组、消费进度偏移、主题和队列信息等。
• rocketmq-console 控制台（可选）。
  通过UI界面监控和管理mq

2. 安装

2.1 namesrv注册中心

# 创建目录存放日记和配置文件
mkdir rocketmq
cd rocketmq
# 安装
docker run -d -p 9876:9876 -v $PWD/data/namesrv/logs:/root/logs -v $PWD/data/namesrv/store:/root/store --name rmqnamesrv -e "MAX_POSSIBLE_HEAP=100000000" rocketmqinc/rocketmq sh mqnamesrv

• $PWD 表示获取命令行目录
• #-d 以守护进程的方式启动
• #--name rmqnamesrv 把容器的名字设置为rmqnamesrv
• #-p 9876:9876 把容器内的端口9876挂载到宿主机9876上面
• #-v $PWD/data/namesrv/logs:/root/logs 把容器内的/root/logs日志目录挂载到宿主机的 $PWD/data/namesrv/logs
• #-v $PWD/data/namesrv/store:/root/store 把容器内的/root/store数据存储目录挂载到宿主机的 $PWD/data/namesrv/store目录
• #-e "MAX_POSSIBLE_HEAP=100000000" 设置容器的最大堆内存为100000000
• #rocketmqinc/rocketmq 使用的镜像名称
• #sh mqnamesrv 启动namesrv服务

2.2 rmqbroker负责存储消息、转发消息

• 启动之前，你需要在 rocketmq/conf目录下创建 broker.conf 文件

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
brokerIP1 = 主机的IP

• broker.conf解析
  brokerClusterName 所属集群名称，如果节点较多可以配置多个
  brokerNamebroker名称，master和slave使用相同的名称，表明他们的主从关系
  brokerId 0表示Master，大于0表示不同的slave
  deleteWhen表示几点做消息删除动作，默认是凌晨4点
  fileReservedTime在磁盘上保留消息的时长，单位是小时
  brokerRole 有三个值：SYNC_MASTER，ASYNC_MASTER，SLAVE；同步和异步表示Master和Slave之间同步数据的机制
  flushDiskType 刷盘策略，取值为：ASYNC_FLUSH，SYNC_FLUSH表示同步刷盘和异步刷盘；SYNC_FLUSH消息写入磁盘后才返回成功状态，ASYNC_FLUSH不需要；
  brokerIP1 设置broker节点所在服务器的ip地址
• 启动broker

# 和2.1一样的目录
cd rocketmq
docker run -d -p 10911:10911 -p 10909:10909 -v  $PWD/broker/logs:/root/logs -v  $PWD/broker/store:/root/store -v  $PWD/conf/broker.conf:/opt/rocketmq/conf/broker.conf --name rmqbroker --link rmqnamesrv:namesrv -e "NAMESRV_ADDR=namesrv:9876" -e "MAX_POSSIBLE_HEAP=200000000" rocketmqinc/rocketmq sh mqbroker -c /opt/rocketmq/conf/broker.conf

#-d 以守护进程的方式启动
#--name rmqbroker 把容器的名字设置为rmqbroker
#--link rmqnamesrv:namesrv 和rmqnamesrv容器通信
#-p 10911:10911 把容器的非vip通道端口挂载到宿主机
#-p 10909:10909 把容器的vip通道端口挂载到宿主机
#-e "NAMESRV_ADDR=namesrv:9876" 指定namesrv的地址为本机namesrv的ip地址:9876
#-e "MAX_POSSIBLE_HEAP=200000000" rocketmqinc/rocketmq sh mqbroker 指定broker服务的最大堆内存
#rocketmqinc/rocketmq 使用的镜像名称
#sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf 指定配置文件启动broker节点

2.3 rocketmq-console 控制台

• 启动

docker run -e "JAVA_OPTS=-Drocketmq.config.namesrvAddr={docker主机ip}:9876 -Drocketmq.config.isVIPChannel=false" --name rocketmq-console  -p 8080:8080 -t styletang/rocketmq-console-ng

• 如果8080冲突了，修改-p:新的端口:8080即可
• 浏览器输入ip:8080访问控制台