docker安装rocketMQ和安装过程中出现问题的解决_docker

作者：min_xie_964 | 来源：互联网 | 2023-09-07 21:37

本文主要介绍了docker安装rocketMQ和安装过程中出现问题的解决，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的

拉取rocketmq镜像

docker命令如下

docker pull rocketmqinc/rocketmq:4.4.0

创建namesrv

docker命令

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文件配置

#如果节点较多可以配置多个
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。

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安装成功了。

在这里插入图片描述

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

在这里插入图片描述

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

在这里插入图片描述

拉取rocketmq镜像

docker命令如下

docker pull rocketmqinc/rocketmq:4.4.0

创建namesrv

docker命令

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文件配置

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。

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安装成功了。

在这里插入图片描述

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

在这里插入图片描述

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

在这里插入图片描述

推荐阅读

client
初学者遇到的dubbo设计架构问题及解决方法总结

本文总结了初学者在使用dubbo设计架构过程中遇到的问题，并提供了相应的解决方法。问题包括传输字节流限制、分布式事务、序列化、多点部署、zk端口冲突、服务失败请求3次机制以及启动时检查。通过解决这些问题，初学者能够更好地理解和应用dubbo设计架构。 ... [详细]

蜡笔小新 2023-12-09 10:07:18
client
ABAP开发发送邮件程序的配置和代码整理

本文介绍了通过ABAP开发往外网发邮件的需求，并提供了配置和代码整理的资料。其中包括了配置SAP邮件服务器的步骤和ABAP写发送邮件代码的过程。通过RZ10配置参数和icm/server_port_1的设定，可以实现向Sap User和外部邮件发送邮件的功能。希望对需要的开发人员有帮助。摘要长度：184字。 ... [详细]

蜡笔小新 2023-12-13 15:50:17
client
如何实现织梦DedeCms全站伪静态

本文介绍了如何通过修改织梦DedeCms源代码来实现全站伪静态，以提高管理和SEO效果。全站伪静态可以避免重复URL的问题，同时通过使用mod_rewrite伪静态模块和.htaccess正则表达式，可以更好地适应搜索引擎的需求。文章还提到了一些相关的技术和工具，如Ubuntu、qt编程、tomcat端口、爬虫、php request根目录等。 ... [详细]

蜡笔小新 2023-12-14 19:45:47
byte
Netty拆包粘包问题解决 —— 特殊结束符

本文介绍了解决Netty拆包粘包问题的一种方法——使用特殊结束符。在通讯过程中，客户端和服务器协商定义一个特殊的分隔符号，只要没有发送分隔符号，就代表一条数据没有结束。文章还提供了服务端的示例代码。 ... [详细]

蜡笔小新 2023-12-14 18:02:45
text
Web学习历程记录（七）——Tomcat基本概念和配置

本文介绍了Web学习历程记录中关于Tomcat的基本概念和配置。首先解释了Web静态Web资源和动态Web资源的概念，以及C/S架构和B/S架构的区别。然后介绍了常见的Web服务器，包括Weblogic、WebSphere和Tomcat。接着详细讲解了Tomcat的虚拟主机、web应用和虚拟路径映射的概念和配置过程。最后简要介绍了http协议的作用。本文内容详实，适合初学者了解Tomcat的基础知识。 ... [详细]

蜡笔小新 2023-12-13 17:08:24
import
计算机网络初识及通信流程分析

本文介绍了计算机网络的定义和通信流程，包括客户端编译文件、二进制转换、三层路由设备等。同时，还介绍了计算机网络中常用的关键词，如MAC地址和IP地址。 ... [详细]

蜡笔小新 2023-12-13 16:50:29
client
java命令运行

Java在运行已编译完成的类时，是通过java虚拟机来装载和执行的，java虚拟机通过操作系统命令JAVA_HOMEbinjava–option来启 ... [详细]

蜡笔小新 2023-12-12 19:26:55
client
Linux下Kafka单机安装配置方法（实操成功）

