正文 

当前位置： 首页 > 技术 > java教程

docker部署rocketmq集群(代码片段)

Luther- Luther-     2022-12-05     409

关键词：

最近搭建RocketMQ踩了一些坑，更新下

第一步，创建目录

mkdir -p /opt/rocketmq/logs/nameserver-a
mkdir -p /opt/rocketmq/logs/nameserver-b
mkdir -p /opt/rocketmq/store/nameserver-a
mkdir -p /opt/rocketmq/store/nameserver-b
mkdir -p /opt/rocketmq/logs/broker-a
mkdir -p /opt/rocketmq/logs/broker-b
mkdir -p /opt/rocketmq/store/broker-a
mkdir -p /opt/rocketmq/store/broker-b
mkdir -p /opt/rocketmq/broker-a/
mkdir -p /opt/rocketmq/broker-b/

第二步，创建broker.conf

vim /opt/rocketmq/broker-a/broker-a.conf
vim /opt/rocketmq/broker-b/broker-b.conf

brokerClusterName = rocketmq-cluster
brokerName = broker-a
brokerId = 0
#这个很有讲究 如果是正式环境 这里一定要填写内网地址（安全）
#如果是用于测试或者本地这里建议要填外网地址，因为你的本地代码是无法连接到阿里云内网，只能连接外网。
brokerIP1 = IP
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# 内网的(阿里云有内网IP和外网IP)
namesrvAddr=IP:9876;IP:9877
autoCreateTopicEnable=true
#Broker 对外服务的监听端口,
listenPort = 10911
#Broker角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH

=================================================================

brokerClusterName = rocketmq-cluster
brokerName = broker-b
brokerId = 0
brokerIP1 = IP
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# 内网的(阿里云有内网IP和外网IP)
namesrvAddr=IP:9876;IP:9877
autoCreateTopicEnable=true
#Broker 对外服务的监听端口,
listenPort = 10912
#Broker角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=ASYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH

第三步，编写 docker-compose.yml

vim /opt/rocketmq/docker-compose.yml

version: '3.5'
services:
  rmqnamesrv-a:
    image: rocketmqinc/rocketmq:4.4.0
    container_name: rmqnamesrv-a
    ports:
      - 9876:9876
    volumes:
      - /opt/rocketmq/logs/nameserver-a:/home/rocketmq/logs
      - /opt/rocketmq/store/nameserver-a:/home/rocketmq/store
    command: sh mqnamesrv
    networks:
        rmq:
          aliases:
            - rmqnamesrv-a

  rmqnamesrv-b:
    image: rocketmqinc/rocketmq:4.4.0
    container_name: rmqnamesrv-b
    ports:
      - 9877:9877
    volumes:
      - /opt/rocketmq/logs/nameserver-b:/home/rocketmq/logs
      - /opt/rocketmq/store/nameserver-b:/home/rocketmq/store
    command: sh mqnamesrv
    networks:
        rmq:
          aliases:
            - rmqnamesrv-b

  rmqbroker-a:
    image: rocketmqinc/rocketmq:4.4.0
    container_name: rmqbroker-a
    ports:
      - 10911:10911
    volumes:
      - /opt/rocketmq/logs/broker-a:/opt/logs
      - /opt/rocketmq/store/broker-a:/opt/store
      - /opt/rocketmq/broker-a/broker-a.conf:/opt/rocketmq-4.4.0/conf/broker.conf
    environment:
        TZ: Asia/Shanghai
        NAMESRV_ADDR: "rmqnamesrv-a:9876"
        JAVA_OPTS: " -Duser.home=/opt"
        JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"
    command: sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf
    links:
      - rmqnamesrv-a:rmqnamesrv-a
      - rmqnamesrv-b:rmqnamesrv-b
    networks:
      rmq:
        aliases:
          - rmqbroker-a

  rmqbroker-b:
    image: rocketmqinc/rocketmq:4.4.0
    container_name: rmqbroker-b
    ports:
      - 10912:10912
    volumes:
      - /opt/rocketmq/logs/broker-b:/opt/logs
      - /opt/rocketmq/store/broker-b:/opt/store
      - /opt/rocketmq/broker-b/broker-b.conf:/opt/rocketmq-4.4.0/conf/broker.conf
    environment:
        TZ: Asia/Shanghai
        NAMESRV_ADDR: "rmqnamesrv-b:9877"
        JAVA_OPTS: " -Duser.home=/opt"
        JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"
    command: sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf
    links:
      - rmqnamesrv-a:rmqnamesrv-a
      - rmqnamesrv-b:rmqnamesrv-b
    networks:
      rmq:
        aliases:
          - rmqbroker-b
  rmqconsole:
    image: styletang/rocketmq-console-ng
    container_name: rmqconsole
    ports:
      - 8087:8080
    environment:
        JAVA_OPTS: -Drocketmq.namesrv.addr=rmqnamesrv-a:9876;rmqnamesrv-b:9877 -Dcom.rocketmq.sendMessageWithVIPChannel=false
    networks:
      rmq:
        aliases:
          - rmqconsole
