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

本文主要介绍了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端口