环境说明
Rocket 4.8.0 / WSL2(Debian 12.2) / Docker 24.0.7
安装 RocketMQ
为了方便，使用 rocketmq-docker 以单机的方式部署, 参考 stage-a-specific-version.
1. 下载 rocket-docker
$ git clone https://github.com/apache/rocketmq-docker.git
2. 生成指定版本的启动模板
$ cd rocketmq-docker
$ sh stage.sh 4.8.0
$ ls stages/4.8.0/templates/
data kubernetes play-docker-compose.sh play-docker.sh play-kubernetes.sh ssl
docker-compose play-consumer.sh play-docker-dledger.sh play-docker-tls.sh play-producer.sh
3. 单机模式启动
$ cd stages/4.8.0/templates/
$ ./play-docker.sh centos
$ docker ps
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
43eecbf367c7 apache/rocketmq:4.8.0 "sh mqbroker -c /hom…" 20 seconds ago Up 19 seconds 0.0.0.0:10909->10909/tcp, :::10909->10909/tcp, 9876/tcp, 0.0.0.0:10911-10912->10911-10912/tcp, :::10911-10912->10911-10912/tcp rmqbroker
445df298e4e5 apache/rocketmq:4.8.0 "sh mqnamesrv" 20 seconds ago Up 19 seconds 10909/tcp, 0.0.0.0:9876->9876/tcp, :::9876->9876/tcp, 10911-10912/tcp rmqnamesrv
看起来运行正常对吧，但是存在一点问题，稍后再讲。
安装 rocketmq-dashboard
为了方便管理，安装rocketmq-dashboard， 同样使用 docker 方式。
$ docker pull apacherocketmq/rocketmq-dashboard:latest
$ docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest
报错(坑点) 1
打开链接 http://127.0.0.1:8080 , 会发现弹窗报错，如下:
org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to [127.0.0.1:9876] failed
因为 虽然 rmqnamesrv 容器服务已经将端口 9876 映射到本地(WSL2 Debian), 但是 rocketmq-dashboard 是从容器内部请求9876，故无法成功。
需要将 JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876 IP 改为 rmqnamesrv 容器的 IP。
查看 rmqnamesrv 容器 IP
$ docker inspect rmqnamesrv | grep IPAddress
"SecondaryIPAddresses": null,
"IPAddress": "172.17.0.2",
"IPAddress": "172.17.0.2",
可知 IP 为 172.17.0.2。 停止并删除原容器，重新启动。
$ docker stop rocketmq-dashboard
$ docker rm rocketmq-dashboard
$ docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=172.17.0.2:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest
报错(坑点) 2
再打开链接 http://127.0.0.1:8080 , 会发现新的弹窗报错，如下:
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to 30.25.90.30:10909 failed
这个地址 30.25.90.30:10909 其实是 docker 启动 rocketmq 时自带的：
broker.conf 修改前
$ cat data/broker/conf/broker.conf
brokerClusterName = DefaultCluster
brokerName = broker-abc
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
brokerIP1 = 30.25.90.30
在 broker.conf 添加一行 namesrvAddr = 172.17.0.2:9876
同时更换 brokerIP1 的地址(通过docker inspect rmqbroker | grep IPAddress命令获取)
broker.conf 修改后
$ cat data/broker/conf/broker.conf
brokerClusterName = DefaultCluster
brokerName = broker-abc
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = 172.17.0.1:9876
brokerIP1 = 172.17.0.3
重启 rocketmq ./play-docker.sh centos.
再打开链接 http://127.0.0.1:8080 即可成功的查看 rocketmq 的各种信息。
在调研(解决😂)完上面的安装问题后, 又遇到了 client sdk 问题。
Client SDK (坑点)
RocketMQ官方目前提供了Java/Go/CPP三个比较好的 Client SDK， 我大Python不配了(😠)，Python SDK是基于CPP包装的，相当于**阉割 **版，且不支持异步。 但我的项目是使用异步编程的，有大量的磁盘IO、网络IO，俗话说：“一处异步，处处异步”~ 但 rocketmq-client-python 它不支持异步呀！
卒~~~(☠️)
写在后面
虽然查看官网文档， 看到了丰富详细的功能介绍，但在安装使用中也遇到了不少坑，虽然也解决了一些，能进行初步的使用。 不过实在不敢继续深入研究和使用，主要怕遇见更多的坑(🏃♂️). 而且最重要的是官方没有详细有序的说明( 安装、使用、运维等等)，并且遇到问题一般在官方找不到解决方案!!! 和 Nacos 一样，都是开源出来的看起来功能性能都不错，但是文档、社区等维护的一塌糊涂。好像这两个都是阿里系开源的项目。能接触学习到这两个项目，只能说太年轻~~~
最后，我成功投入了RabbitMQ的怀抱😀。