2

начал разбираться с библиотекой для работы с очередью сообщений RabbitMq, которая называется EasyNetQ.

Особенность EasyNetQ в том, что очередь создается Подписчиком при активации подписки. Если коннект к RabbitMq теряется в процессе работы, то EasyNetQ мониторит доступность коннекта и при появлении связи восстановит его, это работает хорошо. Но если перезапустить Docker контейнер с RabbitMq, то подписчик сам восстановит коннект, но созданной им очереди уже не будет в новом экземпляре контейнера. Никаких событий у подписчика, доступности очереди или обмена я не нашел.

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

Как отследить наличие очереди в подписчике?

Скорее всего нужно пробросить папку с очередью из Docker, что-бы очередь всегда была сохранена. Просто сама ситуация что очередь не доступна, но про это известно только издателю и он на это никак повлиять не может.

Приведу пример подписчика:

    static void Main(string[] args)
    {
        var connectionStr = "host=localhost;username=guest;password=guest";
        using var bus = RabbitHutch.CreateBus(connectionStr);
        try
        {
            var subscriptionResult=bus.PubSub.Subscribe<MessageWrapper>(String.Empty, HandleTextMessage); //subscriptionId пустое, имя очереди задается только атрибатом над MessageWrapper
            Console.WriteLine("Listening for messages. Hit <return> to quit.");
            Console.ReadLine();
        }
        catch (BrokerUnreachableException e)  //Ошибка подключения к Брокеру
        {
            Console.WriteLine(e);
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
        }
    }
    
    static void HandleTextMessage(MessageWrapper messageWrapper) 
    {
        Console.ForegroundColor = ConsoleColor.Red;
        Console.WriteLine("Got message: {0}", messageWrapper);
        Console.ResetColor();
    }
    
    
    [Queue("TestMessagesQueue", ExchangeName = "MyTestExchange")] //Задает имя очереди и имя обмена
    public class MessageWrapper
    {
        public string Header { get; set; }
        public override string ToString() => $"{Header}";
    }
6
  • 1
    Если кратко, рестарт AMQP агента никак не должен влиять на наличие очередей. Если это происходит, значит с кроликом что-то не так. А вообще рестарт AMQP агента для прода - это катастрофа, агент не должен перезапускаться никогда. Немотря на то что прод должен выдерживать такой рестарт и не падать, в больших структурах MQ агент пересылает миллионы сообщений в секунду, как вы думаете, что произойдет, пара сотен миллионов сообщений не будет доставлена (или доставлена с огромной задержкой) из-за рестарта агента? Я к тому что рестарт MQ агента - это НЕ НОРМАЛЬНО, это внештатная ситуация.
    – aepot
    31 мар 2021 в 8:26
  • 1
    ... как лечить - решать вам, но в первую очередь выясните, почему очереди не сохраняются при рестарте, это явно стоит починить.
    – aepot
    31 мар 2021 в 8:30
  • 1
    Спасибо, я так и понял уже, условие сохранности очереди должно выполняться точно.
    – Aldmi
    31 мар 2021 в 10:28
  • Как принято делать: очередь создает продюсер или же очередь создается на Rabbit в ручную и Продюсер с Консьюмером ее используют?
    – Aldmi
    31 мар 2021 в 10:31
  • 1
    Мой сервис пока будет только Продюсером и ему предстоит заботится о создании очереди если ее нет. Поэтому EasyNetQ не подойдет мне буду использовать базовый клиент RabbitMq. Спасибо еще раз.
    – Aldmi
    31 мар 2021 в 10:41

0

Ваш ответ

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

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