1

Сейчас разбираюсь с RabbitMQ. Ну и везде куча слов, типа сообщение после попадания в очередь живет, пока не будет обработано. Сообщение переживает как перезапуск читателя, так и всего брокера и т.д.

Но, если я правильно понимаю, все это работает, если сообщение уже попало в брокер. А если между писателем и удаленным брокером находится плохой канал связи, то о гарантированной доставке сообщений должен беспокоиться сам писатель. Он должен сам периодически опрашивать доступность брокера и самостоятельно буферизировать неотправленные сообщения.

Вопрос - нельзя ли эту заботу переложить на сам RabbitMQ? Может поднять как-то второго брокера на локальной машине писателя и настроить репликацию?

Неотправленные сообщения должны переживать полный перезапуск компьютера писателя. Сейчас у меня все реализовано на своем протоколе. Но может можно как-то напрячь сам RabbitMQ?

2
  • Но второй брокер тоже может упасть по какой-нибудь причине и сообщение в него тоже может не попасть. Вообще, согласно задаче двух генералов решить проблему невозможно даже теоретически. Можно лишь попытаться уменьшить вероятность потерь
    – andreymal
    25 мар 2020 в 17:47
  • @andreymal считаем, что вероятность падения локального брокера равна нулю 26 мар 2020 в 9:10

1 ответ 1

1

Если вы пишете на asp.net core, то для решения этой задачи можете воспользоваться фреймворком MassTransit - по-умолчанию, писатель в MassTransit ждёт подтверждения Ack от RabbitMQ для гарантированной отправки сообщения (разумеется, ценой уменьшения производительности отправки).

Также, фреймворк обладает рядом других фич, которые делают работу с RabbitMQ не такой низкоуровневой - например, повторный приём сообщения читателем (в случае возникновения какой-то временной проблемы на его стороне) настраивается в показанном ниже примере. При этом, если принимающее приложение вдруг стало останавливаться и стали срабатывать токены отмены, то сообщение просто вернётся обратно в очередь и будет доставлено другому доступному получателю.

IRabbitMqHost host = cfg.Host(secrets.MessageBusHost, secrets.MessageBusVHost, h =>
{
    h.Username(secrets.MessageBusLogin);
    h.Password(secrets.MessageBusPassword);
});

cfg.ReceiveEndpoint(host, PrivateServiceQueueName, e =>
{
    e.UseMessageRetry(x =>
    {
        x.Handle<OperationCanceledException>();
        x.Interval(2, 500);
    });

    e.Consumer<TestRequestConsumer>(provider);
});
1
  • Спасибо, но у меня не .net. И вопрос не в фрейморках, а в функционале самого RabbitMQ 24 мар 2020 в 17:27

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.