Docker部署RocketMQ

# 文件目录

mq
  conf
    broker.conf
    plain_acl.yml
    users.properties
  docker-compose.yml

1
2
3
4
5
6

# `broker.conf`

#所属集群名字
brokerClusterName=DefaultCluster

#broker名字，注意此处不同的配置文件填写的不一样，如果在broker-a.properties使用:broker-a,
#在broker-b.properties使用:broker-b
brokerName=broker-a

#0 表示Master，>0 表示Slave
brokerId=0


#启动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.220.1

#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4

#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭 ！！！这里仔细看是false，false，false
autoCreateTopicEnable=true

#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true

#此参数控制是否开启密码
aclEnable=true

#删除文件时间点，默认凌晨4点
deleteWhen=04

#文件保留时间，默认48小时
fileReservedTime=120

#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824

#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000

#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
#storePathRootDir=/home/rocketmq/store
#commitLog 存储路径
#storePathCommitLog=/home/rocketmq/store/commitlog
#消费队列存储
#storePathConsumeQueue=/home/rocketmq/store/consumequeue
#消息索引存储路径
#storePathIndex=/home/rocketmq/store/index
#checkpoint 文件存储路径
#storeCheckpoint=/home/rocketmq/store/checkpoint
#abort 文件存储路径
#abortFile=/home/rocketmq/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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

# `plain_acl.yml`

如果配置了开启acl,需要配置accessKey、secretKey等

globalWhiteRemoteAddresses:
  - 10.10.103.123
accounts:
  - accessKey: RocketMQ
    secretKey: 12345678
    whiteRemoteAddress:
    admin: false
    defaultTopicPerm: DENY
    defaultGroupPerm: SUB
    topicPerms:
      - topicA=DENY
      - topicB=PUB|SUB
      - topicC=SUB
    groupPerms:
      # the group should convert to retry topic
      - groupA=DENY
      - groupB=PUB|SUB
      - groupC=SUB

  - accessKey: rocketmq2
    secretKey: 12345678
    whiteRemoteAddress: 
    # if it is admin, it could access all resources
    admin: true

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

# `docker-compose.yml`

version: "3.5"
services:
  mqnamesrv:
    image: apache/rocketmq:4.9.3
    container_name: mqnamesrv
    ports:
      - 9876:9876
    volumes:
      - /var/data/rocketmq/namesrv/logs:/home/rocketmq/logs
    environment:
      JAVA_OPT_EXT: -server -Xms128m -Xmx128m
    command: sh mqnamesrv
    networks:
      mq:
        aliases:
          - mqnamesrv
  mqbroker:
    image: apache/rocketmq:4.9.3
    container_name: mqbroker
    ports:
      - 10911:10911
      - 10909:10909
    volumes:
      - /var/data/rocketmq/broker/store:/home/rocketmq/store
      - /var/data/rocketmq/broker/logs:/home/rocketmq/logs
      - ./conf/broker.conf:/usr/local/dockerCompose/rocketmq/conf/broker.conf
      - ./conf/plain_acl.yml:/usr/local/dockerCompose/rocketmq/conf/plain_acl.yml
    depends_on:
      - mqnamesrv
    environment:
      JAVA_OPT_EXT: "-server -Xms128m -Xms128m -Xmn64m "
      NAMESRV_ADDR: mqnamesrv:9876
    command: sh mqbroker -n mqnamesrv:9876 -c /usr/local/dockerCompose/rocketmq/conf/broker.conf
    networks:
      mq:
        aliases:
          - mqbroker
  rocketmq-dashboard:
    container_name: rocketmq-dashboard
    image: apacherocketmq/rocketmq-dashboard:latest
    environment:
      JAVA_OPTS: "-Drocketmq.namesrv.addr=mqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=falses -Drocketmq.config.loginRequired=true  -Drocketmq.config.accessKey=rocketmq2 -Drocketmq.config.secretKey=12345678"
    ports:
      - 19876:8080
    volumes:
        - ./conf/users.properties:/tmp/rocketmq-console/data/users.properties
    depends_on:
      - mqnamesrv
    networks:
      mq:
        aliases:
          - dashboard
networks:
  mq:
    name: mq
    driver: bridge

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

需要注意的是一定要赋予挂载目录读写权限，否则broker启动失败。

# `users.properties`

设置控制台访问账户

# 该文件支持热修改，即添加和修改用户时，不需要重新启动console
# 格式， 每行定义一个用户， username=password[,N]  #N是可选项，可以为0 (普通用户)； 1 （管理员）
#定义管理员
# Define Admin
admin=123456Ww,1

# Define Users
#user1=user1
#user2=user2

1
2
3
4
5
6
7
8
9

编辑

#RocketMQ #Docker

上次更新: 2023/04/09, 16:34:32

← RocketMQ核心概念 SpringBoot集成RocketMQ→

Docker部署RocketMQ

# 文件目录

# broker.conf

# plain_acl.yml

# docker-compose.yml

# users.properties

# `broker.conf`

# `plain_acl.yml`

# `docker-compose.yml`

# `users.properties`