4. API网关设计

API网关是微服务架构的流量入口，承担着请求路由、安全认证、流量控制和协议转换等职责。本章从网关核心功能出发，使用Gin框架实现一个轻量级基础网关，并探讨网关与业务服务的通信模式。

4.1 网关核心功能矩阵

一个生产级API网关至少需要具备以下三大核心能力：

4.2 使用Gin实现基础网关

Gin框架的高性能和中间件机制使其成为构建Go网关的理想选择。以下是一个包含路由分发和限流熔断的基础网关实现。

4.2.1 网关架构分层

4.2.2 核心代码实现

1. 网关初始化与路由注册

package gateway

import (
    "github.com/gin-gonic/gin"
    "time"
)

// Gateway 网关核心结构
type Gateway struct {
    engine *gin.Engine
    cfg    *Config
}

// Config 网关配置
type Config struct {
    ListenAddr    string        // 监听地址
    ReadTimeout   time.Duration // 读取超时
    WriteTimeout  time.Duration // 写入超时
    MaxHeaderSize int           // 最大请求头大小
}

// NewGateway 创建网关实例
func NewGateway(cfg *Config) *Gateway {
    gin.SetMode(gin.ReleaseMode)
    engine := gin.New()

    // 注册全局中间件
    engine.Use(gin.Recovery())
    engine.Use(NewRateLimiter(100, 200)) // 限流：100rps，突发200
    engine.Use(NewCircuitBreaker(0.5, 10, 5*time.Second)) // 熔断：50%错误率触发

    return &Gateway{
        engine: engine,
        cfg:    cfg,
    }
}

// RegisterRoute 注册业务服务路由
func (g *Gateway) RegisterRoute(prefix string, target string) {
    group := g.engine.Group(prefix)
    // 反向代理处理器
    group.Any("/*path", ReverseProxyHandler(target))
}

// Start 启动网关
func (g *Gateway) Start() error {
    srv := &http.Server{
        Addr:         g.cfg.ListenAddr,
        Handler:      g.engine,
        ReadTimeout:  g.cfg.ReadTimeout,
        WriteTimeout: g.cfg.WriteTimeout,
    }
    return srv.ListenAndServe()
}

2. 限流中间件（令牌桶实现）

// NewRateLimiter 基于令牌桶的限流中间件
func NewRateLimiter(rate int, burst int) gin.HandlerFunc {
    limiter := rate.NewLimiter(rate.Limit(rate), burst)
    return func(c *gin.Context) {
        if !limiter.Allow() {
            c.AbortWithStatusJSON(429, gin.H{
                "code":    429,
                "message": "too many requests",
            })
            return
        }
        c.Next()
    }
}

3. 熔断中间件（滑动窗口计数）

// NewCircuitBreaker 熔断中间件
func NewCircuitBreaker(errorRate float64, minRequests int, timeout time.Duration) gin.HandlerFunc {
    cb := &circuitBreaker{
        state:       stateClosed,
        errorRate:   errorRate,
        minRequests: minRequests,
        timeout:     timeout,
        lastState:   time.Now(),
    }
    return func(c *gin.Context) {
        if !cb.allowRequest() {
            c.AbortWithStatusJSON(503, gin.H{
                "code":    503,
                "message": "service unavailable, circuit breaker open",
            })
            return
        }
        c.Next()
        // 记录请求结果
        cb.recordResult(c.Writer.Status() >= 500)
    }
}

4.3 网关与业务服务通信模式

网关与下游业务服务之间的通信模式直接影响系统的延迟、可靠性和可维护性。以下是三种主流通信模式对比：

4.3.1 HTTP反向代理模式（最常用）

Gin网关通过httputil.ReverseProxy将请求透明转发到下游服务，支持请求头传递、路径重写和负载均衡。

// ReverseProxyHandler 创建反向代理处理器
func ReverseProxyHandler(target string) gin.HandlerFunc {
    url, _ := url.Parse(target)
    proxy := httputil.NewSingleHostReverseProxy(url)

    // 自定义Director：修改请求路径和头信息
    proxy.Director = func(req *http.Request) {
        req.URL.Scheme = url.Scheme
        req.URL.Host = url.Host
        req.URL.Path = strings.TrimPrefix(req.URL.Path, "/api/v1")
        // 传递原始客户端IP
        req.Header.Set("X-Forwarded-For", req.RemoteAddr)
        req.Header.Set("X-Real-IP", req.RemoteAddr)
    }

    // 自定义错误处理
    proxy.ErrorHandler = func(w http.ResponseWriter, r *http.Request, err error) {
        log.Printf("proxy error: %v", err)
        w.WriteHeader(http.StatusBadGateway)
        w.Write([]byte(`{"code":502,"message":"upstream service unavailable"}`))
    }

    return func(c *gin.Context) {
        proxy.ServeHTTP(c.Writer, c.Request)
    }
}

4.3.2 gRPC转码模式（高性能场景）

对于内部服务间通信，gRPC提供更低的延迟和更强的类型约束。网关通过grpc-gateway将HTTP请求转码为gRPC调用。

// GrpcProxyHandler gRPC转码处理器
func GrpcProxyHandler(conn *grpc.ClientConn) gin.HandlerFunc {
    // 使用grpc-gateway的mux
    mux := runtime.NewServeMux()
    // 注册服务（以UserService为例）
    pb.RegisterUserServiceHandler(context.Background(), mux, conn)

    return func(c *gin.Context) {
        mux.ServeHTTP(c.Writer, c.Request)
    }
}

4.4 网关高可用部署架构

生产环境中，网关通常以无状态集群方式部署，前端通过负载均衡器（如Nginx/HAProxy）分发流量。以下是推荐的部署拓扑：

• 多副本部署：至少2个网关实例，避免单点故障
• 健康检查：网关暴露/health端点，负载均衡器定期探测
• 配置中心：路由规则、限流阈值等配置存储在Etcd/Consul，网关启动时拉取并监听变更
• 优雅关闭：捕获SIGTERM信号，等待正在处理的请求完成后再退出

4.5 本章小结

API网关是微服务架构的流量枢纽，其设计质量直接影响整个系统的稳定性与可扩展性。本章核心要点：

• 网关三大核心功能：路由（请求分发）、限流（流量控制）、熔断（故障隔离）
• 使用Gin框架可以快速构建高性能网关，中间件链模式天然支持功能扩展
• 通信模式选择：HTTP反向代理适合通用场景，gRPC转码适合内部高性能调用，消息队列适合异步解耦
• 生产部署需关注多副本、健康检查、配置中心和优雅关闭等运维要点