RabbitMQ — это брокер сообщений, имплементирующий протокол AMQP (Advanced Message Queuing Protocol). Он позволяет приложениям асинхронно взаимодействовать, отправляя и получая сообщения через централизованную систему. RabbitMQ обеспечивает надежную доставку, маршрутизацию и хранение сообщений.
Основные компоненты:
- Производитель (Producer): Отправляет сообщения в RabbitMQ.
- Обменник (Exchange): Получает сообщения от произведетелей и направляет их в одну или несколько очередей на основе правил маршрутизации (binding).
- Очередь (Queue): Хранит сообщения до тех пор, пока их не заберут потребители.
- Потребитель (Consumer): Получает сообщения из очередей для обработки.
Типы обменников:
- Direct: Маршрутизирует сообщения в очереди, где ключ маршрутизации сообщения точно совпадает с ключом привязки очереди.
- Fanout: Маршрутизирует сообщения во все привязанные очереди, игнорируя ключ маршрутизации.
- Topic: Маршрутизирует сообщения на основе частичного совпадения ключа маршрутизации сообщения с шаблоном ключа привязки очереди (с использованием символов
* и #).
- Headers: Маршрутизирует сообщения на основе заголовков сообщения, а не ключа маршрутизации.
Применение в PHP-разработке:
- Отложенная обработка задач: Например, отправка email, генерация отчетов, обработка изображений.
- Микросервисная архитектура: Асинхронное взаимодействие между сервисами.
- Системы реального времени: Обработка большого потока событий.
- Балансировка нагрузки: Распре
RabbitMQ — это брокер сообщений, имплементирующий протокол AMQP (Advanced Message Queuing Protocol). Он позволяет приложениям асинхронно взаимодействовать, отправляя и получая сообщения через централизованную систему. RabbitMQ обеспечивает надежную доставку, маршрутизацию и хранение сообщений.
Основные компоненты:
- Производитель (Producer): Отправляет сообщения в RabbitMQ.
- Обменник (Exchange): Получает сообщения от произведетелей и направляет их в одну или несколько очередей на основе правил маршрутизации (binding).
- Очередь (Queue): Хранит сообщения до тех пор, пока их не заберут потребители.
- Потребитель (Consumer): Получает сообщения из очередей для обработки.
Типы обменников:
- Direct: Маршрутизирует сообщения в очереди, где ключ маршрутизации сообщения точно совпадает с ключом привязки очереди.
- Fanout: Маршрутизирует сообщения во все привязанные очереди, игнорируя ключ маршрутизации.
- Topic: Маршрутизирует сообщения на основе частичного совпадения ключа маршрутизации сообщения с шаблоном ключа привязки очереди (с использованием символов
* и #).
- Headers: Маршрутизирует сообщения на основе заголовков сообщения, а не ключа маршрутизации.
Применение в PHP-разработке:
- Отложенная обработка задач: Например, отправка email, генерация отчетов, обработка изображений.
- Микросервисная архитектура: Асинхронное взаимодействие между сервисами.
- Системы реального времени: Обработка большого потока событий.
- Балансировка нагрузки: Распре