Крок 32: Використання RabbitMQ у якості брокера повідомлень

5.2 version
Maintained

Використання RabbitMQ у якості брокера повідомлень

RabbitMQ — це дуже популярний брокер повідомлень, який ви можете використовувати як альтернативу PostgreSQL.

Перехід від PostgreSQL до RabbitMQ

Щоб використовувати RabbitMQ замість PostgreSQL у якості брокера повідомлень:

patch_file
 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:

patch_file
 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

Або з панелі інструментів веб-налагодження:

Використовуйте guest/guest, щоб увійти до інтерфейсу управління RabbitMQ:

Розгортання RabbitMQ

Додавання RabbitMQ до продакшн серверів можна здійснити додавши його до списку сервісів:

patch_file
 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:

patch_file
 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.