Middle

tipas Response sąsaja {} tipas Backend sąsaja { Invoke(ctx: kontekstas, req: Request): Response, error } var _ Backend = &BackendImpl{} // addr nurodo konkretaus pavyzdžio ip:port adresą func NewBackend(addr: string) BackendImpl tipas Balancer struktūra { // TODO backends []BackendImpl index int mu sync.Mutex } var _ Backend = &Balancer{} func (b Balancer) Invoke(ctx: kontekstas, req: Request) (Response, error) { jei len(b.backends) == 0 { grąžinti nil, fmt.Errorf("Backends skaičius masyve yra 0") } b.mu.Lock() index := b.index jei b.index + 1 == len(b.backends) { b.index = 0 index = 0 } b.mu.Unlock() resp, err := b.backends[index].Invoke(ctx, req) grąžinti resp, err } // addrs apima visų balansuotų pavyzdžių adresus func NewBalancer(addrs []string) Balancer { // TODO backends := make([]*BackendImpl, len(addrs))

sobes.tech AI

Atsakymas iš AI

В представленном коде балансировщик (Balancer) реализует интерфейс Backend и распределяет вызовы между несколькими экземплярами BackendImpl по кругу (round-robin).

В методе Invoke есть ошибка в логике обновления индекса:

b.mu.Lock()
index := b.index
if b.index + 1 == len(b.backends) {
    b.index = 0
    index = 0
}
b.mu.Unlock()

Здесь b.index не увеличивается, а только сбрасывается в 0, из-за чего всегда выбирается первый backend.

Правильная реализация должна:

Зафиксировать текущий индекс
Увеличить b.index с переходом на 0 при достижении конца слайса

Пример исправления:

b.mu.Lock()
index := b.index
b.index = (b.index + 1) % len(b.backends)
b.mu.Unlock()

resp, err := b.backends[index].Invoke(ctx, req)
return resp, err

Также в функции NewBalancer нужно инициализировать слайс backends и заполнить его экземплярами BackendImpl по адресам из addrs:

func NewBalancer(addrs []string) *Balancer {
    backends := make([]*BackendImpl, len(addrs))
    for i, addr := range addrs {
        backends[i] = NewBackend(addr)
    }
    return &Balancer{
        backends: backends,
    }
}

Таким образом, балансировщик корректно распределит запросы по backend-экземплярам в круговом порядке.

Ankstesnis Kitas