Go微服务: 基于rocketmq:5.2.0搭建RocketMQ环境，以及示例参考

news2025/1/13 10:16:57

概述

参考最新官方文档：https://rocketmq.apache.org/zh/docs/quickStart/03quickstartWithDockercompose
以及：https://rocketmq.apache.org/zh/docs/deploymentOperations/04Dashboard
综合以上两个文档来搭建环境

搭建RocketMQ环境

1 ) 基于 docker-compose 来搭建

version: '3.8'

services:
  namesrv:
    image: apache/rocketmq:5.2.0
    container_name: rmqnamesrv
    ports:
      - 9876:9876
    networks:
      - rmq
    command: sh mqnamesrv

  broker:
    image: apache/rocketmq:5.2.0
    container_name: rmqbroker
    ports:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    volumes:
      - ./conf/broker.conf:/opt/rocketmq-5.2.0/conf/broker.conf # 挂载入自定义配置文件
    environment:
      - NAMESRV_ADDR=rmqnamesrv:9876
    depends_on:
      - namesrv
    networks:
      - rmq
    command: sh mqbroker -c /opt/rocketmq-5.2.0/conf/broker.conf # 使用自定义配置文件启动

  proxy:
    image: apache/rocketmq:5.2.0
    container_name: rmqproxy
    networks:
      - rmq
    depends_on:
      - broker
      - namesrv
    ports:
      - 8080:8080
      - 8081:8081
    restart: on-failure
    environment:
      - NAMESRV_ADDR=rmqnamesrv:9876
    command: sh mqproxy

  dashboard:
    image: apacherocketmq/rocketmq-dashboard:latest
    container_name: rocketmq-dashboard
    ports:
      - 8088:8080
    networks:
      - rmq
    environment:
      - JAVA_OPTS=-Drocketmq.namesrv.addr=namesrv:9876
    depends_on:
      - namesrv
    restart: unless-stopped

networks:
  rmq:
    name: rmq
    driver: bridge

以上配置，是基于官方的2个文档综合而成的一个 yaml 配置文件
注意，如果 broker 中不配置 conf 文件，对 brokeIP 进行指定，则会使用容器内的地址
这时候，就需要自己的程序同样运行在相关的docker网络或打通和上述docker网络之间的连通
这个涉及到部署时的网络畅通，非常重要，在写程序的时候，可以像上述指定配置

2 ）对于 proxy 的特别说明

在上述Docker Compose配置中，proxy服务指的是RocketMQ的代理服务
具体来说，它对应的是RocketMQ提供的一个可选组件——RocketMQ Proxy
虽然RocketMQ Proxy并非RocketMQ的核心组件（核心组件主要是Nameserver和Broker）
但它扮演着重要的角色，特别是在提高系统可用性和简化客户端接入方面
以下是关于RocketMQ Proxy的一些详细说明

2.1 ）作用与目的

简化客户端配置
- 客户端只需要连接到Proxy
- 而不需要关心具体的Nameserver和Broker的地址，这减少了客户端的配置复杂度
- 尤其是在Broker集群规模大或频繁变动的情况下
负载均衡与高可用
- Proxy可以对客户端请求进行负载均衡，自动转发到不同的Broker
- 同时如果Broker发生故障，Proxy也能自动切换到其他可用Broker，提高了系统的高可用性
协议转换
- 虽然现代的RocketMQ客户端通常直接支持与Broker交互
- 但Proxy可以提供额外的协议转换能力，使得老版本或非标准的客户端也能接入
安全控制
- 作为中间层，Proxy可以更容易地实施访问控制、身份验证和加密等安全措施，增强系统安全性。

2.2 ）配置与使用

在上述配置中，proxy服务通过以下方式定义：
- 映射端口：8080:8080和8081:8081，这通常是Proxy的HTTP和HTTPS端口，用于客户端的连接。
- 环境变量：NAMESRV_ADDR=rmqnamesrv:9876，指定了Proxy需要连接到的Nameserver地址，这是为了获取Broker信息以进行消息路由。
- 重启策略：restart: on-failure，意味着当Proxy服务因某种原因失败时，Docker会自动尝试重启它，增加了服务的健壮性。
- 命令：command: sh mqproxy，这是启动Proxy服务的命令，表明这是一个RocketMQ Proxy实例

2.3 ）注意事项