文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

docker安装rocketMQ和安装过程中出现问题怎么处理

2023-06-22 05:21

关注

小编给大家分享一下docker安装rocketMQ和安装过程中出现问题怎么处理,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!

本文主要介绍安装rocketMQ4.4.0,主要分为四步,分别为:
1、拉取rocketmq镜像。
2、创建namesrv。
3、创建broker节点,我在这里介绍的是创建单个broker的。
4、rocketMQ-console服务,用于管理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表示不同的slavebrokerId = 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地址:9876brokerIP1 = 本机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安装成功了。

docker安装rocketMQ和安装过程中出现问题怎么处理

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

docker安装rocketMQ和安装过程中出现问题怎么处理

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

docker安装rocketMQ和安装过程中出现问题怎么处理

看完了这篇文章,相信你对“docker安装rocketMQ和安装过程中出现问题怎么处理”有了一定的了解,如果想了解更多相关知识,欢迎关注编程网行业资讯频道,感谢各位的阅读!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