通俗易懂，如何最便捷 docker 安装 rocketmq 队列

文章保证，一路执行下去不会报错，报错你找我。如果觉得有用，希望屏幕前的大佬，点赞?关注

如果想搭建一个本地玩的 rocketmq，可以继续向下看，绝对让你体会“傻瓜式”点点点安装

文章中的内容皆是作者 “踩屎”无数，总结出来的绝对精髓

能够来看 rocketmq 的安装，证明已经了解基本概念，也就不在这班门弄斧了

rocketmq 有两个非常重要的概念，nameserver 和 broker，文章也是围绕这两个点进行安装，提供 便捷版本 & 可靠版本 两种方式

文章大纲如下：

• 安装 nameserver
  • 便捷版安装 nameserver
  • 可靠版安装 nameserver
• 安装 broker server
  • 便捷版安装 broker server
  • 可靠版安装 broker server
• 安装 rocketmq 控制台
• 创建 topic
  • 控制台创建
  • 命令行创建
• 结言

安装 nameserver

---

首先，通过 docker search 命令查看，准备拉取 rocketmq 的镜像

因为没有官方制作的镜像，所以我们选择一款名称为 foxiswho/rocketmq 的镜像，大家也可以使用 docker search rocketmq 自己搜索看一下

便捷版和可靠版的区别就是：安全版把重要文件通过映射的方式存放宿主机

微信搜索【源码兴趣圈】，关注龙台，回复【资料】领取涵盖 GO、Netty、SpringCLoud Alibaba、Seata、开发规范、面试宝典、数据结构等电子书 or 视频学习资料！

便捷版安装 nameserver

使用 docker 的好处就是 “一行命令走天下，如果不是那就来两行”

便捷版就是纯属本地安装，容器被铲掉就铲掉了，数据不稀的存储，就像某银行的经典字母。I（爱）C（存）B（不）C（存）

docker run -d -p 9876:9876 \
--name rmqnamesrv \
foxiswho/rocketmq:server-4.5.1

简单明了，运行命令 docker ps 查看是否有名称为 rmqnamesrv 的 docker 程序

如果是自己搭个 rocketmq 玩一玩，便捷版就可以满足需求

如果选择便捷版模式，直接跳过下一节可靠版安装就行

可靠版安装 nameserver

为了避免，我铲掉个容器，数据都丢失的情况。特此推出可靠版本，把数据存储存放到宿主机

先创建个目录，为了规范以后的 docker 文章，所以我们固定化目录方式

${HOME} 表示当前用户主目录，小伙伴不喜欢可以自行替换

mkdir -p ${HOME}/docker/software/rocketmq/data/namesrv/store
mkdir -p ${HOME}/docker/software/rocketmq/data/namesrv/logs

目录文件创建完成之后，执行下列包含映射关系的 docker 命令语句即可

docker run -d -p 9876:9876 \
-v ${HOME}/docker/software/rocketmq/data/namesrv/logs:/opt/logs \
-v ${HOME}/docker/software/rocketmq/data/namesrv/store:/opt/store \
--name rmqnamesrv \
-e "MAX_POSSIBLE_HEAP=100000000" \
foxiswho/rocketmq:server-4.5.1

nameserver 到这里就安装结束了，接下来继续 broker 服务端安装

安装 broker server

---

老规矩，broker 同样便捷版本 & 可靠版本安排，上才艺～

因为 broker 也是从 rocketmq 的镜像包中启动，所以这里不会再拉取新镜像

便捷版安装 broker

安装 broker 之前，我们需要在本地初始化配置文件，防止项目连接不到 rocketmq

1）新建配置目录

mkdir -p ${HOME}/docker/software/rocketmq/config

2）新建配置文件 broker.conf

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# 此处为本地ip, 如果部署服务器, 需要填写服务器外网ip
brokerIP1 = xx.xx.xx.xx

最后执行创建 broker 容器命令，命令虽然比较长，但是职责比较单一

1. 宿主机 10911、10909 和容器做一个映射
2. 给 broker 起一个新的名字 rmqbroker
3. 关联 rmqnamesrv 并起一个别名 namesrv 用作 namesrv 地址 ip
4. 修改启动内存为 512 m

docker run -d \
-p 10911:10911 \
-p 10909:10909 \
--name rmqbroker \
--link rmqnamesrv:namesrv \
-v ${HOME}/docker/software/rocketmq/conf/broker.conf:/etc/rocketmq/broker.conf \
-e "NAMESRV_ADDR=namesrv:9876" \
-e "JAVA_OPTS=-Duser.home=/opt" \
-e "JAVA_OPT_EXT=-server -Xms512m -Xmx512m" \
foxiswho/rocketmq:broker-4.5.1

可靠版安装 broker

还是先把目录文件创建出来

