Senior

Да предположим, че нашият микросервис трябва да достъпва външно API, например платежен шлюз, но то внезапно започва да се забавя силно или изобщо пада. Как обикновено защитаваш приложението си от такива съседи, за да не падне цялата ни услуга?

sobes.tech AI

Отговор от AI

Чтобы защитить микросервис от зависимостей, которые могут тормозить или падать (например, внешнее API платежной системы), обычно применяют следующие подходы:

Таймауты и ретраи — задавать разумные таймауты на запросы и ограниченное число повторных попыток.
Circuit Breaker (автоматический выключатель) — если внешний сервис часто падает или отвечает медленно, circuit breaker временно блокирует вызовы к нему, чтобы не нагружать систему и не ждать долго.
Bulkhead (отсекатель) — изолировать ресурсы, выделяя отдельные пулы потоков или горутин для вызовов к внешнему сервису, чтобы сбой не распространялся.
Fallback (запасной вариант) — при недоступности внешнего сервиса возвращать заранее подготовленные данные или заглушки.
Мониторинг и алерты — отслеживать состояние вызовов и быстро реагировать.

В Go для реализации circuit breaker и таймаутов часто используют библиотеки вроде github.com/sony/gobreaker или github.com/afex/hystrix-go.

Пример с таймаутом и circuit breaker:

import (
    "context"
    "net/http"
    "time"

    "github.com/sony/gobreaker"
)

var cb *gobreaker.CircuitBreaker

func init() {
    cb = gobreaker.NewCircuitBreaker(gobreaker.Settings{
        Name:        "PaymentAPI",
        MaxRequests: 5,
        Interval:    60 * time.Second,
        Timeout:     30 * time.Second,
        ReadyToTrip: func(counts gobreaker.Counts) bool {
            return counts.ConsecutiveFailures > 3
        },
    })
}

func callPaymentAPI(ctx context.Context, url string) (*http.Response, error) {
    result, err := cb.Execute(func() (interface{}, error) {
        req, _ := http.NewRequestWithContext(ctx, "GET", url, nil)
        client := &http.Client{
            Timeout: 5 * time.Second, // таймаут на запрос
        }
        return client.Do(req)
    })

    if err != nil {
        // fallback или обработка ошибки
        return nil, err
    }

    return result.(*http.Response), nil
}

Таким образом, при проблемах с внешним сервисом наш микросервис не зависнет и сможет корректно обработать ситуацию.

Предишни Следващият