Docker安装RocketMQ

矫情吗；* 2021-10-06 04:04 349阅读 0赞

### Docker安装RocketMQ ###

*  单机安装
 *   *  拉取镜像
     *  创建nameserver容器
     *  创建broker容器
     *  启动容器
     *  停止删除容器
 *  RocketMQ的管理工具
 *  集群安装
 *   *  创建2个master
     *  创建第1个master broker
     *  创建第2个master broker
     *  创建第1个slave broker
     *  创建第2个slave broker
     *  启动容器

# 单机安装 #

## 拉取镜像 ##

docker pull foxiswho/rocketmq:server-4.3.2 
    docker pull foxiswho/rocketmq:broker-4.3.2

## 创建nameserver容器 ##

docker create -p 9876:9876 --name rmqserver \ 
    -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \ 
    -e "JAVA_OPTS=-Duser.home=/opt"  \ 
    -v /haoke/rmq/rmqserver/logs:/opt/logs \ 
    -v /haoke/rmq/rmqserver/store:/opt/store \ 
    foxiswho/rocketmq:server-4.3.2

## 创建broker容器 ##

docker create -p 10911:10911 -p 10909:10909 --name rmqbroker \ 
    -e "JAVA_OPTS=-Duser.home=/opt"  \ 
    -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \ 
    -v /haoke/rmq/rmqbroker/conf/broker.conf:/etc/rocketmq/broker.conf \ 
    -v /haoke/rmq/rmqbroker/logs:/opt/logs \ 
    -v /haoke/rmq/rmqbroker/store:/opt/store \ 
    foxiswho/rocketmq:broker-4.3.2

## 启动容器 ##

docker start rmqserver rmqbroker

## 停止删除容器 ##

docker stop rmqbroker rmqserver 
    docker rm rmqbroker rmqserver

# RocketMQ的管理工具 #

RocketMQ提供了UI管理工具，名为rocketmq-console，项目地址：https://github.com/apache/rocketmq-exter nals/tree/master/rocketmq-console

\#拉取镜像  
docker pull styletang/rocketmq-console-ng:1.0.0

\#创建并启动容器  
docker run -e “JAVA\_OPTS=-Drocketmq.namesrv.addr=172.16.55.185:9876 Dcom.rocketmq.sendMessageWithVIPChannel=false” -p 8082:8080 -t styletang/rocketmqconsole-ng:1.0.0

通过浏览器进行访问：http://172.16.55.185:8082/\#/

# 集群安装 #

## 创建2个master ##

#nameserver1 
    docker create -p 9876:9876 --name rmqserver01 \ 
    -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \ 
    -e "JAVA_OPTS=-Duser.home=/opt"  \ 
    -v /haoke/rmq/rmqserver01/logs:/opt/logs \ 
    -v /haoke/rmq/rmqserver01/store:/opt/store \ 
    foxiswho/rocketmq:server-4.3.2
     
    #nameserver2 
    docker create -p 9877:9876 --name rmqserver02 \ 
    -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \ 
    -e "JAVA_OPTS=-Duser.home=/opt"  \ 
    -v /haoke/rmq/rmqserver02/logs:/opt/logs \ 
    -v /haoke/rmq/rmqserver02/store:/opt/store \ 
    foxiswho/rocketmq:server-4.3.2

## 创建第1个master broker ##

#master broker01 
    docker create --net host --name rmqbroker01 \ 
    -e "JAVA_OPTS=-Duser.home=/opt"  \ 
    -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \ 
    -v /haoke/rmq/rmqbroker01/conf/broker.conf:/etc/rocketmq/broker.conf \ 
    -v /haoke/rmq/rmqbroker01/logs:/opt/logs \ 
    -v /haoke/rmq/rmqbroker01/store:/opt/store \ 
    foxiswho/rocketmq:broker-4.3.2
    #配置
    namesrvAddr=172.16.55.185:9876;172.16.55.185:9877 
    brokerClusterName=VanderCluster 
    brokerName=broker01 
    brokerId=0 
    deleteWhen=04 
    fileReservedTime=48 
    brokerRole=SYNC_MASTER 
    flushDiskType=ASYNC_FLUSH 
    brokerIP1=172.16.55.185 
    brokerIp2=172.16.55.185 
    listenPort=10911

## 创建第2个master broker ##

#master broker02 
    docker create --net host --name rmqbroker02 \ 
    -e "JAVA_OPTS=-Duser.home=/opt"  \ 
    -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \ 
    -v /haoke/rmq/rmqbroker02/conf/broker.conf:/etc/rocketmq/broker.conf \ 
    -v /haoke/rmq/rmqbroker02/logs:/opt/logs \ 
    -v /haoke/rmq/rmqbroker02/store:/opt/store \ 
    foxiswho/rocketmq:broker-4.3.2
     
    #master broker02 
    namesrvAddr=172.16.55.185:9876;172.16.55.185:9877 
    brokerClusterName=VanderCluster 
    brokerName=broker02 
    brokerId=0 
    deleteWhen=04 
    fileReservedTime=48 
    brokerRole=SYNC_MASTER 
    flushDiskType=ASYNC_FLUSH 
    brokerIP1=172.16.55.185 
    brokerIp2=172.16.55.185 
    listenPort=10811

## 创建第1个slave broker ##

#slave broker01 
    docker create --net host --name rmqbroker03 \ 
    -e "JAVA_OPTS=-Duser.home=/opt"  \ 
    -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \ 
    -v /haoke/rmq/rmqbroker03/conf/broker.conf:/etc/rocketmq/broker.conf \ 
    -v /haoke/rmq/rmqbroker03/logs:/opt/logs \ 
    -v /haoke/rmq/rmqbroker03/store:/opt/store \ 
    foxiswho/rocketmq:broker-4.3.2
     
    #slave broker01 
    namesrvAddr=172.16.55.185:9876;172.16.55.185:9877 
    brokerClusterName=VanderCluster 
    brokerName=broker01 
    brokerId=1 
    deleteWhen=04 
    fileReservedTime=48
    brokerRole=SLAVE 
    flushDiskType=ASYNC_FLUSH 
    brokerIP1=172.16.55.185 
    brokerIp2=172.16.55.185 
    listenPort=10711

## 创建第2个slave broker ##

#slave broker01 
    docker create --net host --name rmqbroker04 \ 
    -e "JAVA_OPTS=-Duser.home=/opt"  \ 
    -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" \ 
    -v /haoke/rmq/rmqbroker04/conf/broker.conf:/etc/rocketmq/broker.conf \ 
    -v /haoke/rmq/rmqbroker04/logs:/opt/logs \ 
    -v /haoke/rmq/rmqbroker04/store:/opt/store \ 
    foxiswho/rocketmq:broker-4.3.2
     
    #slave broker02 
    namesrvAddr=172.16.55.185:9876;172.16.55.185:9877 
    brokerClusterName=VanderCluster 
    brokerName=broker02 
    brokerId=1 
    deleteWhen=04 
    fileReservedTime=48 
    brokerRole=SLAVE 
    flushDiskType=ASYNC_FLUSH 
    brokerIP1=172.16.55.185 
    brokerIp2=172.16.55.185 
    listenPort=10611

## 启动容器 ##

docker start rmqserver01 rmqserver02 
    docker start rmqbroker01 rmqbroker02 rmqbroker03 rmqbroker04