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

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.kler.cn/a/271188.html

相关文章:

  • 如何将Excel两列数据转换为统计图、曲线图、折线图?如何自定义某一列作为Excel的统计图横纵坐标?
  • 爬虫学习 Scrapy中间件代理UA随机selenium使用
  • 矩阵消元-MIT
  • 蓝桥杯单片机——备赛(DS18B20)数码管亮度不同问题,温度一直是85或者95的问题。初步看赛点资源包!!!
  • 如何在webapp中于动发布一个应用
  • linux内建命令/内部命令之type
  • Lua中文语言编程源码-第三节,更改lualib.h Lua标准库, 使Lua支持中文关键词(与所有的基础库相关)
  • Kafka-SSL笔记整理
  • 用户故事到需求实例化
  • 【JavaScript】JavaScript 运算符 ④ ( 逻辑运算符 | 逻辑与运算符 | 逻辑或运算符 || | 逻辑非运算符 ! )
  • 关于微信公众号的一些个心得(持续更新)
  • Hack The Box-Jab
  • Lua-Lua与C的交互3
  • MacBook使用——彻底卸载并删除软件:NTFS for Mac
  • 游戏引擎中的动画基础
  • 线程有哪几种状态(附图)以及线程状态的变化
  • pycharm如何创建虚拟环境
  • tomcat 实现会话绑定
  • 客户端:Vue3,服务端:Node,基于Socket.IO实现单聊的功能
  • python opencv的最基础初学