RocketMQ基于Docker/Linux方式安装步骤

矫情吗；* 2023-06-11 03:24 1阅读 0赞

### RocketMQ基于Docker方式安装步骤 ###

*   *  一、Linux 环境
     *  二、RocketMQ镜像版本
     *   *  2.1、三个镜像
     *  三、安装步骤
     *   *  3.1、构建目录如下图
         *  3.2、启动容器
     *  四、Demo操作
     *  五、关闭服务

## 一、Linux 环境 ##

JDK + Docker-Compose

## 二、RocketMQ镜像版本 ##

### 2.1、三个镜像 ###

foxiswho/rocketmq:server，服务端

foxiswho/rocketmq:broker，节点

styletang/rocketmq-console-ng，web端，便于监控  
也就是说，我要同时安装这三个镜像，才算是RocketMQ的完整安装  
Docker-Compose可操作多个镜像的安装

## 三、安装步骤 ##

### 3.1、构建目录如下图 ###

![在这里插入图片描述][20191028214104710.png]  
其中logs和store是构建过程中才出现的，因此，只需要在指定的目录下构建broker.conf 和docker-compose.yml即可，这两个配置的具体配置如下

broker.conf

# 是否允许 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

docker-compose.yml

version: '3.5'
    services:
      rmqnamesrv:
        image: foxiswho/rocketmq:server
        container_name: rmqnamesrv
        ports:
          - 9876:9876
        volumes:
          - ./data/logs:/opt/logs
          - ./data/store:/opt/store
        networks:
            rmq:
              aliases:
                - rmqnamesrv
    
      rmqbroker:
        image: foxiswho/rocketmq:broker
        container_name: rmqbroker
        ports:
          - 10909:10909
          - 10911:10911
        volumes:
          - ./data/logs:/opt/logs
          - ./data/store:/opt/store
          - ./data/brokerconf/broker.conf:/etc/rocketmq/broker.conf
        environment:
            NAMESRV_ADDR: "rmqnamesrv:9876"
            JAVA_OPTS: " -Duser.home=/opt"
            JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
        command: mqbroker -c /etc/rocketmq/broker.conf
        depends_on:
          - rmqnamesrv
        networks:
          rmq:
            aliases:
              - rmqbroker
    
      rmqconsole:
        image: styletang/rocketmq-console-ng
        container_name: rmqconsole
        ports:
          - 10801:8080
        environment:
            JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
        depends_on:
          - rmqnamesrv
        networks:
          rmq:
            aliases:
              - rmqconsole
    
    networks:
      rmq:
        name: rmq
        driver: bridge

要注意，这三个镜像的端口映射，不要使用正在运行的端口，还有就是当你更改端口时，要删除镜像（我第一次就是使用了正在运行的端口，当我发现改了端口，run的时候，还是会有异常，后来 docker rm container才可以），

### 3.2、启动容器 ###

docker-compose up -d

![在这里插入图片描述][20191028215047185.png]  
可查看三个容器，构建完成，这时我们浏览器打开访问

ip:端口（console的端口）即ip:10801

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA1NjI5_size_16_color_FFFFFF_t_70]

## 四、Demo操作 ##

## 五、关闭服务 ##

![在这里插入图片描述][20191119112456797.png]

[20191028214104710.png]: /images/20230531/8f4c11ca2728471a807e6f40b93361cf.png
[20191028215047185.png]: /images/20230531/e65aa10c9f9e4961b2dbc9b2f258a2e3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyMTA1NjI5_size_16_color_FFFFFF_t_70]: /images/20230531/7ec7ce389cd64055a529df2fc603be96.png
[20191119112456797.png]: /images/20230531/ee77bba4c8cd476184fbc19de635f405.png