Docker 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/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 服务启动成功。

Docker 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);

									        }

									    }

									}