Docker 版rocketmq部署

rocketmq 部署啓動指南-Docker 版

 

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

準備工做#

在搭建以前,咱們須要作一些準備工做,這裏咱們須要使用 docker 搭建服務,因此須要提早安裝 docker。此外,因爲 rocketmq 須要部署 broker 與 nameserver ,考慮到分開部署比較麻煩,這裏將會使用 docker-compose。java

rocketmq 架構圖以下:git

rocketmq

另外,還須要搭建一個 web 可視化控制檯,能夠監控 mq 服務狀態,以及消息消費狀況,這裏使用 rocketmq-console,一樣該程序也將使用 docker 安裝。github

部署過程#

首先咱們須要 rocketmq docker 鏡像,這裏咱們能夠選擇本身製做,直接拉取 git@github.com:apache/rocketmq-docker.git ,而後再製做鏡像。 另外還能夠直接使用 docker hub 上官方製做的鏡像,鏡像名: rocketmqinc/rocketmqweb

接着建立 mq 配置文件 broker.conf,文件放置到 /opt/rocketmq/conf ,配置以下:spring

Copy
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 文件,配置以下:docker

Copy
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

注意點shell

這裏須要注意 rocketmq broker 與 rokcetmq-console 都須要與 rokcetmq nameserver 鏈接,須要知道 nameserver ip。使用 docker-compose 以後,上面三個 docker 容器將會一塊兒編排,能夠直接使用容器名代替容器 ip,如這裏 nameserver 容器名 rmqnamesrv。apache

配置完成以後,運行 docker-compose up 啓動三個容器,啓動成功後,訪問 ip:8087,查看 mq 外部控制檯,若是能夠看到如下信息,rocketmq 服務啓動成功。springboot

mq 控制檯

初體驗 rocketmq#

這裏將會使用 springboot 快速上手使用 mq,將會使用 rocketmq-spring-boot-starter 模塊,pom 配置以下:

Copy
<!--在pom.xml中添加依賴--> <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.0.3</version> </dependency>

消費服務發送方配置以下:

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

消費服務發送方程序以下:

Copy
@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()); } }

消息消費方配置以下:

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

消息消費方運行程序以下:

Copy
@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); } } }

相關問題#

  1. 消息發送方消息發送異常,異常如圖所示:Caused by: org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout

該異常是因爲 brokerip 未設置正確致使,登陸 mq 服務控制檯,能夠查看 broker 配置信息。

image.png

上面 192.168.128.3:10911 是 docker 容器 IP,這是一個主機內部 IP。這裏須要將 IP 設置爲雲主機的 IP,須要在 broker.conf 修改 brokerIP1 參數。

  1. mq 控制檯沒法正常查看 mq 服務信息。

這個問題主要是 nameserver ip 設置錯誤致使。查看 mq 控制檯運維頁面,能夠看到此時鏈接的 nameserver 地址信息。

image.png

能夠看到這裏設置的地址爲:127.0.0.1:9876。因爲這裏 mq 控制檯使用 docker 容器,容器內直接訪問 127.0.0.1:9876 將會訪問本身內部,而非宿主機內正確程序。

這裏須要在 docker 配置環境變量,配置以下:

Copy
- JAVA_OPTS= -Dlogging.level.root=info -Drocketmq.namesrv.addr=rmqnamesrv:9876 

幫助文檔#

rocketmq-docker
RocketMq docker 搭建和基本概念
RocketMQ-Spring

相關文章
相關標籤/搜索