docker-compose安装rocketmq

news2024/11/12 21:55:29

创建挂载目录

mkdir -p /home/docker/rocketmq/rocketmq_server/logs
mkdir -p /home/docker/rocketmq/rocketmq_broker/logs
mkdir -p /home/docker/rocketmq/rocketmq_broker/store
mkdir -p /home/docker/rocketmq/rocketmq_broker/conf


#创建配置文件broker.conf
cd /home/docker/rocketmq/rocketmq_broker/conf
#brokerIP1 为 `宿主机IP`
vim broker.conf

broker.conf里的内容为:

brokerIP1 为 `宿主机IP`

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.


# 所属集群名字
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

# 启动IP,如果 docker 报 com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.0.88:10909> failed
# 解决方式1 加上一句 producer.setVipChannelEnabled(false);,解决方式2 brokerIP1 设置宿主机IP,不要使用docker 内部IP
# brokerIP1=192.168.0.88
brokerIP1=xxx.126.23.xxx

# 在发送消息时,自动创建服务器不存在的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/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

权限

chmod 777 -R /home/docker/rocketmq

配置docker-compose.yml

cd /home/docker/rocketmq

vim docker-compose.yml

docker-compose.yml里的内容:

# 定义 Docker Compose 文件的版本。这里使用的是版本 3
version: '3'

# 定义了一个名为 rocketmq 的网络,使用默认的 IP 地址管理(IPAM)驱动,并且配置了一个子网 172.23.0.0/24
networks:
  rocketmq:
    ipam:
      driver: default
      config:
      # 为 rocketmq 网络配置一个子网,范围是 172.23.0.0/24。这个子网可以容纳 256 个 IP 地址(从 172.23.0.1 到 172.23.0.254),其中一些 IP 地址将用于容器
        - subnet: "172.23.0.0/24"

services:
  rocketmq_server:
    image: apache/rocketmq:5.1.3  
    container_name: rocketmq_server
    ports:
      - 9876:9876
    volumes:
      - /home/docker/rocketmq/rocketmq_server/logs:/home/rocketmq/logs
    environment:
      JAVA_OPT_EXT: "-Duser.home=/home/rocketmq -Xms256M -Xmx256M -Xmn128m"
    command: ["sh","mqnamesrv"]
    networks:
      rocketmq:
        ipv4_address: 172.23.0.11

  rocketmq_broker:
    image: apache/rocketmq:5.1.3
    container_name: rocketmq_broker
    ports:
      - 10909:10909
      - 10911:10911
    volumes:
      - /home/docker/rocketmq/rocketmq_broker/logs:/home/logs
      - /home/docker/rocketmq/rocketmq_broker/store:/home/store
      # `broker.conf`配置参考 https://github.com/apache/rocketmq/blob/master/distribution/conf/broker.conf
      - /home/docker/rocketmq/rocketmq_broker/conf/broker.conf:/home/rocketmq/broker.conf
    environment:
      NAMESRV_ADDR: "rocketmq_server:9876"
      JAVA_OPT_EXT: "-Duser.home=/home/rocketmq -server -Xms128m -Xmx128m -Xmn128m"
    command: ["sh","mqbroker","-c","/home/rocketmq/broker.conf","autoCreateTopicEnable=true"]
    depends_on:
      - rocketmq_server
    networks:
      rocketmq:
        ipv4_address: 172.23.0.21

  # mq可视化控制台
  rocketmq_dashboard:
    image: apacherocketmq/rocketmq-dashboard:1.0.0
    container_name: rocketmq_dashboard
    ports:
      - 9002:8080
    environment:
      JAVA_OPTS: "-Drocketmq.namesrv.addr=rocketmq_server:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
    depends_on:
      - rocketmq_server
    networks:
      rocketmq:
        ipv4_address: 172.23.0.31

开放端口

开放端口10909、10911、9876、9002

启动容器

cd /home/docker/rocketmq

docker-compose -p rocketmq up -d

