rocketmq 部署啟動指南-Docker 版
最近學習使用 rocketmq,需要搭建 rocketmq 服務端,本文主要記錄 rocketmq 搭建過程以及這個過程踩到的一些坑。
準備工作
在搭建之前,我們需要做一些準備工作,這裡我們需要使用 docker 搭建服務,所以需要提前安裝 docker。此外,由於 rocketmq 需要部署 broker 與 nameserver ,考慮到分開部署比較麻煩,這裡將會使用 docker-compose。
rocketmq 架構圖如下:
另外,還需要搭建一個 web 視覺化控制檯,可以監控 mq 服務狀態,以及訊息消費情況,這裡使用 rocketmq-console,同樣該程式也將使用 docker 安裝。
部署過程
首先我們需要 rocketmq docker 映象,這裡我們可以選擇自己製作,直接拉取 [email protected]: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/rocketmq container_name: rmqnamesrv ports: - 9876:9876 volumes: - /opt/rocketmq/logs:/home/rocketmq/logs - /opt/rocketmq/store:/home/rocketmq/store command: sh mqnamesrv broker: image: rocketmqinc/rocketmq container_name: rmqbroker ports: - 10909:10909 - 10911:10911 - 10912:10912 volumes: - /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:9876 command: sh mqbroker -n namesrv:9876 -c ../conf/broker.conf depends_on: - namesrv environment: - JAVA_HOME=/usr/lib/jvm/jre console: image: styletang/rocketmq-console-ng container_name: rocketmq-console-ng ports: - 8087:8080 depends_on: - namesrv environment: - 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 配置如下:
<!--在pom.xml中新增依賴-->
<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 {
@Resource
private 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);
}
}
}
相關問題
- 訊息傳送方訊息傳送異常,異常如圖所示:
Caused by: org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
。
該異常是由於 brokerip 未設定正確導致,登入 mq 服務控制檯,可以檢視 broker 配置資訊。
上面 192.168.128.3:10911
是 docker 容器 IP,這是一個主機內部 IP。這裡需要將 IP 設定為雲主機的 IP,需要在 broker.conf
修改 brokerIP1
引數。
- mq 控制檯無法正常檢視 mq 服務資訊。
這個問題主要是 nameserver ip 設定錯誤導致。檢視 mq 控制檯運維頁面,可以看到此時連線的 nameserver 地址資訊。
可以看到這裡設定的地址為:127.0.0.1:9876
。由於這裡 mq 控制檯使用 docker 容器,容器內直接訪問 127.0.0.1:9876
將會訪問自己內部,而非宿主機內正確程式。
這裡需要在 docker 配置環境變數,配置如下:
- JAVA_OPTS= -Dlogging.level.root=info -Drocketmq.namesrv.addr=rmqnamesrv:9876
幫助文件
rocketmq-docker
RocketMq docker 搭建和基本概念
RocketMQ-Spring