argoproj/nats-gateway Docker 镜像 - 轩辕镜像 | Docker 镜像高效稳定拉取服务

NATS Gateway 镜像文档

镜像概述

NATS Gateway是NATS消息系统的官方网关组件，旨在实现不同NATS集群间的互联、消息路由及多协议转换。该镜像提供轻量级、高性能的网关服务，支持跨集群通信、异构消息系统集成，并通过灵活配置满足复杂消息架构需求。

核心功能与特性

1. 集群互联

• 支持多NATS集群桥接，实现跨集群消息透明传输
• 兼容NATS Core与JetStream集群的双向通信
• 动态集群发现与连接状态管理

2. 协议转换

• 内置多协议支持（NATS Core、JetStream、MQTT等）
• 协议间消息格式自动转换与主题映射
• 可扩展协议适配器架构，支持自定义协议扩展

3. 智能路由

• 基于主题、队列、标签的细粒度路由规则
• 静态路由配置与动态路由发现双模式支持
• 消息过滤、转换与 enrichment 能力

4. 高可用设计

• 无状态服务架构，支持水平扩展
• 集群模式下自动故障检测与转移
• 持久化连接状态与消息重试机制

使用场景

1. 多区域集群互联

适用于跨数据中心、多区域部署的NATS集群，通过网关实现区域间消息同步与跨区域业务协同。

2. 混合云消息架构

在混合云环境（私有云+公有云）中，连接不同环境的NATS集群，实现统一消息传递与业务流程贯通。

3. 异构系统集成

对接非NATS协议的消息系统（如MQTT设备网络、传统消息队列），实现跨协议消息交换与业务协同。

4. 安全消息隔离

在组织内部不同部门或外部合作伙伴间，通过网关实现消息的安全隔离、权限控制与受控转发。

使用方法

基本运行方式

通过docker run命令启动NATS Gateway：

bash
docker run -d \
  --name nats-gateway \
  -p 8080:8080 \
  -p 4222:4222 \
  -v ./gateway-config:/etc/nats-gateway \
  natsio/gateway:latest \
  --config /etc/nats-gateway/gateway.conf

Docker Compose配置示例

yaml
version: '3.8'

services:
  nats-gateway:
    image: natsio/gateway:latest
    container_name: nats-gateway
    restart: always
    ports:
      - "8080:8080"  # 管理API端口
      - "4222:4222"  # NATS协议端口
      - "1883:1883"  # MQTT协议端口（如启用MQTT转换）
    volumes:
      - ./config:/etc/nats-gateway
      - ./data:/var/lib/nats-gateway
    environment:
      - NATS_GATEWAY_LOG_LEVEL=info
      - NATS_GATEWAY_CLUSTER_ID=prod-gateway-cluster
    command: --config /etc/nats-gateway/gateway.conf

配置文件说明

NATS Gateway支持YAML/JSON格式配置文件，典型配置示例（gateway.conf）：

yaml
# 网关基本配置
gateway:
  name: "prod-gateway-01"
  cluster_id: "${NATS_GATEWAY_CLUSTER_ID}"
  listen: "0.0.0.0:4222"
  http:
    listen: "0.0.0.0:8080"  # 管理API监听地址

# 连接的NATS集群配置
clusters:
  - name: "on-prem-cluster"
    url: "nats://nats-onprem:4222"
    credentials:
      user: "${ONPREM_USER}"
      password: "${ONPREM_PASSWORD}"
    jetstream:
      enabled: true
      domain: "onprem"

  - name: "cloud-cluster"
    url: "nats://nats-cloud:4222"
    token: "${CLOUD_TOKEN}"
    tls:
      enabled: true
      ca_file: "/etc/nats-gateway/tls/ca.crt"

# 路由规则配置
routes:
  - from_cluster: "on-prem-cluster"
    to_clusters: ["cloud-cluster"]
    subjects: ["orders.>", "inventory.>"]
    transform:
      subject: "gateway.${from_cluster}.${original_subject}"
      headers:
        add:
          gateway-source: "${from_cluster}"

  - from_cluster: "cloud-cluster"
    to_clusters: ["on-prem-cluster"]
    subjects: ["notifications.>"]
    filter:
      headers:
        required: ["x-allow-gateway"]

# 协议转换配置
protocols:
  mqtt:
    enabled: true
    listen: "0.0.0.0:1883"
    persistence:
      file: "/var/lib/nats-gateway/mqtt-state.db"
    mapping:
      - mqtt_topic: "devices/+/telemetry"
        nats_subject: "mqtt.devices.{{wildcard_0}}.telemetry"
        qos_mapping: "exact"

环境变量配置

常用环境变量说明：

管理与监控

NATS Gateway提供HTTP管理API，访问http://<gateway-ip>:8080可获取：

• 健康检查：GET /healthz
• 集群状态：GET /clusters
• 路由状态：GET /routes
• 配置重载：POST /config/reload（支持动态更新配置）
• 性能指标：GET /metrics（Prometheus格式）

注意事项

1. 网络配置：确保网关与目标NATS集群间网络互通，开放必要端口（默认NATS 4222、管理API 8080）。
2. 安全建议：生产环境中使用TLS加密集群连接，通过文件挂载管理敏感认证信息，避免环境变量暴露凭据。
3. 资源配置：高并发场景下建议调整容器CPU/内存限制（如--cpus=2 --memory=2G），并启用持久化存储保存协议状态。
4. 版本兼容性：使用与目标NATS集群版本匹配的网关镜像，避免协议版本不兼容问题。