docker-compose -p rocketmq up -d 这个命令用于启动 Docker Compose 定义的所有服务,并指定一个项目名称(project name)为 rocketmq。以下是命令的详细解释:

  • docker-compose:Docker Compose 是一个用于定义和运行多容器 Docker 应用的工具。使用 docker-compose.yml 文件,可以配置应用的服务、网络和卷等。

  • -p rocketmq:这个选项指定项目名称(project name)为 rocketmq。项目名称用于隔离环境中的资源(如网络、卷等)。如果不指定项目名称,Docker Compose 会默认使用当前目录名作为项目名称。

  • up:这个命令用于创建并启动 docker-compose.yml 文件中定义的所有服务。

  • -d:这个选项表示以守护进程(detached)模式运行,服务将在后台运行。

 

访问

http://ip:9002

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1917887.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

StarRocks 集群管理又添“猛将“ ,随配随用随时修改

前言 在存储业务数据时&#xff0c;StarRocks 存算分离支持使用各种外部独立存储系统。 在早期 3.0 版本中&#xff0c;用户需要在 fe.conf 中配置存储相关信息&#xff08;如 endpoint 等&#xff09;&#xff0c;这种静态配置模式也给用户使用带来了很多的不便性。 为此&a…

echarts中tooltip添加点击事件代码示例

echarts中tooltip添加点击事件代码示例_javascript技巧_脚本之家 点击事件无法使用this 或者 this无法使用&#xff1a;

【python】随机森林预测汽车销售

目录 引言 1. 数据收集与预处理 2. 划分数据集 3. 构建随机森林模型 4. 模型训练 5. 模型评估 6. 模型调优 数据集 代码及结果 独热编码 随机森林模型训练 特征重要性图 混淆矩阵 ROC曲线 引言 随机森林&#xff08;Random Forest&#xff09;是一种集成学习方法…

springboot餐饮管理系统-计算机毕业设计源码43667

摘 要 在信息化、数字化的时代背景下&#xff0c;餐饮行业面临着前所未有的挑战与机遇。为了提高运营效率、优化顾客体验&#xff0c;餐饮企业亟需一套高效、稳定且灵活的管理系统来支撑其日常运营。基于Spring Boot的餐饮管理系统应运而生&#xff0c;成为餐饮行业数字化转型的…

高仿imtoken钱包源码/获取助记词/获取私钥/自动归集

简介&#xff1a; 高仿imtoken钱包/获取助记词/获取私钥/自动归集 带双端&#xff0c;无纯源码 下载源码

企业网站源码系统 自主快速搭建响应式网站 海量模版随心选择 带完整的源代码包以及搭建教程

系统概述 企业网站源码系统&#xff0c;是一款专为中小企业量身定制的网站建设解决方案。该系统基于先进的Web开发技术&#xff0c;融合了模块化设计理念和用户友好的操作界面&#xff0c;旨在帮助企业用户无需编程基础&#xff0c;即可轻松搭建出符合自身需求的响应式网站。通…

太恐怖了,30秒录音,就能复刻你的声音

最近出的这一款AI文本转语音工具&#xff0c;太恐怖了&#xff01; 只需要有你一段录音&#xff0c;就能直接复刻你的声音。 下边是我复刻的李云龙的声音 这个工具复刻声音非常简单 使用步骤&#xff1a; 打开网站后选择构建声音 上传封面 填写名字和描述 上传音频或录制…

本周六!上海场新能源汽车数据基础设施专场 Meetup 来了

本周六下午 14:30 新能源汽车数据基础设施专场 Meetup 在上海&#xff0c;点击链接报名 &#x1f381; 到场有机会获得 Greptime 和 AutoMQ 的精美文创周边哦&#xff5e; &#x1f52e; 会后还有观众问答 & 抽奖环节等你来把神秘礼物带回家&#xff5e; &#x1f9c1; 更…

《信息技术时代》是什么级别的期刊?是正规期刊吗?能评职称吗?

​问题解答 问&#xff1a;《信息技术时代》是不是核心期刊&#xff1f; 答&#xff1a;不是&#xff0c;是万方维普收录的正规学术期刊。 问&#xff1a;《信息技术时代》级别&#xff1f; 答&#xff1a;省级。主管单位&#xff1a;深圳湾科技发展有限公司 主办单位&am…

Vue从零到实战

&#x1f49d;&#x1f49d;&#x1f49d;欢迎来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里可以感受到一份轻松愉快的氛围&#xff0c;不仅可以获得有趣的内容和知识&#xff0c;也可以畅所欲言、分享您的想法和见解。 非常期待和您一起在这个小…

web安全及内网安全知识

