Шаг 32: Использование RabbitMQ в качестве брокера сообщений
Использование RabbitMQ в качестве брокера сообщений¶
RabbitMQ — очень популярный брокер сообщений, который можно использовать в качестве альтернативы PostgreSQL.
Переход с PostgreSQL на RabbitMQ¶
Сделайте следующие изменение, чтобы использовать RabbitMQ вместо PostgreSQL в качестве брокера сообщений:
1 2 3 4 5 6 7 8 9 10 11 | --- a/config/packages/messenger.yaml
+++ b/config/packages/messenger.yaml
@@ -6,7 +6,7 @@ framework:
transports:
# https://symfony.com/doc/current/messenger.html#transport-configuration
async:
- dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+ dsn: '%env(RABBITMQ_URL)%'
options:
use_notify: true
check_delayed_interval: 60000
|
Добавление RabbitMQ в Docker¶
Как вы уже догадались, нам также нужно добавить RabbitMQ в файл Docker Compose:
1 2 3 4 5 6 7 8 9 10 | --- a/docker-compose.yaml
+++ b/docker-compose.yaml
@@ -21,3 +21,7 @@ services:
redis:
image: redis:5-alpine
ports: [6379]
+
+ rabbitmq:
+ image: rabbitmq:3.7-management
+ ports: [5672, 15672]
|
Перезапуск сервисов Docker¶
Остановите и перезапустите контейнеры, чтобы Docker Compose смог добавить новый контейнер RabbitMQ:
1 2 | $ docker-compose stop
$ docker-compose up -d
|
1 | $ sleep 10
|
Знакомство с панелью управления RabbitMQ¶
Если вы хотите посмотреть очереди и сообщения, проходящие через RabbitMQ, воспользуйтесь специальной панелью управления:
1 | $ symfony open:local:rabbitmq
|
Это также можно сделать через панель отладки:

Для входа в интерфейс управления RabbitMQ в качестве логина/пароля используйте guest
/guest
:

Развёртывание новой версии с RabbitMQ¶
Чтобы активировать RabbitMQ на продакшен-серверах добавьте его в список сервисов:
1 2 3 4 5 6 7 8 9 10 11 | --- a/.symfony/services.yaml
+++ b/.symfony/services.yaml
@@ -18,3 +18,8 @@ files:
rediscache:
type: redis:5.0
+
+queue:
+ type: rabbitmq:3.7
+ disk: 1024
+ size: S
|
Также укажите его в конфигурации веб-контейнера и включите PHP-модуль amqp
:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 | --- a/.symfony.cloud.yaml
+++ b/.symfony.cloud.yaml
@@ -4,6 +4,7 @@ type: php:7.4
runtime:
extensions:
+ - amqp
- redis
- blackfire
- xsl
@@ -28,6 +29,7 @@ disk: 512
relationships:
database: "db:postgresql"
redis: "rediscache:redis"
+ rabbitmq: "queue:rabbitmq"
web:
locations:
|
Чтобы перейти в панель управления RabbitMQ на продакшен-сервер прежде всего откройте туннель:
1 2 3 4 5 | $ symfony tunnel:open
$ symfony open:remote:rabbitmq
# when done
$ symfony tunnel:close
|
- « Previous Шаг 31: Использование Redis для хранения сессий
- Next » Что дальше?
This work, including the code samples, is licensed under a Creative Commons BY-NC-SA 4.0 license.