magneticio/vamp-gateway-agent

Vamp Gateway Agent

基于HAProxy的网关代理，可从ZooKeeper、etcd或Consul获取配置并自动重载，同时支持日志推送至Logstash，确保服务高可用性。

![Build Status]([] ![Download ]([]

镜像概述

Vamp Gateway Agent整合HAProxy（TCP/HTTP负载均衡器）与分布式配置存储（ZooKeeper、etcd、Consul），实现配置动态更新与服务高可用。它自动读取存储中的HAProxy配置并重载，处理存储或Logstash故障时不中断客户端请求。

核心功能

1. 动态配置重载：从ZooKeeper/etcd/Consul读取配置，变更时自动重载HAProxy，最小化请求中断。
2. 日志推送：通过Socket读取HAProxy日志，经UDP推送到Logstash。
3. 故障恢复：应对存储或Logstash outage，不中断HAProxy进程与客户端请求。
4. 自定义配置：支持指定基础配置，存储中的配置会追加到基础配置中使用。

使用场景

• 微服务架构中需动态更新负载均衡配置的网关场景。
• 日志集中化管理需求，将HAProxy日志统一推送至Logstash分析。
• 高可用服务场景，确保配置存储或日志系统故障时服务持续运行。

配置说明

命令行参数

运行时可通过参数调整代理行为：

Usage of ./vamp-gateway-agent:
  -configurationBasicFile string
        基础HAProxy配置文件（默认："haproxy.basic.cfg"）
  -configurationPath string
        HAProxy配置路径（默认："/usr/local/vamp/"）
  -debug
        开启额外日志输出
  -help
        打印帮助信息
  -logo
        显示logo（默认：true）
  -logstash string
        Logstash UDP地址（格式：host:port），为空则禁用日志推送（默认："127.0.0.1:10001"）
  -retryTimeout int
        默认重试超时（秒，默认：5）
  -scriptPath
        HAProxy验证与重载脚本路径（默认："/usr/local/vamp/"）
  -storeConnection string
        键值存储连接字符串
  -storeKey string
        HAProxy配置在存储中的键（默认："/vamp/gateways/haproxy/1.6"）
  -storeType string
        存储类型：zookeeper、consul或etcd

Logstash配置示例

input {
  udp {
    port => 10001
    type => haproxy
  }
}

filter {
  grok {
    match => ["message", "^.+?]: (?<metrics>{.*})$"]
    match => ["message", "^.*$"]
  }
  if [metrics] =~ /.+/ {
    json {
      source => "metrics"
    }
    if [t] =~ /.+/ {
      date {
        match => ["t", "dd/MMM/YYYY:HH:mm:ss.SSS"]
      }
    }
  }
}

output {
  elasticsearch {
    hosts => "elasticsearch:9200"
  }
  stdout {
    codec => rubydebug
  }
}

注意：Logstash配置依赖HAProxy日志配置，该配置需从分布式存储获取。

Docker部署示例

基础运行

bash
docker run --net=host --restart=always magneticio/vamp-gateway-agent:0.9.1

自定义参数运行（示例）

bash
docker run --net=host --restart=always magneticio/vamp-gateway-agent:0.9.1 \
  -storeType consul \
  -storeConnection "consul:8500" \
  -logstash "logstash:***"