简介
本文介绍使用docker compose安装RocketMQ的方法。
本处我安装4.9.4版本，因为5.x版本的Java客户端有问题，官方还没解决。
1.创建docker-compose.yml
本处我新建一个文件夹：/work/middle/rocketmq，并创建docker-compose.yml，其内容如下：
version: '3.3'
services:
namesrv:
image: apache/rocketmq:4.9.4
container_name: rocketmq4.9.4_namesrv
ports:
- 9876:9876
environment:
# 注意：前边不要加-。如果想加-，那么:要改为=
JAVA_OPT_EXT: "-server -Xms512m -Xmx512m"
volumes:
- /work/middle/rocketmq/namesrv/logs:/opt/logs
- /work/middle/rocketmq/namesrv/store:/opt/logs
command: ["sh", "mqnamesrv"]
broker1:
image: apache/rocketmq:4.9.4
container_name: rocketmq4.9.4_broker1
depends_on:
- namesrv
#links:
# - namesrv
ports:
- 10909:10909
- 10911:10911
environment:
NAMESRV_ADDR: "namesrv:9876"
JAVA_OPT_EXT: "-server -Xms512m -Xmx512m"
volumes:
- /work/middle/rocketmq/broker/logs:/opt/logs
- /work/middle/rocketmq/broker/store:/opt/store
- /work/middle/rocketmq/broker/conf:/etc/rocketmq/conf
command: sh mqbroker -c /etc/rocketmq/conf/broker.conf
dashboard:
image: apacherocketmq/rocketmq-dashboard:1.0.0
container_name: rocketmqdashboard1.0.0
depends_on:
- namesrv
ports:
- 8080:8080
environment:
JAVA_OPTS: "-Xmx256M -Xms256M -Xmn128M -Drocketmq.namesrv.addr=namesrv:9876"
# 开启登录认证
ROCKETMQ_CONFIG_LOGIN_REQUIRED: true
volumes:
# 数据目录映射, user.properties需要放在data目录下
- /work/middle/rocketmq/rocketmq-dashboard/data:/tmp/rocketmq-console/data
2.创建broker配置文件
创建broker.conf，命令为：
mkdir -p /work/middle/rocketmq/broker/conf/ cd /work/middle/rocketmq/broker/conf/ sudo vi broker.conf
broker.conf的内容为：
# 所属集群名字 brokerClusterName=DefaultCluster # broker 名字，注意此处不同的配置文件填写的不一样，如果在 broker-a.properties 使用: broker-a, # 在 broker-b.properties 使用: broker-b brokerName=broker-a # 0 表示 Master，> 0 表示 Slave brokerId=0 # nameServer地址，分号分割 # namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876 # namesrvAddr=127.0.0.1:9876 # 启动IP,如果 docker 报 com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.0.120:10909> failed # 解决方式1：加上一句 producer.setVipChannelEnabled(false);，解决方式2：brokerIP1 设置宿主机IP，不要使用docker 内部IP brokerIP1=192.168.5.193 # 在发送消息时，自动创建服务器不存在的topic，默认创建的队列数 defaultTopicQueueNums=4 # 是否允许 Broker 自动创建 Topic，建议线下开启，线上关闭 ！！！这里仔细看是 false，false，false autoCreateTopicEnable=true # 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭 autoCreateSubscriptionGroup=true # Broker 对外服务的监听端口 listenPort=10911 # 删除文件时间点，默认凌晨4点 deleteWhen=04 # 文件保留时间，默认48小时 fileReservedTime=120 # commitLog 每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 # ConsumeQueue 每个文件默认存 30W 条，根据业务情况调整 mapedFileSizeConsumeQueue=300000 # destroyMapedFileIntervalForcibly=120000 # redeleteHangedFileInterval=120000 # 检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 # 存储路径 # storePathRootDir=/home/ztztdata/rocketmq-all-4.1.0-incubating/store # commitLog 存储路径 # storePathCommitLog=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/commitlog # 消费队列存储 # storePathConsumeQueue=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/consumequeue # 消息索引存储路径 # storePathIndex=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/index # checkpoint 文件存储路径 # storeCheckpoint=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/checkpoint # abort 文件存储路径 # abortFile=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/abort # 限制的消息大小 maxMessageSize=65536 # flushCommitLogLeastPages=4 # flushConsumeQueueLeastPages=2 # flushCommitLogThoroughInterval=10000 # flushConsumeQueueThoroughInterval=60000 # Broker 的角色 # - ASYNC_MASTER 异步复制Master # - SYNC_MASTER 同步双写Master # - SLAVE brokerRole=ASYNC_MASTER # 刷盘方式 # - ASYNC_FLUSH 异步刷盘 # - SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH # 发消息线程池数量 # sendMessageThreadPoolNums=128 # 拉消息线程池数量 # pullMessageThreadPoolNums=128
3.创建管理页面配置文件
默认是不需要账号和密码就能进入到管理页面，这样是不安全的，需要设置账号密码。
创建users.properties配置文件
mkdir -p /work/middle/rocketmq/rocketmq-dashboard/data cd /work/middle/rocketmq/rocketmq-dashboard/data sudo vi users.properties
users.properties内容如下：
# This file supports hot change, any change will be auto-reloaded without Dashboard restarting. # Format: a user per line, username=password[,N] #N is optional, 0 (Normal User); 1 (Admin) # 用户名和密码规则「用户名=密码,权限」，这里的权限为1表示管理员，为0表示普通用户 # Define Admin admin=admin123,1 # Define Users user1=user111
4.启动容器
docker compose up
5.查看管理页面
访问：ip:8080
输入账号和密码：admin admin123 然后点击登录后：
请先 ！