mkdir -p ${HOME}/docker/software/rocketmq/data/broker/logs
mkdir -p ${HOME}/docker/software/rocketmq/data/broker/store

把 broker 相关数据目录存放宿主机最大的好处：后续铲掉了 broker 容器，再次新建 topic 等数据未丢失

docker run -d \
-p 10911:10911 \
-p 10909:10909 \
--name rmqbroker \
--link rmqnamesrv:namesrv \
-v ${HOME}/docker/software/rocketmq/conf/broker.conf:/etc/rocketmq/broker.conf \
-v ${HOME}/docker/software/rocketmq/data/broker/logs:/opt/logs \
-v ${HOME}/docker/software/rocketmq/data/broker/store:/opt/store \
-e "NAMESRV_ADDR=namesrv:9876" \
-e "JAVA_OPTS=-Duser.home=/opt" \
-e "JAVA_OPT_EXT=-server -Xms512m -Xmx512m" \
foxiswho/rocketmq:broker-4.5.1

安装 rocketmq 控制台

如果没有可视化控制台是怎么样的体验

• 创建 topic 需要用又长又臭的命令，关键还记不住
• 无法很好的测试 topic 提供者、消费者发送接收消息
• 对于集群状态以及生产、消费数额统计无法得知等功能…

既然没有控制台有如上缺点，安装了后就是优点。首先，拉取控制台镜像包到本地

docker pull pangliang/rocketmq-console-ng

通过 docker 命令启动，直接执行即可，作者在安装控制台时因为一直错误差点嗝屁了

后面对于本地安装总结出，直接关联到 rmqnamesrv 容器上的 ip 就行

docker run -d \
--link rmqnamesrv:namesrv \
-e "JAVA_OPTS=-Drocketmq.config.namesrvAddr=namesrv:9876 -Drocketmq.config.isVIPChannel=false" \
--name rmqconsole \
-p 8088:8080 \
-t pangliang/rocketmq-console-ng

运行成功，稍等几秒启动时间，浏览器输入 localhost:8088 查看

顶栏是控制台支持的功能清单，进来默认是英文的，像作者这种小学一年级的英文水平，必须右上角 Chinese 安排

创建 topic

---

作者在创建 topic 时也是吃尽了“苦头”，可以这么说，目前为止，按照网上教程，没有一个能把文章流程跑下来的

控制台创建

推荐采用控制台方式创建 topic，便捷的同时错误率也低

1）点击控制台 新增/更新 按钮创建 topic

2）根据规则创建自己想要的 topic

集群名和 BROKER_NAME 选择默认即可，主题名你也随意，不要起中文名字 就行（别问我怎么知道的 ??）

命令行创建

rocketmq topic 可以在控制台创建，但是为了声明一个本镜像安装的一个 bug，还是选择通过原生命令测试

首先我们需要通过命令进入到容器内部，执行下述命令会进入容器的 /opt/rocketmq-4.4.0/bin 目录

docker exec -it rmqbroker bash

直接执行命令没商量，当然，报错也没商量

sh mqadmin updateTopic -b localhost:10911 -n localhost:9876 -t TopicTest-1

通过报错大概也能看出来一点，是某个算法签名照不到，这是为什么呢？

后来经过网上案例分析，镜像本身携带的是 OpenJDK，并不是 Oracle 的，问题就出在了这，如何解决呢？

目录下执行 vi tools.sh 命令，修改一行命令指向 OpenJDK 的绝对路径就可以了

将上图中的命令行修改为下述 JDK 的绝对路径即可

JAVA_OPT="${JAVA_OPT} -Djava.ext.dirs=${BASE_DIR}/lib:${JAVA_HOME}/jre/lib/ext:${JAVA_HOME}/lib/ext:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.212.b04-0.el7_6.x86_64/jre/lib/ext"

再次执行上述创建 topic 命令，出现创建成功标志就OK

create topic to localhost:10911 success.

结言

---

文章主要针对 rocketmq 的安装以及使用做出了详细的介绍，文章的每一步都是作者试验过很多遍的成果，如果发现哪一步行不通可以找我

小伙伴的喜欢就是对我最大的支持, 如果读了文章有所收获, 希望能够 点赞、评论、关注三连!

参考文章:

• http://www.10qianwan.com/articledetail/628561.html
• https://www.cnblogs.com/qdhxhz/p/11109696.html
• http://www.10qianwan.com/articledetail/532038.html

推荐阅读：

1. 【强烈推荐】1w 字，18 张图，彻底说清 springboot starter
2. 【强烈推荐】谨慎使用 JDK 8 新特性并行流 ParallelStream
3. 【大厂面试真题】JDK 线程池中如何不超最大线程数快速消费任务
4. 【大厂面试真题】JDK 线程池如何保证核心线程不被销毁