Docker rocketmq部署的實(shí)現(xiàn)示例
最近學(xué)習(xí)使用 rocketmq，需要搭建 rocketmq 服務(wù)端，本文主要記錄 rocketmq 搭建過(guò)程以及這個(gè)過(guò)程踩到的一些坑。
準(zhǔn)備工作
在搭建之前，我們需要做一些準(zhǔn)備工作，這里我們需要使用 docker 搭建服務(wù)，所以需要提前安裝 docker。此外，由于 rocketmq 需要部署 broker 與 nameserver ，考慮到分開部署比較麻煩，這里將會(huì)使用 docker-compose。
rocketmq 架構(gòu)圖如下:
另外，還需要搭建一個(gè) web 可視化控制臺(tái)，可以監(jiān)控 mq 服務(wù)狀態(tài)，以及消息消費(fèi)情況，這里使用 rocketmq-console，同樣該程序也將使用 docker 安裝。
部署過(guò)程
首先我們需要 rocketmq docker 鏡像，這里我們可以選擇自己制作，直接拉取git@github.com:apache/rocketmq-docker.git，然后再制作鏡像。 另外還可以直接使用 docker hub 上官方制作的鏡像，鏡像名：rocketmqinc/rocketmq。
接著創(chuàng)建 mq 配置文件broker.conf，文件放置到/opt/rocketmq/conf，配置如下:
brokerClusterName = DefaultCluster brokerName = broker-a brokerId = 0 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH # 如果是本地程序調(diào)用云主機(jī) mq，這個(gè)需要設(shè)置成 云主機(jī) IP brokerIP1=10.10.101.80
在創(chuàng)建如下文件夾：/opt/rocketmq/logs，/opt/rocketmq/store，最后創(chuàng)建 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
注意點(diǎn)
這里需要注意 rocketmq broker 與 rokcetmq-console 都需要與 rokcetmq nameserver 連接，需要知道 nameserver ip。使用 docker-compose 之后，上面三個(gè) docker 容器將會(huì)一起編排，可以直接使用容器名代替容器 ip，如這里 nameserver 容器名 rmqnamesrv。
配置完成之后，運(yùn)行 docker-compose up 啟動(dòng)三個(gè)容器，啟動(dòng)成功后，訪問(wèn) ip:8087，查看 mq 外部控制臺(tái)，如果可以看到以下信息，rocketmq 服務(wù)啟動(dòng)成功。
初體驗(yàn) rocketmq
這里將會(huì)使用 springboot 快速上手使用 mq，將會(huì)使用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>
消費(fèi)服務(wù)發(fā)送方配置如下：
## application.properties rocketmq.name-server=ip:9876 rocketmq.producer.group=my-group
消費(fèi)服務(wù)發(fā)送方程序如下：
@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());
}
}
消息消費(fèi)方配置如下：
## application.properties rocketmq.name-server=ip:9876
消息消費(fèi)方運(yùn)行程序如下：
@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);
}
}
}
相關(guān)問(wèn)題
消息發(fā)送方消息發(fā)送異常，異常如圖所示：Caused by: org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout。
該異常是由于 brokerip 未設(shè)置正確導(dǎo)致，登錄 mq 服務(wù)控制臺(tái)，可以查看 broker 配置信息。
上面192.168.128.3:10911是 docker 容器 IP，這是一個(gè)主機(jī)內(nèi)部 IP。這里需要將 IP 設(shè)置為云主機(jī)的 IP，需要在broker.conf修改brokerIP1參數(shù)。
mq 控制臺(tái)無(wú)法正常查看 mq 服務(wù)信息。
這個(gè)問(wèn)題主要是 nameserver ip 設(shè)置錯(cuò)誤導(dǎo)致。查看 mq 控制臺(tái)運(yùn)維頁(yè)面，可以看到此時(shí)連接的 nameserver 地址信息。
可以看到這里設(shè)置的地址為：127.0.0.1:9876。由于這里 mq 控制臺(tái)使用 docker 容器，容器內(nèi)直接訪問(wèn)127.0.0.1:9876將會(huì)訪問(wèn)自己內(nèi)部，而非宿主機(jī)內(nèi)正確程序。
這里需要在 docker 配置環(huán)境變量，配置如下：
- JAVA_OPTS= -Dlogging.level.root=info -Drocketmq.namesrv.addr=rmqnamesrv:9876
幫助文檔
rocketmq-docker
RocketMq docker 搭建和基本概念
RocketMQ-Spring
作者：Leo_wl
出處：http://www.cnblogs.com/Leo_wl/
到此這篇關(guān)于Docker rocketmq部署的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)Docker rocketmq部署內(nèi)容請(qǐng)搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！
版權(quán)聲明：本站文章來(lái)源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請(qǐng)保持原文完整并注明來(lái)源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非www.sddonglingsh.com所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來(lái)源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來(lái)，僅供學(xué)習(xí)參考，不代表本站立場(chǎng)，如有內(nèi)容涉嫌侵權(quán)，請(qǐng)聯(lián)系alex-e#qq.com處理。
關(guān)注官方微信