networks:
  rmq:
    name: rmq
    driver: bridge

最后一步，执行docker-compose

docker-compose -f docker-compose.yml up -d

 http://IP:8087/#/

rocketmq===》docker部署rocketmq(代码片段)

一、拉取镜像dockerpullrocketmqinc/rocketmq:4.4.0二、启动容器dockerrun-d-p9876:9876-v/data/ota_soft/mqtt/data/namesrv/logs:/root/logs-vRmHome/data/namesrv/store:/root/store--namermqnamesrv-e"MAX_POSSIBLE_HEAP& 查看详情

rocketmq：linux环境-单机部署和主从集群部署(代码片段)

1.单机部署（单主）1.1下载安装包说明：rocketmq需要jdk环境。（1）下载jdk安装包https://www.oracle.com/technetwork/java/javase/archive-139210.html下载jdk，这边选择的是jdk-8u144-linux-x64.tar.gz（2）下载rocketmq安装包http://rocketmq.apache.org/dowlo 查看详情

rocketmq集群部署（多master多slave异步）(代码片段)

一、最近公司在做队列的技术选型，经过调研，决定使用rocketmq作为整个架构的队列层，我们之前的公司是用RabbitMQ，集群部署参考我之前的文章：RabbitMQ集群部署；rocketmq集群由NameServer和Broker两种角色组成，NameServer是无状态的... 查看详情

docker环境下使用docker-compose一键式搭建rocketmq（4.5.0版本）集群及其管理工具(外网版)(代码片段)

...博客内容，使用docker-compose一键式搭建docker环境下的RocketMQ集群及其管理工具，实现rocketmq在docker环境容器外部访问。特别说明，内网版的RocketMQ集群只能实现docker环境内部访问，并不适用于测试使用，本节内容... 查看详情

docker环境下使用docker-compose一键式搭建rocketmq（4.5.0版本）集群及其管理工具(代码片段)

...本节我们主要讲解下如何使用docker-compose一键式搭建一套RocketMQ的消息中间键集群服务，在项目开发中kafka与rockerMQ应该是我们最常用的消息中间键，为了最大化的利用系统资源，便于研究测试，docker容器搭建这些... 查看详情

docker-compose部署rocketmq集群

...//////////////////////////////如果你的微服务没有放入docker或者rocketmq容器中，不能用IP直接访问。请修改broker-a.conf、broker-b.conf、broker-a-s.conf、broker-b-s.conf的brokerIP为宿主机IP，并去掉#。否则会报如下错误：com.alibaba.rocketmq.remoting.excepti... 查看详情

docker部署canal1.1.6rocketmq分区顺序性(代码片段)

docker部署canal1.1.6dockerpullcanal/canal-server:v1.1.6mkdir-p/mydata/canal/mkdir-p/mydata/canal/logs/chmod755-R/mydata/canal/dockerrun--namecanal-dcanal/canal-server:v1.1.6#拷贝配置文件dockercpcanal:/home/ad 查看详情

rocketmq的集群部署以及可视化监控界面(代码片段)

