Как работает асинхронная обработка данных с использованием брокера сообщений?

Асинхронная обработка данных с использованием брокера сообщений предполагает отправку запроса или сообщения от одного сервиса к другому, при этом деятельность сервиса-отправителя не приостанавливается в ожидании ответа от получателя. blog.skillfactory.ru

Процесс работы брокера сообщений на примере RabbitMQ: blog.skillfactory.ru

1. Продюсер отправляет сообщение в обменник. blog.skillfactory.ru Он может указать ключ маршрутизации, который определяет, в какую очередь должно быть направлено сообщение. timeweb.cloud
2. Обменник направляет сообщение в соответствующую очередь, в зависимости от типа обмена и биндинга (связи между обменником и очередью, которая определяет, какие сообщения в какую очередь будут направлены). blog.skillfactory.ru
3. Получатель подписывается на очередь и начинает получать сообщения из неё. blog.skillfactory.ru
4. Получатель обрабатывает сообщения и выполняет необходимые действия. blog.skillfactory.ru
5. Получатель подтверждает получение сообщения, чтобы исключить его из очереди. blog.skillfactory.ru
6. Если сообщение не было подтверждено в течение определённого времени, оно будет повторно отправлено в очередь. blog.skillfactory.ru

Существует множество различных брокеров сообщений, и каждый из них подходит под свои задачи. ru.hexlet.io Некоторые из них: Apache Kafka, NATS, ActiveMQ, Redis Pub/Sub и другие. timeweb.cloud

Пользователь

Время добавления