.NET 2022 | 14.2 Лекция | Брокеры сообщений. Rabbit MQ

• В видео рассказывается о том, как использовать очереди в RabbitMQ для работы с сообщениями.  

• Создаются соединения, ченолы и очереди для отправки и получения сообщений.  

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

• Упоминаются временные и постоянные очереди, их применение в бизнес-процессах.  

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

• Это достигается с помощью декларирования и обмена сообщениями.  

• В этом случае отправитель не кладет сообщение сразу в очередь, а делает это через экс-чеч.  

• Это позволяет отправителю не знать, какая очередь будет использована для обработки сообщения.  

• Если очередь еще не создана, сообщение может быть потеряно.  

• Фанаут - это способ отправки сообщения всем подписчикам, независимо от того, создали ли они очередь.  

• В этом случае, отправитель декларирует экс-чеч и определяет правило маршрутизации и биндинга между очередью и экс-чеч.  

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

• Дайрек - это способ маршрутизации сообщений в зависимости от ключа.  

• В этом случае, отправитель декларирует обменник, считывает сообщения из консоли и отправляет их, передавая роуд-кей.  

• Роуд-кей определяет, в какую очередь должно быть отправлено сообщение.  

• В зависимости от ключа, сообщение может быть отправлено в одну или другую очередь.  

• В этом разделе рассматривается реализация RPC на брокере.  

• Сначала конфигурируется принимающая сторона, где создается соединение и декларируется очередь для отправки команд.  

• Затем подписывается на очередь, где будут приходить ответы.  

• В примере кода показано, как считать число Фибоначчи и отправить ответ в очередь, откуда он будет получен принимающей стороной.  

• В этом разделе рассматривается реализация RPC на клиенте.  

• Клиент отправляет данные, используя абстракцию RPC, не зная о транспортном пути и сложной реализации.  

• В примере кода показано, как создать клиент, вызвать метод и получить ответ.  

• В видео обсуждается работа с брокером, который используется для отправки и получения сообщений между микросервисами.  

• Создается соединение, канал и очередь для отправки и получения ответов.  

• Затем создается подписчик для обработки ответов в рамках канала и соединения.  

• В видео обсуждаются различные способы реализации взаимодействия с брокером, включая использование синхронной очереди и асинхронной очереди.  

• Также обсуждается параметр "basic.co.  

• un.  

• max.  

• requests" в брокере, который определяет максимальное количество запросов, которые могут быть обработаны одновременно.  

• В видео обсуждаются проблемы, которые могут возникнуть при неравномерной работе с брокером, когда некоторые консамеры могут обрабатывать больше сообщений, чем другие.  

• Для решения этой проблемы предлагается использовать параметр "prefetch.  

• count", который ограничивает количество сообщений, которые могут быть обработаны одновременно.