Как по Go way реализовать переподключение к RabbitMQ?

Question

[cascado]

Добрый день. Был взят за основу пример github.com/streadway/amqp либы, был найден отрывочный код по реализации переподключения к ноде RabbitMQ https://gist.github.com/svcavallar/be2d40953eaf278... в случае закрытия соединения. Перепробовано несколько вариантов, видимо я в корне неверно представляю как это должно работать. Насколько я понимаю, при пересоздании объекта amqp.Connect, требуется пересоздать и объекты channel, queue и messages. Прошу показать (или поправить кусок кода), как должен выглядеть такой функционал, код прилагаю https://gist.github.com/cascad-s/7fca5c68639114eb9.... Заранее благодарю.

Answer 1

[Roman Kravchik]

Детально не вчитывался, но перед каждым:
r_connection.NotifyClose(rabbitCloseError)
канал rabbitCloseError для уведомлений о закрытии соединения нужно пересоздавать через make.
Пруф: https://github.com/streadway/amqp/issues/160

У svcavallar как раз так и реализовано:

rabbitConn = connectToRabbitMQ(uri)
rabbitCloseError = make(chan *amqp.Error)  // <---- look here
rabbitConn.NotifyClose(rabbitCloseError)

Если будут вопросы, пишите комментарии к ответу.

P.S. Также я бы рекомендовал не блокировать программу "бесконечным" каналом, а хотя бы использовать сигналы ОС (даже под виндой).

Comments

[cascado]

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

[cascado]

за сигналы ОС благодарю

[cascado]

Если возможно, проясните момент с закрытием канала, который мы запихиваем в коллбэк на ошибку подключения, вот для чего он закрывается, для чего вся канитель с пересозданием, с моей позиции это глупо смотрится, может я чего не знаю?

[Roman Kravchik]

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