4. 蓝绿发布拓扑：蓝绿部署概念、蓝绿拓扑结构、流量切换机制、Go后端实现要点

4.1 蓝绿部署概念

蓝绿部署（Blue-Green Deployment）是一种零停机、快速切换的发布策略。其核心思想是维护两套完全独立的生产环境——蓝环境（Blue）和绿环境（Green），在任何时刻只有一套环境承载真实用户流量，另一套环境保持空闲或用于新版本验证。

4.2 蓝绿拓扑结构

蓝绿部署的拓扑结构通常由负载均衡器、两套独立的应用集群以及共享的数据层组成。负载均衡器是流量切换的“开关”，两套集群在物理或逻辑上完全隔离，避免环境间相互干扰。

4.3 流量切换机制

流量切换是蓝绿部署的核心操作，分为手动切换和自动切换两种模式。切换的本质是修改负载均衡器的上游服务器组，将流量从旧环境全部导向新环境。

4.3.1 切换流程

1. 预检查：确认新环境（Green）健康检查通过、业务指标正常。
2. 切换：修改负载均衡配置，将流量 100% 指向 Green 环境。
3. 观察：监控错误率、延迟、业务量，观察窗口通常为 5-30 分钟。
4. 确认/回滚：若正常，保留 Blue 环境作为回滚备用；若异常，立即切回 Blue。

4.4 Go后端实现要点

在 Go 后端实现蓝绿部署，主要关注优雅启停、健康检查端点、连接池预热和指标暴露四个要点。

4.4.1 优雅启停（Graceful Shutdown）

切换流量前，旧环境需要优雅关闭，新环境需要平滑启动。Go 1.8+ 的 http.Server 原生支持 Shutdown() 方法。

package main

import (
    "context"
    "log"
    "net/http"
    "os"
    "os/signal"
    "syscall"
    "time"
)

func main() {
    mux := http.NewServeMux()
    mux.HandleFunc("/health", healthHandler)
    mux.HandleFunc("/api", apiHandler)

    srv := &http.Server{
        Addr:    ":8080",
        Handler: mux,
    }

    // 启动服务
    go func() {
        log.Printf("Server starting on :8080")
        if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
            log.Fatalf("listen: %s\n", err)
        }
    }()

    // 等待中断信号
    quit := make(chan os.Signal, 1)
    signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
    <-quit
    log.Println("Shutting down server...")

    // 优雅关闭：等待现有请求完成，最多 30 秒
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()
    if err := srv.Shutdown(ctx); err != nil {
        log.Fatalf("Server forced to shutdown: %v", err)
    }
    log.Println("Server exited gracefully")
}

4.4.2 健康检查端点

负载均衡器通过健康检查判断实例是否可用。Go 服务应提供 /health 端点，返回 200 状态码并包含依赖状态。

func healthHandler(w http.ResponseWriter, r *http.Request) {
    // 检查数据库连接、缓存等依赖
    dbOK := checkDB()
    cacheOK := checkCache()

    if dbOK && cacheOK {
        w.WriteHeader(http.StatusOK)
        w.Write([]byte(`{"status":"healthy"}`))
    } else {
        w.WriteHeader(http.StatusServiceUnavailable)
        w.Write([]byte(`{"status":"unhealthy"}`))
    }
}

4.4.3 连接池预热

新环境启动后，数据库连接池、HTTP 连接池需要预热，避免切换瞬间大量请求因连接未建立而超时。

func warmUpPool(db *sql.DB, targetSize int) {
    // 预热连接池到目标大小
    db.SetMaxOpenConns(targetSize)
    for i := 0; i < targetSize; i++ {
        go func() {
            conn, err := db.Conn(context.Background())
            if err != nil {
                log.Printf("warmup conn error: %v", err)
                return
            }
            conn.Close()
        }()
    }
    // 等待连接建立
    time.Sleep(2 * time.Second)
}

4.4.4 指标暴露

暴露 Prometheus 指标，用于切换前后的对比监控。

import "github.com/prometheus/client_golang/prometheus/promhttp"

func main() {
    http.Handle("/metrics", promhttp.Handler())
    // 注册自定义指标：请求数、错误率、延迟
    http.ListenAndServe(":9090", nil)
}