VY
штуки три минимум
Size: a a a
2021 June 17
VY
(я лично их избегаю)
АК
и не обязательно они в докере еще, верно?
АК
все, дошло
АК
спасибо.
VY
без разницы, даже если в докере но на другом сервере - все проблемы реальной сети будут иметь место
АК
Подумаю тогда как канал пересоздавать и обновлять в структуре
VY
у некоторых либ автореконнект есть вроде
VY
надо смотреть
Н
канал вроде нигде не пересоздается автоматом, даже в случае реконнекта
АК
То есть такой вариант не совсем верен и помимо этого нужно здесь еще и очереди пересоздать?
type RabbitClient struct {
ch *amqp.Channel
}
func (r *RabbitClient) UpdateChannel() error {
conn, err := amqp.Dial("amqp://guest:guest@rabbitsrv:5672/")
if err != nil {
return err
}
ch, err := conn.Channel()
if err != nil {
return err
}
r.ch = ch
return nil
}АК
Или я вообще не так понял и каждый пакет которому нужен реббит должен внутри себя создавать канал и очередь ?
АК
1. Утекают - имеете ввиду что не нужно каждый раз создавать Conn а использовать старый?
AB
++
AV
а если в Defer добавить amqp.Close() ? Или нет такого?
AB
на каждый dial, должен быть close
АК
я пока для себя делаю простую штуку
типа
1. Сервис получает запрос, получает из редиса количество запросов за последние n сек и если их больше n то добавляет пользователя в бан.
После этого я хочу отправить сообщение в реббит о том, что есть новый бан
2. Второй сервис считывает очередь раз в n секунд (не дошёл еще до консюмера поэтому хз как там будет)
типа
1. Сервис получает запрос, получает из редиса количество запросов за последние n сек и если их больше n то добавляет пользователя в бан.
После этого я хочу отправить сообщение в реббит о том, что есть новый бан
2. Второй сервис считывает очередь раз в n секунд (не дошёл еще до консюмера поэтому хз как там будет)
АК
То есть после создания канала нам conn уже не нужен, верно понимаю?