本文来源无问社区&#xff08;wwlib.cn&#xff09;更多详细内容可前往观看http://www.wwlib.cn/index.php/artread/artid/7506.html Web安全 1、sql注入 Web程序中对于用户提交的参数未做过滤直接拼接到SQL语句中执行&#xff0c;导致参数中的特殊字符破坏了SQL语句原有逻…

新品牌快速成长指南:揭秘品牌成功的黄金法则

打造一个新品牌是一个系统性工程&#xff0c;不是一两句话就能说清楚的。 作为一个13年的营销人&#xff0c;今天试图给大家以最简练和通俗的文字&#xff0c;详细讲讲打造一个全新的品牌都需要做些啥&#xff1f;码字不易&#xff0c;请多给点支持哦。 一、市场调研与定位&a…

顶顶通呼叫中心中间件实现随时启动和停止质检(mod_cti基于FreeSWITCH)

文章目录 前言联系我们拨号方案启动停止ASR执行FreeSWITCH 命令接口启动ASR接口停止ASR接口 通知配置cti.json配置质检结果写入数据库 前言 顶顶通呼叫中心中间件的实时质检功能是由两个模块组成&#xff1a;mod_asr 和 mod_qc。 mod_asr&#xff1a;负责调用ASR将用户们在通…

CDGA|创新数据治理工具:推动数据治理标准规范化之路

在数字化时代&#xff0c;数据已经成为企业运营和社会发展的重要资产。然而&#xff0c;随着数据量的激增和来源的多样化&#xff0c;如何有效地管理和利用这些数据成为了一个亟待解决的问题。为了应对这一挑战&#xff0c;创新数据治理工具应运而生&#xff0c;它们不仅提高了…

【简历】吉林某985大学:JAVA实习简历指导,面试通过率相当低

注&#xff1a;为保证用户信息安全&#xff0c;姓名和学校等信息已经进行同层次变更&#xff0c;内容部分细节也进行了部分隐藏 简历说明 这份简历是一个顶级985吉林大学的同学投Java职位的简历。因为学校是顶级985&#xff0c;所以他的大厂简历通过率是比较高的&#xff0c;…

qdma enable jtag debugger

ip上的m_axi_lite 是连接到qdma_v4_0_11_dma5_rtl_top这个ip的 和jtag debugger没有关系 qdma enable jtag debugger 读取的是ip内部reg ///home/nic626/smart_nic/build_dir/qdma_no_sriov_ex/qdma_no_sriov_ex.srcs/sources_1/ip/qdma_no_sriov.xcix!/qdma_no_sriov/ip_0/so…

经典文献阅读之--DEviLOG(使用合成数据和真实世界数据的数据驱动占用网格映射基于Transformer的BEV方案量产方案)

Tip: 如果你在进行深度学习、自动驾驶、模型推理、微调或AI绘画出图等任务&#xff0c;并且需要GPU资源&#xff0c;可以考虑使用UCloud云计算旗下的Compshare的GPU算力云平台。他们提供高性价比的4090 GPU&#xff0c;按时收费每卡2.6元&#xff0c;月卡只需要1.7元每小时&…

【中项第三版】系统集成项目管理工程师 | 第 11 章 规划过程组② | 11.3 - 11.5

前言 第 11 章对应的内容选择题和案例分析都会进行考查&#xff0c;这一章节属于10大管理的内容&#xff0c;学习要以教材为准。本章上午题分值预计在15分。 目录 11.3 收集需求 11.3.1 主要输入 11.3.2 主要工具与技术 11.3.3 主要输出 11.4 定义范围 11.4.1 主要输入…

Hi3861 OpenHarmony嵌入式应用入门--HTTPD

httpd 是 Apache HTTP Server 的守护进程名称&#xff0c;Apache HTTP Server 是一种广泛使用的开源网页服务器软件。 本项目是从LwIP中抽取的HTTP服务器代码&#xff1b; Hi3861 SDK中已经包含了一份预编译的lwip&#xff0c;但没有开启HTTP服务器功能&#xff08;静态库无法…

C# 解析省份、城市、区域 json文件

一、json文件内容如下&#xff0c;&#xff08;小程序里好像有用到...&#xff09;: 二、读取包含省份城市区域的json文件&#xff0c;并整理成想要的结果&#xff1a; string path Server.MapPath("/js"); string file System.IO.Path.Combine(path, "数据.…