當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

启动rocketmq_RocketMQ 部署启动指南-Docker 版

發布時間：2025/3/19 编程问答 35 豆豆

生活随笔收集整理的這篇文章主要介紹了启动rocketmq_RocketMQ 部署启动指南-Docker 版小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

最近學習使用 rocketmq，需要搭建 rocketmq 服務端，本文主要記錄 rocketmq 搭建過程以及這個過程踩到的一些坑。

準備工作

在搭建之前，我們需要做一些準備工作，這里我們需要使用 docker 搭建服務，所以需要提前安裝 docker。此外，由于 rocketmq 需要部署 broker 與 nameserver ，考慮到分開部署比較麻煩，這里將會使用 docker-compose。

rocketmq 架構圖如下:

另外，還需要搭建一個 web 可視化控制臺，可以監控 mq 服務狀態，以及消息消費情況，這里使用 rocketmq-console，同樣該程序也將使用 docker 安裝。

部署過程

首先我們需要 rocketmq docker 鏡像，這里我們可以選擇自己制作，直接拉取 git@github.com:apache/rocketmq-docker.git ，然后再制作鏡像。另外還可以直接使用 docker hub 上官方制作的鏡像，鏡像名： rocketmqinc/rocketmq。

接著創建 mq 配置文件 broker.conf，文件放置到 /opt/rocketmq/conf ，配置如下:

brokerClusterName = DefaultCluster brokerName = broker-a brokerId = 0 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH # 如果是本地程序調用云主機 mq，這個需要設置成云主機 IP brokerIP1=10.10.101.80

在創建如下文件夾：/opt/rocketmq/logs，/opt/rocketmq/store，最后創建 docker-compose.yml 文件，配置如下：

version: '2' services:namesrv:image: rocketmqinc/rocketmqcontainer_name: rmqnamesrvports:- 9876:9876volumes:- /opt/rocketmq/logs:/home/rocketmq/logs- /opt/rocketmq/store:/home/rocketmq/storecommand: sh mqnamesrvbroker:image: rocketmqinc/rocketmqcontainer_name: rmqbrokerports:- 10909:10909- 10911:10911- 10912:10912volumes:- /opt/rocketmq/logs:/home/rocketmq/logs- /opt/rocketmq/store:/home/rocketmq/store- /opt/rocketmq/conf/broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf#command: sh mqbroker -n namesrv:9876command: sh mqbroker -n namesrv:9876 -c ../conf/broker.confdepends_on:- namesrvenvironment:- JAVA_HOME=/usr/lib/jvm/jreconsole:image: styletang/rocketmq-console-ngcontainer_name: rocketmq-console-ngports:- 8087:8080depends_on:- namesrvenvironment:- JAVA_OPTS= -Dlogging.level.root=info -Drocketmq.namesrv.addr=rmqnamesrv:9876 - Dcom.rocketmq.sendMessageWithVIPChannel=false

注意點

這里需要注意 rocketmq broker 與 rokcetmq-console 都需要與 rokcetmq nameserver 連接，需要知道 nameserver ip。使用 docker-compose 之后，上面三個 docker 容器將會一起編排，可以直接使用容器名代替容器 ip，如這里 nameserver 容器名 rmqnamesrv。

配置完成之后，運行 docker-compose up 啟動三個容器，啟動成功后，訪問 ip:8087，查看 mq 外部控制臺，如果可以看到以下信息，rocketmq 服務啟動成功。

初體驗 rocketmq

這里將會使用 springboot 快速上手使用 mq，將會使用 rocketmq-spring-boot-starter 模塊，pom 配置如下：

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.3</version> </dependency>

消費服務發送方配置如下：

## application.properties rocketmq.name-server=ip:9876 rocketmq.producer.group=my-group

消費服務發送方程序如下：

@SpringBootApplication public class ProducerApplication implements CommandLineRunner {@Resourceprivate RocketMQTemplate rocketMQTemplate;public static void main(String[] args){SpringApplication.run(ProducerApplication.class, args);}public void run(String... args) throws Exception {rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");rocketMQTemplate.send("test-topic-1", MessageBuilder.withPayload("Hello, World! I'm from spring message").build());}}

消息消費方配置如下：

## application.properties rocketmq.name-server=ip:9876

消息消費方運行程序如下：

@SpringBootApplication public class ConsumerApplication{public static void main(String[] args){SpringApplication.run(ConsumerApplication.class, args);}@Slf4j@Service@RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1")public static class MyConsumer1 implements RocketMQListener<String> {public void onMessage(String message) {log.info("received message: {}", message);}} }

總結

以上是生活随笔為你收集整理的启动rocketmq_RocketMQ 部署启动指南-Docker 版的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇：刷脸支付弊端举例_刷脸支付的优势和弊端，
下一篇： cmd静默运行_【已解决】BAT批处理中

生活随笔