1.简介RocketMQisadistributedmessagingandstreamingplatformwithlowlatency,highperformanceandreliability,trillion-levelcapacityandflexiblescalability.ItisthethirdgenerationdistributedmessagingmiddlewareopensourcedbyAlibabain2012.OnNovember21,2016,AlibabadonatedRocketMQtotheApacheSoftwareFoundation.Ne... 查看详情

onos集群---基于docker部署(代码片段)

...为了能够快速的搭建起ONOS的集群环境，官网提供了基于docker的部署镜像。当我们部署完成docker环境以后，可以很方便的使用docker来部署一个ONOS的集群。[关于docker的环境部署，参考：http://www.cnblogs.com/BurlyLuo/p/8283815.html]ONOS使用 查看详情

docker-容器部署consul集群(代码片段)

原文:Docker-容器部署Consul集群目录说明简介了解ConsulConsul使用场景Consul优势Consul中的概念安装准备Consul镜像安装单个Consul组装集群Consul总结引用和附件说明本文主要介绍怎么使用Docker在Linux环境部署Consul集群，如果你对Docker不了... 查看详情

rocketmq===》docker部署rocketmq(代码片段)

一、拉取镜像dockerpullrocketmqinc/rocketmq:4.4.0二、启动容器dockerrun-d-p9876:9876-v/data/ota_soft/mqtt/data/namesrv/logs:/root/logs-vRmHome/data/namesrv/store:/root/store--namermqnamesrv-e"MAX_POSSIBLE_HEAP=100000000"rocketmqinc/rocketmq:4.4.0shmqnamesrv#通过docker的-v参... 查看详情

docker-swarm集群部署(代码片段)

docker-swarm集群部署一、swarm介绍  Swarm是Docker公司推出的用来管理docker集群的平台，几乎全部用GO语言来完成的开发的，代码开源在https://github.com/docker/swarm，它是将一群Docker宿主机变成一个单一的虚拟主机，Swarm使用标准的... 查看详情

部署consul建立docker集群(代码片段)

部署Consul建立Docker集群架构图1、什么是consul2、consul-template说明3、registrator的作用4、部署②、容器服务自动加入nginx集群③、服务端Consul下安装consul-template④、在宿主机上部署nginx⑤、部署多个Consul服务端主机架构图1、什么是cons... 查看详情

docker中redis集群部署(代码片段)

Docker中redis集群部署1.创建网卡dockernetworkcreateredis--subnet172.38.0.0/16#16有255*255设置24的话就2552.通过shell脚本创建6个redis配置forportin$(seq16);\\do\\mkdir-p/mydata/redis/node-$port/conftouch/mydata/redis/node-$po 查看详情

docker------dockerconsul集群部署(代码片段)

目录一.服务注册与发现概述二.Consul的概念三.Consul的部署环境准备1.建立Consul服务（192.168.121.22）①安装consul服务②查看集群信息③通过httpapi获取集群信息2.registrator服务器（192.168.121.33）①安装Gliderlabs/Registrator②... 查看详情

docker------dockerconsul集群部署(代码片段)

目录一.服务注册与发现概述二.Consul的概念三.Consul的部署环境准备1.建立Consul服务（192.168.121.22）①安装consul服务②查看集群信息③通过httpapi获取集群信息2.registrator服务器（192.168.121.33）①安装Gliderlabs/Registrator②... 查看详情

dockeroverlay应用部署(代码片段)

DockerOverlay部署条件要想使用Docker原生Overlay网络，需要满足以下任意条件： 1、Docker运行在Swarm模式 2、使用键值存储的Docker主机集群本次部署使用键值存储的Docker主机集群，需要满足以下条件：1.集群中主机连接到键值存... 查看详情

云原生之docker实战使用docker部署rabbitmq集群(代码片段)

【云原生之Docker实战】使用Docker部署Rabbitmq集群一、Rabbitmq介绍1.Rabbitmq简介2.Rabbitmq特点3.Rabbitmq的工作机制二、检查本地dokcer状态1.检查docker版本2.查看docker状态3.查看docker信息三、创建容器前准备工作1.创建数据卷2.创建网络3.查... 查看详情