一切福田,不離方寸,從心而覓,感無不通。

Docker 部署 RocketMQ

这一节介绍如何使用Docker快速部署一个单节点单副本 RocketMQ 服务,并完成简单的消息收发。

系统要求
  1. 64位操作系统
  2. 64位 JDK 1.8+

1.拉取RocketMQ镜像

这里以dockerhub上 RocketMQ 5.3.1 版本的镜像为例,介绍部署过程。


 

2.创建容器共享网络

RocketMQ 中有多个服务,需要创建多个容器,创建 docker 网络便于容器间相互通信。


 

3.启动NameServer


 

信息

我们可以看到 'The Name Server boot success..’, 表示NameServer 已成功启动。

4.启动 Broker+Proxy

NameServer 成功启动后,我们启动 Broker 和 Proxy。

  • Linux
  • Windows

 

信息

我们可以看到 'The broker boot success..’, 表示 Broker 已成功启动。

备注

至此,一个单节点副本的 RocketMQ 集群已经部署起来了,我们可以利用脚本进行简单的消息收发。

5.SDK测试消息收发

工具测试完成后,我们可以尝试使用 SDK 收发消息。这里以 Java SDK 为例介绍一下消息收发过程,可以从 rocketmq-clients 中参阅更多细节。

  1. 在IDEA中创建一个Java工程。
  2. 在 pom.xml 文件中添加以下依赖引入Java依赖库,将 rocketmq-client-java-version 替换成 最新的版本.

     

  3. 进入broker容器,通过mqadmin创建 Topic。

     

  4. 在已创建的Java工程中,创建发送普通消息程序并运行,示例代码如下:

     

  5. 在已创建的Java工程中,创建订阅普通消息程序并运行。Apache RocketMQ 支持SimpleConsumerPushConsumer两种消费者类型,您可以选择以下任意一种方式订阅消息。

 

6. 停止容器

完成实验后,我们可以通过以下方式停止容器。


 

from:https://github.com/apache/rocketmq-site/blob/new-official-website/versioned_docs/version-5.0/02-quickStart/02quickstartWithDocker.md