小知识:docker安装rocketMQ和安装过程中出现问题的解决

目录 拉取rocketmq镜像 创建namesrv 创建单个broker节点 rocketmq-console服务

本文主要介绍安装rocketmq4.4.0,主要分为四步,分别为:

1、拉取rocketmq镜像。

2、创建namesrv。

3、创建broker节点,我在这里介绍的是创建单个broker的。

4、rocketmq-console服务,用于管理rocketmq的管理界面。

拉取rocketmq镜像

docker命令如下

?
1
docker pull rocketmqinc/rocketmq:4.4.0

创建namesrv

docker命令

?
1
docker run -d –name rmqnamesrv -p 9876:9876 -v c:\data\rocketmq\logs:/root/logs -v c:\data\rocketmq\store:/root/store -e “max_possible_heap=100000000” rocketmqinc/rocketmq:4.4.0 sh mqnamesrv

参数解释

参数 描述 -d 以守护进程的方式启动 – -name 设置容器的名字 -p 容器9876端口映射到本机9876端口上 -v 把容器/root/logs(日志文件)目录映射到本机对应路径上 /把容器/root/store(数据存储)目录映射到本机对应路径上 -e 设置容器最大堆内存为 100000000 rocketmqinc/rocketmq:4.4.0 镜像名称:版本 sh 启动服务mqnamesrv

创建单个broker节点

docker命令

docker run -d –name rmqbroker –link rmqnamesrv:namesrv -p 10911:10911 -p 10909:10909 –privileged=true -v  c:\data\broker\logs:/root/logs -v  c:\data\broker\store:/root/store -v c:\data\broker\conf\broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf -e “namesrv_addr=namesrv:9876” -e “max_possible_heap=200000000” rocketmqinc/rocketmq:4.4.0 sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf

参数解释

参数 描述 -d 以守护进程的方式启动 – -name 设置容器的名字 – -link 和rmqnamesrv 容器建立通讯 -p 10911:10911 把容器的非vip通讯端口10911映射到本机10911端口 -p 10909:10909 把容器的vip通讯端口1090映射到本机10909端口 –privileged=true 设置允许挂载私有文件夹 -v 把容器/root/logs(日志文件)目录映射到本机对应路径上 /把容器/root/store(数据存储)目录映射到本机对应路径上 / 把容器/opt/rocketmq-4.4.0/conf/broker.conf配置文件映射到本机对应路径上(每次可以修改本机上的broker.conf文件,重启容器即可) -e “namesrv_addr=namesrv:9876” 指定namesrv的地址为本机的9876 -e “max_possible_heap=200000000” 设置broker服务的最大堆内存为 200000000 rocketmqinc/rocketmq:4.4.0 镜像名称:版本 sh mqbroker 启动服务mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf 指定配置文件启动broker

broker.conf文件配置

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
#如果节点较多可以配置多个
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地址
namesrvaddr = 本机ip地址:9876
brokerip1 = 本机ip地址

broker.conf配置文件中如果不加namesrvaddr配置,运行程序时会报如下的错:

exception in thread “main” org.apache.rocketmq.remoting.exception.remotingtoomuchrequestexception: senddefaultimpl call timeout

 at org.apache.rocketmq.client.impl.producer.defaultmqproducerimpl.senddefaultimpl(defaultmqproducerimpl.java:588)

 at org.apache.rocketmq.client.impl.producer.defaultmqproducerimpl.send(defaultmqproducerimpl.java:1223)

 at org.apache.rocketmq.client.impl.producer.defaultmqproducerimpl.send(defaultmqproducerimpl.java:1173)

 at org.apache.rocketmq.client.producer.defaultmqproducer.send(defaultmqproducer.java:214)

 at com.baojian.mob.base.producer.syncproducer.main(syncproducer.java:41)

15:22:31.455 [nettyclientselector_1] info rocketmqremoting – closechannel: close the connection to remote address[] result: true

15:22:32.049 [nettyclientselector_1] info rocketmqremoting – closechannel: close the connection to remote address[] result: true

rocketmq-console服务

docker命令

可以不使用docker pull 命令进行镜像拉取,直接执行docker run命令,如果此镜像不存在会先拉取镜像在执行docker run。

?
1
docker run -d –name rmqadmin -e “java_opts=-drocketmq.namesrv.addr=172.16.122.115:9876 -dcom.rocketmq.sendmessagewithvipchannel=false” -p 8081:8080 pangliang/rocketmq-console-ng

参数说明

描述 说明 -d 以守护进程的方式启动 – -name 设置容器的名字 -e “java_opts=-drocketmq.namesrv.addr=172.16.122.115:9876 设置namesrv服务的ip地址 -dcom.rocketmq.sendmessagewithvipchannel=false” 不使用vip通道发送消息 -p 8081:8080 把容器内的端口8080映射到主机上的8081端口

rocketmq-console界面

容器运行成功后,使用浏览器打开 http://127.0.0.1:8081 就可以进入到rokcetmq-console管理界面,看到集群信息,说明rocketmq安装成功了。

%小知识:docker安装rocketMQ和安装过程中出现问题的解决-猿站网-插图

rocketmq-console生产者界面报错问题

%小知识:docker安装rocketMQ和安装过程中出现问题的解决-1猿站网-插图

点击搜索报错,是因为生产者创建生产组后使用producer.shutdown()将它关闭了,将下面代码注销即可。

%小知识:docker安装rocketMQ和安装过程中出现问题的解决-2猿站网-插图

到此这篇关于docker安装rocketmq和安装过程中出现问题的解决的文章就介绍到这了,更多相关docker安装rocketmq内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家!

原文链接:https://blog.csdn.net/weixin_45003796/article/details/122156567

声明: 猿站网有关资源均来自网络搜集与网友提供,任何涉及商业盈利目的的均不得使用,否则产生的一切后果将由您自己承担! 本平台资源仅供个人学习交流、测试使用 所有内容请在下载后24小时内删除,制止非法恶意传播,不对任何下载或转载者造成的危害负任何法律责任!也请大家支持、购置正版! 。本站一律禁止以任何方式发布或转载任何违法的相关信息访客发现请向站长举报,会员发帖仅代表会员个人观点,并不代表本站赞同其观点和对其真实性负责。本网站的资源部分来源于网络,如有侵权烦请发送邮件至:2697268773@qq.com进行处理。
建站知识

小知识:MacOS使用Docker创建MySQL主从数据库的方法

2023-3-12 13:01:43

建站知识

小知识:Redis快速部署为Docker容器的实现方法

2023-3-12 13:16:42

0 条回复 A文章作者 M管理员
    暂无讨论,说说你的看法吧
个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索