基于Docker安装RocketMQ4.3.2

拉取镜像

我们拉取的不是官方提供的rocketmq，而是一个哥们自己整个的rocketmq版本。之所以不选择官方提供的最主要原因是，官方提供的版本有很多配置地方比较麻烦，这哥们整合的更好一些。

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

查看rmqserver是否启动成功

docker logs rmqserver

查看rmqbrocker是否启动成功

docker logs rmqbroker

测试消息是否可以发送成功

复制一个会话，我们先发送消息

sh tools.sh org.apache.rocketmq.example.quickstart.Producer

可以看到消息可以发送成功

消费者接受消息

sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

消费者也没有问题

启动测试类，可以看到同样没有问题