在 go 框架中，限流和熔断期间的请求重试由 gobreaker 框架实现。重试机制可配置如下：retrythreshold：重试百分比阈值，当错误率超过此值时触发重试。retryinterval：重试时间间隔。retrymaxattempts：最大重试次数。

Go 框架中的限流和熔断期间的请求重试

背景

在高并发场景中，系统可能会遇到请求量激增或服务故障等情况，此时为了防止服务雪崩，需要引入限流和熔断机制。限流限制请求的并发量，熔断则在服务故障时迅速切断请求，防止流量持续涌入。

请求重试

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

当请求遇到限流或熔断时，客户端应采取重试机制，在一段时间后再次发送请求。重试可以提高请求的最终成功率，但过频繁的重试会给系统带来额外的压力。

Go 框架重试实现

在 Go 中，可以使用 github.com/sony/gobreaker 框架来实现限流和熔断功能。该框架提供了内置的重试机制：

import (
    "context"
    "errors"
    "fmt"
    "time"

    "github.com/sony/gobreaker"
)

var cb *gobreaker.CircuitBreaker

func init() {
    cb = gobreaker.NewCircuitBreaker(gobreaker.Settings{
        Name:             "MyService",
        Timeout:          10 * time.Second,
        MaxRequests:      10,
        Interval:         5 * time.Second,
        OnStateChanged:   logStateChange,
        RetryThreshold:   0.5,
        RetryHalfOpen:    true,
        ForceClosed:      true,
        RetryInterval:    1 * time.Second,
        RetryMaxAttempts: 3,
    })
}

func callService() error {
    ctx := context.Background()
    err := cb.Do(ctx, func() error {
        // 调用实际的服务
        return errors.New("internal error")
    })
    return err
}

重试机制配置了以下参数：

• RetryThreshold: 重试百分比阈值，当请求错误率超过该阈值时触发重试。
• RetryInterval: 重试时间间隔。
• RetryMaxAttempts: 最大重试次数。

实战案例

以下代码演示了请求限流和重试的实战案例：

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

    "github.com/gorilla/mux"
    "github.com/sony/gobreaker"
)

var cb *gobreaker.CircuitBreaker

func init() {
    cb = gobreaker.NewCircuitBreaker(gobreaker.Settings{
        Name: "MyService",
        Timeout: 10 * time.Second,
        MaxRequests: 10,
        Interval: 5 * time.Second,
        OnStateChanged: logStateChange,
        RetryEnabled: true,
        RetryThreshold: 0.5,
        RetryHalfOpen: true,
        ForceClosed: true,
        RetryInterval: 1 * time.Second,
        RetryMaxAttempts: 3,
    })
}

func handleRequest(w http.ResponseWriter, r *http.Request) {
    vars := mux.Vars(r)
    name := vars["name"]

    err := cb.Do(context.Background(), func() error {
        // 模拟服务调用，此处可能出现错误
        if name == "error" {
            return errors.New("internal error")
        }
        fmt.Fprintf(w, "Hello, %s!", name)
        return nil
    })

    if err != nil {
        fmt.Fprintf(w, "Error: %s", err)
    }
}

func main() {
    router := mux.NewRouter()
    router.HandleFunc("/hello/{name}", handleRequest)

    http.Handle("/", router)
    http.ListenAndServe(":8080", nil)
}

在这个示例中，当访问 /hello/error 路径时，服务会模拟出现内部错误并触发重试。当访问其他路径时，服务将正常返回问候语。

通过使用 gobreaker 框架，我们可以轻松地为 Go 应用程序实现限流和熔断功能，并自动处理请求重试，从而提高系统的鲁棒性和可用性。