/* C'è un'applicazione con architettura a microservizi. Un microservizio può essere astratto tramite l'interfaccia Backend. Per accedere a un'istanza del microservizio, si può usare il tipo BackendImpl, che è già implementato. Ogni microservizio ha diverse decine di istanze in esecuzione, ognuna accessibile tramite il proprio indirizzo addr. Tuttavia, le singole istanze del microservizio non sono affidabili: potrebbero fallire, essere inaccessibili o sovraccariche. Per questo, devi implementare un tipo Balancer, che implementa anche l'interfaccia Backend e effettua il bilanciamento del carico lato client tra le istanze del microservizio, scegliendo ogni volta l'istanza **meno caricata**. */

Для реализации типа Balancer, который реализует интерфейс Backend и выбирает наименее нагруженный экземпляр микросервиса, можно использовать следующий подход:

1. Хранить список BackendImpl с их адресами и текущей нагрузкой.
2. При каждом вызове метода Backend выбирать экземпляр с минимальной нагрузкой.
3. Обновлять информацию о нагрузке после каждого запроса (например, увеличивать счетчик активных запросов и уменьшать после завершения).

Пример на Go:

package main

import (
    "errors"
    "sync"
)

// Backend интерфейс микросервиса
type Backend interface {
    DoRequest() error
}

// BackendImpl - конкретный экземпляр микросервиса
// В реальности здесь будет реализация обращения по адресу addr
// Для примера просто имитируем

type BackendImpl struct {
    addr string
}

func (b *BackendImpl) DoRequest() error {
    // Реализация запроса к микросервису
    return nil
}

// Balancer реализует Backend и балансирует нагрузку

type Balancer struct {
    backends []*backendWithLoad
    mu       sync.Mutex
}

type backendWithLoad struct {
    backend Backend
    load    int // количество активных запросов
}

func NewBalancer(addrs []string) *Balancer {
    b := &Balancer{}
    for _, addr := range addrs {
        b.backends = append(b.backends, &backendWithLoad{
            backend: &BackendImpl{addr: addr},
            load:    0,
        })
    }
    return b
}

func (b *Balancer) DoRequest() error {
    b.mu.Lock()
    // Найти backend с минимальной нагрузкой
    var selected *backendWithLoad
    minLoad := int(^uint(0) >> 1) // макс int
    for _, be := range b.backends {
        if be.load < minLoad {
            minLoad = be.load
            selected = be
        }
    }
    if selected == nil {
        b.mu.Unlock()
        return errors.New("no backends available")
    }
    selected.load++
    b.mu.Unlock()

    // Выполнить запрос
    err := selected.backend.DoRequest()

    // После завершения уменьшить нагрузку
    b.mu.Lock()
    selected.load--
    b.mu.Unlock()

    return err
}

Такой подход позволяет клиенту балансировать нагрузку между экземплярами, выбирая наименее загруженный в момент запроса. Для более точного учета нагрузки можно использовать метрики из самих сервисов или учитывать время отклика.