golang框架限流和熔断在分布式系统中的应用

资讯主编 Go

2024-08-11 0 420

分布式系统中限流和熔断机制至关重要，go 框架提供了广泛的实现机制。限流旨在防止过载，例如限制每秒 HTTP 请求数量。熔断则在服务失败或响应时间过长时，暂时阻止对服务的访问，以避免级联故障。

Go 框架限流和熔断在分布式系统中的应用

在现代分布式系统中，限流和熔断机制对于确保系统稳定性和弹性至关重要。Go 语言提供了广泛的框架来简化这些机制的实现。

限流

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

限流机制旨在防止系统因过载而崩溃。

import (
    "context"
    "Github.com/golang/groupcache/lru"
    "time"
)

// limitRequests 限制每秒请求
func LimitRequests(ctx context.Context, maxRequests, d time.Duration) (func(), error) {
    l := lru.New(maxRequests)

    go func() {
        for {
            time.Sleep(d)
            l.Purge()
        }
    }()

    return func() bool {
        return l.Add(0, nil) != nil
    }, nil
}

实战示例：

使用限流来限制每秒处理的 HTTP 请求数量：

import (
    "github.com/buaazp/fasthttprouter"
    "time"
)

func main() {
    limiter, err := LimitRequests(context.Background(), 10, time.Second)
    if err != nil {
        log.Fatal(err)
    }

    router := fasthttprouter.New()
    router.GET("/", func(ctx *fasthttp.RequestCtx) {
        if limiter() {
            ctx.Error("Too many requests", fasthttp.StatusTooManyRequests)
            return
        }
        // 处理请求...
    })
    server.ListeNANDServe(":8080")
}

熔断

熔断机制旨在在服务失败或响应时间过长时暂时阻止对服务的访问。

import (
    "context"
    "errors"
    "sync"
    "time"
)

// CircuitBreaker 熔断器
type CircuitBreaker struct {
    sync.Mutex
    state     State
    closEDAt  time.Time
    failedReq int
    successReq int
}

// State 熔断状态
type State int

const (
    Closed State = iota
    HalfOpen
    Open
)

// TrIP 熔断
func (cb *CircuitBreaker) Trip() {
    cb.Lock()
    defer cb.Unlock()
    cb.failedReq++
    cb.state = Open
    cb.closedAt = time.now().Add(time.Minute)
}

// Close 关闭熔断
func (cb *CircuitBreaker) Close() {
    cb.Lock()
    defer cb.Unlock()
    cb.state = Closed
    cb.closedAt = time.Now()
}

// Allow 通过请求
func (cb *CircuitBreaker) Allow() error {
    cb.Lock()
    defer cb.Unlock()

    now := time.Now()

    if cb.state == Open && cb.closedAt.After(now) {
        return errors.New("circuit open")
    }

    if cb.state == HalfOpen {
        cb.state = Closed
        cb.successReq++
    }

    return nil
}

实战示例：

使用熔断器来保护对外部服务的调用：

import (
    "errors"
    "time"

    "github.com/sony/gobreaker"
    "github.com/uber/jaeger-client-go"
)

var (
    jaegerCloser jaeger.Closer
    cb           = gobreaker.NewCircuitBreaker(gobreaker.Settings{
        // 连续请求失败才会熔断
        Interval: 10 * time.Second,
    })
    fallbackcallCount int
)

func MakeRemoteCall() (string, error) {
    err := cb.Execute(func() (string, error) {
        return "some result", nil
    })
    if err != nil {
        fallbackCallCount++
        return "fallback result", nil
    }

    return "result", nil
}

登录后复制

收藏 (0) 打赏

感谢您的支持，我会继续努力的!

打开微信/支付宝扫一扫，即可进行扫码打赏哦，分享从这里开始，精彩与您同在

免责声明
1. 本站所有资源来源于用户上传和网络等，如有侵权请邮件联系本站整改team@lcwl.fun！
2. 分享目的仅供大家学习和交流，您必须在下载后24小时内删除！
3. 不得使用于非法商业用途，不得违反国家法律。否则后果自负！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！
5. 如有链接无法下载、失效或广告，请联系本站工作人员处理！
6. 本站资源售价或VIP只是赞助，收取费用仅维持本站的日常运营所需！
7. 如遇到加密压缩包，请使用WINRAR解压，如遇到无法解压的请联系管理员！
8. 因人力时间成本问题，部分源码未能详细测试（解密），不能分辨部分源码是病毒还是误报，所以没有进行任何修改，大家使用前请进行甄别！
9.本站所有源码资源都是经过本站工作人员人工亲测可搭建的，保证每个源码都可以正常搭建，但不保证源码内功能都完全可用，源码属于可复制的产品，无任何理由退款！

网站搭建学习网 Go golang框架限流和熔断在分布式系统中的应用 https://www.xuezuoweb.com/11201.html