微服务稳定性三板斧：熔断、限流与负载均衡全面解析（附 Hystrix-Go 实战代码）

# 拉取官方镜像docker pull mlabouardy/hystrix-dashboard:latest
# 启动控制面板docker run -d -p 9002:9002 --name hystrix-dashboard mlabouardy/hystrix-dashboard:latest

go get github.com/afex/hystrix-go/hystrix

package main
import (    "log"    "net"    "net/http"        "github.com/afex/hystrix-go/hystrix")
func main() {    // 配置熔断器参数    hystrix.ConfigureCommand("service_call", hystrix.CommandConfig{        Timeout:                int(5 * 1000), // 5秒超时        MaxConcurrentRequests:  100,           // 最大并发请求数        SleepWindow:           int(10 * 1000), // 熔断后的恢复时间窗口        RequestVolumeThreshold: 20,            // 请求量阈值        ErrorPercentThreshold:  50,            // 错误率阈值    })        // 创建熔断器监控流处理器    hystrixStreamHandler := hystrix.NewStreamHandler()    hystrixStreamHandler.Start()        // 启动监控端口    go func() {        err := http.ListenAndServe(net.JoinHostPort("0.0.0.0", "9096"), hystrixStreamHandler)        if err != nil {            log.Error(err)        }    }()        // 实际业务逻辑    http.HandleFunc("/api/user", func(w http.ResponseWriter, r *http.Request) {        // 使用熔断器包装业务调用        err := hystrix.Do("service_call", func() error {            // 这里是实际的服务调用逻辑            return callUserService()        }, func(err error) error {            // 降级逻辑：当服务不可用时的备用方案            w.Write([]byte("Service temporarily unavailable, please try again later"))            return nil        })                if err != nil {            http.Error(w, err.Error(), http.StatusInternalServerError)        }    })        log.Println("Server starting on :8080")    log.Fatal(http.ListenAndServe(":8080", nil))}
func callUserService() error {    // 模拟实际的服务调用    // 这里可能是 HTTP 请求、gRPC 调用等    return nil}