使用docker安装RocketMQ

阳光穿透心脏的1/2处 2022-12-14 13:40 224阅读 0赞

### 文章目录 ###

*  1.创建namesrv服务
 *   *  拉取镜像
     *  创建namesrv数据存储路径
     *  构建namesrv容器
 *  2.创建broker节点
 *   *  创建broker数据存储路径
     *  创建配置文件
     *  构建broker容器
 *  3.创建rockermq-console服务
 *   *  拉取镜像
     *  构建rockermq-console容器
     *  需要关闭防火墙或者开放namesrv和broker端口
     *   *  关闭防火墙
         *  开放指定端口
     *  访问控制台

# 1.创建namesrv服务 #

## 拉取镜像 ##

docker pull rocketmqinc/rocketmq

## 创建namesrv数据存储路径 ##

mkdir -p  /docker/rocketmq/data/namesrv/logs   /docker/rocketmq/data/namesrv/store

## 构建namesrv容器 ##

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

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

# 2.创建broker节点 #

## 创建broker数据存储路径 ##

mkdir -p  /docker/rocketmq/data/broker/logs   /docker/rocketmq/data/broker/store /docker/rocketmq/conf

## 创建配置文件 ##

vi /docker/rocketmq/conf/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地址
    brokerIP1 = 192.168.52.136

## 构建broker容器 ##

docker run -d  \
    --restart=always \
    --name rmqbroker \
    --link rmqnamesrv:namesrv \
    -p 10911:10911 \
    -p 10909:10909 \
    -v  /docker/rocketmq/data/broker/logs:/root/logs \
    -v  /docker/rocketmq/data/broker/store:/root/store \
    -v /docker/rocketmq/conf/broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf \
    -e "NAMESRV_ADDR=namesrv:9876" \
    -e "MAX_POSSIBLE_HEAP=200000000" \
    rocketmqinc/rocketmq \
    sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf

<table> 
 <thead> 
  <tr> 
   <th>参数</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>-d</td> 
   <td>以守护进程的方式启动</td> 
  </tr> 
  <tr> 
   <td>–restart=always</td> 
   <td>docker重启时候镜像自动重启</td> 
  </tr> 
  <tr> 
   <td>- -name rmqbroker</td> 
   <td>把容器的名字设置为rmqbroker</td> 
  </tr> 
  <tr> 
   <td>- --link rmqnamesrv:namesrv</td> 
   <td>和rmqnamesrv容器通信</td> 
  </tr> 
  <tr> 
   <td>-p 10911:10911</td> 
   <td>把容器的非vip通道端口挂载到宿主机</td> 
  </tr> 
  <tr> 
   <td>-p 10909:10909</td> 
   <td>把容器的vip通道端口挂载到宿主机</td> 
  </tr> 
  <tr> 
   <td>-e “NAMESRV_ADDR=namesrv:9876”</td> 
   <td>指定namesrv的地址为本机namesrv的ip地址:9876</td> 
  </tr> 
  <tr> 
   <td>-e “MAX_POSSIBLE_HEAP=200000000” rocketmqinc/rocketmq sh mqbroker</td> 
   <td>指定broker服务的最大堆内存</td> 
  </tr> 
  <tr> 
   <td>rocketmqinc/rocketmq</td> 
   <td>使用的镜像名称</td> 
  </tr> 
  <tr> 
   <td>sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf</td> 
   <td>指定配置文件启动broker节点</td> 
  </tr> 
 </tbody> 
</table>

# 3.创建rockermq-console服务 #

## 拉取镜像 ##

docker pull pangliang/rocketmq-console-ng

## 构建rockermq-console容器 ##

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

<table> 
 <thead> 
  <tr> 
   <th>参数</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>-d</td> 
   <td>以守护进程的方式启动</td> 
  </tr> 
  <tr> 
   <td>- -restart=always</td> 
   <td>docker重启时候镜像自动重启</td> 
  </tr> 
  <tr> 
   <td>- -name rmqadmin</td> 
   <td>把容器的名字设置为rmqadmin</td> 
  </tr> 
  <tr> 
   <td>-e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.52.136:9876</td> 
   <td>设置namesrv服务的ip地址</td> 
  </tr> 
  <tr> 
   <td>-Dcom.rocketmq.sendMessageWithVIPChannel=false"</td> 
   <td>不使用vip通道发送消息</td> 
  </tr> 
  <tr> 
   <td>–p 9999:8080</td> 
   <td>把容器内的端口8080挂载到宿主机上的9999端口</td> 
  </tr> 
 </tbody> 
</table>

## 需要关闭防火墙或者开放namesrv和broker端口 ##

如果不设置,控制台服务将无法访问namesrv服务  
异常信息如下  
org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to failed  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pbmcxOTk1MTIyNA_size_16_color_FFFFFF_t_70_pic_center]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pbmcxOTk1MTIyNA_size_16_color_FFFFFF_t_70_pic_center 1]

### 关闭防火墙 ###

systemctl stop 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.52.136:9999/查看控制台信息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pbmcxOTk1MTIyNA_size_16_color_FFFFFF_t_70_pic_center 2]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pbmcxOTk1MTIyNA_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/2b0948d7928d42f197c0115697999ad4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pbmcxOTk1MTIyNA_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/0af38309c015479ea72ef8e613eb299b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pbmcxOTk1MTIyNA_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221123/ec5d588d9aaf4e4cbd32bdbfd12415f8.png