当前位置: 首页 > news >正文

Docker环境快速搭建RocketMq

window上面安装:

1.Namesrv

  1. docker pull rocketmqinc/rocketmq
  2. 创建C:/docker/rocketmq/data/namesrv/logs:/root/logs C:/docker/rocketmq/data/namesrv/store:/root/store 目录
    namesrv:
    docker run -d --restart=always --name rmqnamesrv -p 9876:9876 -v C:/docker/rocketmq/data/namesrv/logs:/root/logs -v C:/docker/rocketmq/data/namesrv/store:/root/store -e “MAX_POSSIBLE_HEAP=100000000” rocketmqinc/rocketmq sh mqnamesrv

Broker

broker:

  1. 在/docker/rocketmq/conf/broker.conf创建配置文件

所属集群名称,如果节点较多可以配置多个

brokerClusterName = DefaultCluster
#broker名称,master和slave使用相同的名称,表明他们的主从关系
brokerName = broker-a
#0表示Master,大于0表示不同的slave
brokerId = 0
#表示几点做消息删除动作,默认是凌晨4点
deleteWhen = 04
#在磁盘上保留消息的时长,单位是小时
fileReservedTime = 48
#有三个值:SYNC_MASTER,ASYNC_MASTER,SLAVE;同步和异步表示Master和Slave之间同步数据的机制;
brokerRole = ASYNC_MASTER
#刷盘策略,取值为:ASYNC_FLUSH,SYNC_FLUSH表示同步刷盘和异步刷盘;SYNC_FLUSH消息写入磁盘后才返回成功状态,ASYNC_FLUSH不需要;
flushDiskType = ASYNC_FLUSH

设置broker节点所在服务器的ip地址

brokerIP1 = 172.20.10.2

磁盘使用达到95%之后,生产者再写入消息会报错 CODE: 14 DESC: service not available now, maybe disk full

diskMaxUsedSpaceRatio=95
docker run -d --restart=always --name rmqbroker --link rmqnamesrv:namesrv -p 10911:10911 -p 10909:10909 -v C:/docker/rocketmq/data/broker/logs:/root/logs -v C:/docker/rocketmq/data/broker/store:/root/store -v C:/docker/rocketmq/conf/broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf -e “NAMESRV_ADDR=namesrv:9876” -e “MAX_POSSIBLE_HEAP=200000000” rocketmqinc/rocketmq sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf

Console

console:
docker run -d --restart=always --name rmqadmin -e “JAVA_OPTS=-Drocketmq.namesrv.addr=172.20.10.2:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false” -p 9999:8080 pangliang/rocketmq-console-ng

http://www.lryc.cn/news/319195.html

相关文章:

  • 【leetcode热题】比较版本号
  • 【ArcGISPro】道路数据下载并使用
  • DataGrip 面试题及答案整理,最新面试题
  • 2、设计模式之单例模式详解(Singleton)
  • 【django framework】ModelSerializer+GenericAPIView,如何在提交前修改某些字段值
  • 2024年【P气瓶充装】模拟考试及P气瓶充装证考试
  • <JavaEE> 数据链路层 -- 以太网协议、MTU限制、ARP协议
  • 认识Testbench仿真激励
  • Postman请求API接口测试步骤和说明
  • 这是二叉搜索树吗?
  • 5.82 BCC工具之tcpdrop.py解读
  • JavaScript 基础知识
  • 【判断是否为回文数】
  • 【C++】string进一步介绍
  • 思科设备下面主机访问公网经常时好时坏延迟大丢包不稳定
  • nuxtjs 如何通过ecosystem.config.js配置pm2?
  • 个人博客系列-后端项目-用户注册功能(7)
  • vue项目因内存溢出启动报错
  • UI 学习 二 可访问性 模式
  • Spring学习
  • 鸿蒙开发-UI-动画-组件内转场动画
  • Leet code 179 最大数
  • swagger踩坑之请求类不显示具体字段
  • 案例分析篇14:信息系统安全设计考点(2024年软考高级系统架构设计师冲刺知识点总结系列文章)
  • 前端之用HTML弄一个古诗词
  • Linux 安装使用 Docker
  • Doris部署学习(一)
  • QT下跨平台库实现及移植经验分享
  • 8:00面试,8:06就出来了,问的问题有点变态。。。
  • Rust 利用 Trait 实现多态性