3. 中间件概念与分类：中间件定义、Go Web中间件模式、HTTP中间件、RPC中间件、消息中间件

3.1 中间件定义与核心价值

在分布式系统与微服务架构中，中间件（Middleware） 是指位于操作系统与应用之间、或位于不同服务之间的一层独立软件实体。它屏蔽底层异构性，为上层提供统一的通信、数据交换与治理能力。

3.2 Go Web 中间件模式

Go 标准库 net/http 定义了 http.Handler 接口，这是所有 Web 中间件的根基。中间件本质是一个接收 http.Handler 并返回新的 http.Handler 的函数。

// 标准中间件签名
type Middleware func(http.Handler) http.Handler

// 示例：日志中间件
func LoggingMiddleware(next http.Handler) http.Handler {
    return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
        start := time.Now()
        log.Printf("[%s] %s %s", r.Method, r.RequestURI, r.RemoteAddr)
        next.ServeHTTP(w, r)
        log.Printf("[%s] completed in %v", r.Method, time.Since(start))
    })
}

// 链式组合
handler := LoggingMiddleware(AuthMiddleware(RecoveryMiddleware(mux)))

3.3 HTTP 中间件

HTTP 中间件是 Go Web 框架中最常见的中间件形态。它工作在 HTTP 请求/响应层面，主要处理 协议头、状态码、请求体、响应体 等协议级数据。

// 超时中间件示例
func TimeoutMiddleware(timeout time.Duration) Middleware {
    return func(next http.Handler) http.Handler {
        return http.TimeoutHandler(next, timeout, "request timeout")
    }
}

// 限流中间件（基于令牌桶）
func RateLimitMiddleware(rate int, burst int) Middleware {
    limiter := rate.NewLimiter(rate.Limit(rate), burst)
    return func(next http.Handler) http.Handler {
        return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
            if !limiter.Allow() {
                http.Error(w, "too many requests", http.StatusTooManyRequests)
                return
            }
            next.ServeHTTP(w, r)
        })
    }
}

3.4 RPC 中间件

在微服务间通信中，RPC（gRPC、Thrift、自研 RPC）中间件作用于 服务调用链路。与 HTTP 中间件不同，RPC 中间件通常以 拦截器（Interceptor） 形式存在，分为客户端拦截器和服务端拦截器。

// gRPC 服务端一元拦截器示例
func UnaryServerLogInterceptor(ctx context.Context, req interface{},
    info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
    log.Printf("[gRPC] method=%s, request=%+v", info.FullMethod, req)
    resp, err := handler(ctx, req)
    log.Printf("[gRPC] method=%s, response=%+v, err=%v", info.FullMethod, resp, err)
    return resp, err
}

// 注册到 gRPC 服务
grpcServer := grpc.NewServer(
    grpc.UnaryInterceptor(UnaryServerLogInterceptor),
)

3.5 消息中间件

消息中间件（Message Queue / Message Broker）是微服务异步通信的核心基础设施。它解耦生产者和消费者，提供削峰填谷、异步解耦、广播通知等能力。Go 生态中常用的消息中间件包括 Kafka、RabbitMQ、NATS、Redis Streams 等。

// 使用 NATS 实现发布/订阅（Go 示例）
import "github.com/nats-io/nats.go"

// 发布者
func publishEvent(nc *nats.Conn, subject string, data []byte) error {
    return nc.Publish(subject, data)
}

// 订阅者
func subscribeEvent(nc *nats.Conn, subject string, handler func(msg *nats.Msg)) {
    nc.Subscribe(subject, handler)
}

// 使用 Kafka 生产消息（segmentio/kafka-go）
writer := kafka.NewWriter(kafka.WriterConfig{
    Brokers: []string{"localhost:9092"},
    Topic:   "order-events",
})
writer.WriteMessages(context.Background(),
    kafka.Message{Key: []byte("order-123"), Value: []byte(`{"status":"created"}`)},
)

3.6 三种中间件对比与选型