byrnedo/stan-http-forwarder

STAN HTTP Forwarder镜像

镜像概述

该镜像提供一个轻量级服务，用于将Nats-Streaming队列主题中的消息转发至指定HTTP端点。它具备简洁的代码结构和少量依赖，适用于事件驱动架构中的消息转发场景。

核心功能

• 轻量化：依赖少、代码简洁，资源占用低。
• 速率限制：对HTTP端点请求进行速率控制，防止意外请求 spam。
• 自定义头部：支持为每个HTTP端点设置自定义请求头。
• 消息保证：策略设为ack时，仅当HTTP响应状态码在健康列表中，才向Nats-Streaming确认消息。

使用场景

• 微服务间通过Nats-Streaming传递消息后触发HTTP回调的场景。
• 事件驱动系统中，将队列消息转换为HTTP请求的场景。
• 需要对HTTP转发请求进行速率控制的场景。

配置说明

主要配置参数（通过环境变量设置）：

• NATS_URL：Nats-Streaming服务地址。
• STAN_CLUSTER_ID：Nats-Streaming集群ID。
• STAN_CLIENT_ID：客户端ID。
• SUBJECT：订阅的Nats主题。
• ENDPOINT：目标HTTP端点地址。
• STRATEGY：消息确认策略（如ack）。
• HEALTHY_STATUS：健康状态码列表（如200,201）。
• RATE_LIMIT：速率限制（如10/second）。

部署示例

Docker Run命令

bash
docker run -d \
  -e NATS_URL=nats://nats:4222 \
  -e STAN_CLUSTER_ID=my-cluster \
  -e STAN_CLIENT_ID=forwarder-1 \
  -e SUBJECT=my-topic \
  -e ENDPOINT=http://my-service/api/webhook \
  -e STRATEGY=ack \
  -e HEALTHY_STATUS=200,201 \
  -e RATE_LIMIT=5/second \
  byrnedo/stan-http-forwarder

Docker Compose示例

yaml
version: '3'
services:
  stan-forwarder:
    image: byrnedo/stan-http-forwarder
    environment:
      NATS_URL: nats://nats:4222
      STAN_CLUSTER_ID: my-cluster
      STAN_CLIENT_ID: forwarder-1
      SUBJECT: my-topic
      ENDPOINT: [***]
      STRATEGY: ack
      HEALTHY_STATUS: 200,201
      RATE_LIMIT: 5/second
    depends_on:
      - nats
  nats:
    image: nats-streaming:latest
    ports:
      - "4222:4222"