Docker安装RocketMQ单机版

Posted 拥有1024的蜡笔小新

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Docker安装RocketMQ单机版相关的知识,希望对你有一定的参考价值。

RocketMQ单机安装

知识索引

  • 基于docker安装namesrv
  • 基于docker安装broker
  • 基于docker安装rocketmq-console控制台

1 namesrv服务

Namesrv就是RMQ中的路由服务,可以类比ZKKafka中的作用,实现了路由管理、服务注册、服务发现等功能;不过Namesrv相比zookeeper来得要更轻便一点。

既然是为服务提供路由,所以要先安装,我们所有的安装都采用Docker容器安装。

namesrv需要存储数据,所以要先创建namesrv数据存储路径,创建命令如下:

mkdir -p \\
/usr/local/server/rocketmq/data/namesrv/logs \\
/usr/local/server/rocketmq/data/namesrv/store

安装namesrv:

docker run -d \\
--restart=always \\
--name rmqnamesrv \\
-p 9876:9876 \\
-v /usr/local/server/rocketmq/data/namesrv/logs:/root/logs \\
-v /usr/local/server/rocketmq/data/namesrv/store:/root/store \\
-e "MAX_POSSIBLE_HEAP=100000000" \\
rocketmqinc/rocketmq:4.4.0 \\
sh mqnamesrv

参数说明:

参数说明
-d以守护进程的方式启动
- -restart=alwaysdocker重启时候容器自动重启
- -name rmqnamesrv把容器的名字设置为rmqnamesrv
-p 9876:9876把容器内的端口9876挂载到宿主机9876上面
-v /usr/local/server/rocketmq/data/namesrv/logs:/root/logs把容器内的/root/logs日志目录挂载到宿主机的 /usr/local/server/rocketmq/data/namesrv/logs目录
-v /usr/local/server/rocketmq/data/namesrv/store:/root/store把容器内的/root/store数据存储目录挂载到宿主机的 /usr/local/server/rocketmq/data/namesrv目录
rmqnamesrv容器的名字
-e “MAX_POSSIBLE_HEAP=100000000”设置容器的最大堆内存为100000000
rocketmqinc/rocketmq使用的镜像名称
sh mqnamesrv启动namesrv服务

安装效果如下:

2 broker安装

brokerRocketMQ的主要服务,我们基于docker实现安装,但安装前,需要先配置,再执行安装。我们先创建存储数据的路径:

mkdir -p \\
/usr/local/server/rocketmq/data/broker/logs \\
/usr/local/server/rocketmq/data/broker/store \\
/usr/local/server/rocketmq/conf

2.1 配置

broker需要创建配置文件,用于指定broker核心配置信息,例如集群模式、刷盘模式等,我们在上面创建的/conf目录下创建文件broker.conf,配置如下:

# 所属集群名称,如果节点较多可以配置多个
brokerClusterName = ItmentuCluster
#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 = 192.168.211.130

2.2 构建broker容器

构建broker容器需要用到上面创建的配置文件,基于docker安装命令如下:

docker run -d  \\
--restart=always \\
--name rmqbroker \\
--link rmqnamesrv:namesrv \\
-p 10911:10911 \\
-p 10909:10909 \\
-v  /usr/local/server/rocketmq/data/broker/logs:/root/logs \\
-v  /usr/local/server/rocketmq/data/broker/store:/root/store \\
-v /usr/local/server/rocketmq/conf/broker.conf:/opt/rocketmq-4.4.20/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以守护进程的方式启动
–restart=alwaysdocker重启时候镜像自动重启
- -name rmqbroker把容器的名字设置为rmqbroker
- --link rmqnamesrv:namesrv和rmqnamesrv容器通信
-p 10911:10911把容器的非vip通道端口挂载到宿主机
-p 10909:10909把容器的vip通道端口挂载到宿主机
-e “NAMESRV_ADDR=namesrv:9876”指定namesrv的地址为本机namesrv的ip地址:9876
-e “MAX_POSSIBLE_HEAP=200000000” rocketmqinc/rocketmq sh mqbroker指定broker服务的最大堆内存
rocketmqinc/rocketmq使用的镜像名称
sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf指定配置文件启动broker节点

3 控制台安装

rockermq-consoleRocketMQ的管理控制台,使用它可以很轻松的管理RocketMQ。我们采用docker实现对rocketmq-console的安装。

3.1 安装rocketmq-console

基于docker命令安装如下:

docker run -d \\
--restart=always \\
--name rmqadmin \\
-e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.211.130:9876 \\
-Dserver.port=7001 \\
-Dcom.rocketmq.sendMessageWithVIPChannel=false" \\
-p 7001:7001 \\
pangliang/rocketmq-console-ng

参数说明:

参数说明
-d以守护进程的方式启动
- -restart=alwaysdocker重启时候镜像自动重启
- -name rmqadmin把容器的名字设置为rmqadmin
-e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.211.130:9876设置namesrv服务的ip地址
-Dcom.rocketmq.sendMessageWithVIPChannel=false"不使用vip通道发送消息
–p 7001:7001把容器内的端口7001挂载到宿主机上的7001端口
-Dserver.port=7001设置http端口为7001

3.2 控制台使用

要想使用rocketmq-console控制台,需要关闭防火墙或者开放namesrvbroker端口。

关闭防火墙:

#关闭防火墙
systemctl stop firewalld.service
#禁止开机启动
systemctl disable firewalld.service

开放指定端口:

firewall-cmd --permanent --zone=public --add-port=9876/tcp
firewall-cmd --permanent --zone=public --add-port=10911/tcp
# 立即生效
firewall-cmd --reload

上面关闭防火墙开放指定端口方法二选一即可,我们这里关闭防火墙后就可以使用了。可以直接访问后台:http://192.168.211.130:7001,效果如下:

以上是关于Docker安装RocketMQ单机版的主要内容,如果未能解决你的问题,请参考以下文章

linux12企业实战 -- 03docker elasticsearch单机映射文件到宿主机

Docker(单机Kafka安装)

Docker安装nacos1.0.0 固定ip 单机模式

RocketMQ在Docker下的部署

49-Docker-网络管理及Compose单机多容器编排

理解Docker单机容器网络