Использование Symfony Messenger для управления очередями сообщений в Symfony

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

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

В Symfony Messenger вы создаете два класса:
🟢Класс сообщения, который содержит данные.
🟢Обработчик(и) сообщения, который будет вызван при отправке этого сообщения. Обработчик читает класс сообщения и выполняет одну или несколько задач.

Middleware — это компоненты, которые могут обрабатывать сообщения, когда они передаются через шину. Middleware могут выполнять различные задачи, такие как логирование, валидация сообщения, начало транзакции и т. д.

Envelope — это специфичный для Messenger концепт, который оборачивает сообщения, позволяя добавлять полезную информацию через envelope stamps. Envelope stamps — это метаданные, которые можно прикрепить к сообщению, например, контекст сериализации для транспорта или маркеры, идентифицирующие полученное сообщение.

Symfony Messenger также поддерживает различные транспорты для асинхронной обработки сообщений, такие как очереди.