本文介绍了在Linux下安装和配置Kafka的方法，包括安装JDK、下载和解压Kafka、配置Kafka的参数，以及配置Kafka的日志目录、服务器IP和日志存放路径等。同时还提供了单机配置部署的方法和zookeeper地址和端口的配置。通过实操成功的案例，帮助读者快速完成Kafka的安装和配置。 ... [详细]

蜡笔小新 2023-12-12 18:14:32
client
服务器上的操作系统有哪些，如何选择适合的操作系统？

本文介绍了服务器上常见的操作系统，包括系统盘镜像、数据盘镜像和整机镜像的数量。同时，还介绍了共享镜像的限制和使用方法。此外，还提供了关于华为云服务的帮助中心，其中包括产品简介、价格说明、购买指南、用户指南、API参考、最佳实践、常见问题和视频帮助等技术文档。对于裸金属服务器的远程登录，本文介绍了使用密钥对登录的方法，并提供了部分操作系统配置示例。最后，还提到了SUSE云耀云服务器的特点和快速搭建方法。 ... [详细]

蜡笔小新 2023-12-12 13:33:19
go
mac php错误日志配置方法及错误级别修改

本文介绍了在mac环境下配置php错误日志的方法，包括修改php.ini文件和httpd.conf文件的操作步骤。同时还介绍了如何修改错误级别，以及相应的错误级别参考链接。 ... [详细]

蜡笔小新 2023-12-12 11:59:08
数组
如何提高PHP编程技能及推荐高级教程

本文介绍了如何提高PHP编程技能的方法，推荐了一些高级教程。学习任何一种编程语言都需要长期的坚持和不懈的努力，本文提醒读者要有足够的耐心和时间投入。通过实践操作学习，可以更好地理解和掌握PHP语言的特异性，特别是单引号和双引号的用法。同时，本文也指出了只走马观花看整体而不深入学习的学习方式无法真正掌握这门语言，建议读者要从整体来考虑局部，培养大局观。最后，本文提醒读者完成一个像模像样的网站需要付出更多的努力和实践。 ... [详细]

蜡笔小新 2023-12-11 18:38:37
function
单页面应用 VS 多页面应用的区别和适用场景

本文主要介绍了单页面应用（SPA）和多页面应用（MPA）的区别和适用场景。单页面应用只有一个主页面，所有内容都包含在主页面中，页面切换快但需要做相关的调优；多页面应用有多个独立的页面，每个页面都要加载相关资源，页面切换慢但适用于对SEO要求较高的应用。文章还提到了两者在资源加载、过渡动画、路由模式和数据传递方面的差异。 ... [详细]

蜡笔小新 2023-12-10 19:31:50
io
禅道测试管理工具的介绍及搭建方法

本文介绍了禅道作为一款国产开源免费的测试管理工具的特点和功能，并提供了禅道的搭建和调试方法。禅道是一款B/S结构的项目管理工具，可以实现组织管理、后台管理、产品管理、项目管理和测试管理等功能。同时，本文还介绍了其他软件测试相关工具，如功能自动化工具和性能自动化工具，以及白盒测试工具的使用。通过本文的阅读，读者可以了解禅道的基本使用方法和优势，从而更好地进行测试管理工作。 ... [详细]

蜡笔小新 2023-12-09 19:03:20
text
canvas.toDataURL('image/png')报错处理方法

前段时间做一个项目，需求是对每个视频添加预览图，这个问题最终选择方案是：用canvas.toDataYRL();来做转换获取视频的一个截图，添加到页面中，达到自动添加预览图的目的。 ... [详细]

蜡笔小新 2023-12-09 09:43:31
text
Tomcat安装与配置教程及常见问题解决方法

本文介绍了Tomcat的安装与配置教程，包括jdk版本的选择、域名解析、war文件的部署和访问、常见问题的解决方法等。其中涉及到的问题包括403问题、数据库连接问题、1130错误、2003错误、Java Runtime版本不兼容问题以及502错误等。最后还提到了项目的前后端连接代码的配置。通过本文的指导，读者可以顺利完成Tomcat的安装与配置，并解决常见的问题。 ... [详细]

蜡笔小新 2023-12-09 07:28:32