使用 golang 框架中的熔断模式保护后端服务，以防止故障导致的服务调用失败和资源浪费。框架提供开箱即用的熔断功能，如 net/http/httputil，允许配置失败阈值和恢复时间等熔断器设置。通过包装 http 客户端并使用熔断器，当后端服务不可用时，可以快速禁用服务，避免持续调用失败的依赖项，从而保护后端服务。

使用 Golang 框架中的熔断模式保护后端服务

介绍

熔断模式是一种常用技术，用于保护后端服务免受故障的负面影响。它通过在服务不可用时将其迅速禁用，从而避免服务持续调用失败的依赖项，从而造成资源浪费和性能下降。

Go 中的熔断模式

在 Golang 中，有几个框架提供了开箱即用的熔断功能。其中一个流行的框架是 net/http/httputil。

实战案例

以下代码示例演示了如何使用 httputil 框架在 Golang 中实现熔断模式：

立即学习“go语言免费学习笔记（深入）”；

package main

import (
    "fmt"
    "net/http"
    "time"

    "<a style='color:#f60; text-decoration:underline;' href="https://www.php.cn/zt/15841.html" target="_blank">git</a>hub.com/go-kit/kit/circuitbreaker"
    "github.com/go-kit/kit/log"
    "github.com/go-kit/kit/tracing/opentracing"
    httptransport "github.com/go-kit/kit/transport/http"
    "github.com/opentracing/opentracing-go"
)

func main() {
    logger := log.NewLogfmtLogger(log.NewSyncWriter(os.Stdout))
    tracer := opentracing.GlobalTracer()

    // 设置熔断配置
    cb := circuitbreaker.New(cb.WithMaxFailures(3))
    wrappedHTTPClient := cb.Wrap(http.DefaultClient)

    // 创建 HTTP 传输
    transport := httptransport.NewClient(
        "GET",
        "http://localhost:8080",
        wrappedHTTPClient,
        opentracing.ClientTrace(tracer),
    )

    // 创建端点
    endpoint := httptransport.NewServer(
        transport,
        decodeRequest,
        encodeResponse,
        opentracing.ServerTrace(tracer),
    )

    // 创建 HTTP 处理程序
    handler := httptransport.NewServer(
        endpoint,
        decodeRequest,
        encodeResponse,
    )

    // 启动 HTTP 服务器
    srv := &http.Server{
        Addr:    ":8080",
        Handler: handler,
    }

    logger.Log("msg", "HTTP 服务器已启动")
    err := srv.ListenAndServe()
    if err != nil {
        logger.Log("err", err)
        return
    }
}

func decodeRequest(r *http.Request) (interface{}, error) {
    return nil, nil
}

func encodeResponse(w http.ResponseWriter, r interface{}) error {
    w.Header().Set("Content-Type", "application/json")
    fmt.Fprint(w, "Hello, World!")
    return nil
}

在上面的示例中：

• circuitbreaker.New 创建了一个新的熔断器，配置为最多允许 3 次失败。
• httputil.Wrap 使用熔断器包装底层 HTTP 客户端。
• cb.Wrap 返回一个包装后的 HTTP 客户端，当后端服务不可用时，它将触发熔断。
• httptransport.NewClient 使用包装后的 HTTP 客户端创建一个新的 HTTP 传输。
• opentracing.ClientTrace 用于跟踪客户端请求。
• opentracing.ServerTrace 用于跟踪服务器响应。

在实际使用中，您需要根据您的特定需求调整熔断器的配置，例如失败阈值和恢复时间。