Usando RabbitMQ como agente de mensajes

RabbitMQ es un agente de mensajes muy popular que puedes utilizar como alternativa a PostgreSQL.

Cambiando de PostgreSQL a RabbitMQ

Para utilizar RabbitMQ en lugar de PostgreSQL como agente de mensajes:

        1
2
3
4
5
6
7
8
9
10
11
        --- i/config/packages/messenger.yaml
+++ w/config/packages/messenger.yaml
@@ -5,7 +5,7 @@ framework:
         transports:
             # https://symfony.com/doc/current/messenger.html#transport-configuration
             async:
-                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+                dsn: '%env(RABBITMQ_URL)%'
                 retry_strategy:
                     max_retries: 3
                     multiplier: 2
    

También necesitamos añadir el soporte de RabbitMQ para Messenger:

        1
        $ symfony composer req amqp-messenger
    

Como habrás adivinado, también necesitamos agregar RabbitMQ a la pila de Docker Compose:

        1
2
3
4
5
6
7
8
9
10
11
12
13
        --- i/compose.yaml
+++ w/compose.yaml
@@ -18,6 +18,10 @@ services:
     image: redis:8.0-alpine
     ports: [6379]

+  rabbitmq:
+    image: rabbitmq:4.2-management
+    ports: [5672, 15672]
+
 volumes:
 ###> doctrine/doctrine-bundle ###
   database_data:
    

Para forzar a Docker Compose a que tenga en cuenta el contenedor RabbitMQ, para los contenedores y reinícialos:

        1
2
        $ docker compose stop
$ docker compose up -d --remove-orphans
    

Si quieres ver las colas y los mensajes que fluyen por RabbitMQ, abre su interfaz web de administración:

        1
        $ symfony open:local:rabbitmq
    

O desde la barra de herramientas de depuración web:

Usa guest/guest para acceder a la interfaz de administración de RabbitMQ:

Se puede añadir RabbitMQ a los servidores de producción agregándolos a la lista de servicios:

        1
2
3
4
5
6
7
8
9
10
11
        --- i/.upsun/config.yaml
+++ w/.upsun/config.yaml
@@ -25,4 +25,8 @@ services:
         rediscache:
             type: redis:8.0

+    queue:
+        type: rabbitmq:4.2
+        size: S
+
 applications:
    

Añade la referencia también en la configuración del contenedor web y activa la extensión de PHP amqp:

        1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
        --- i/.upsun/config.yaml
+++ w/.upsun/config.yaml
@@ -39,6 +39,7 @@ applications:

         runtime:
             extensions:
+                - amqp
                 - apcu
                 - blackfire
                 - ctype
@@ -72,5 +73,6 @@ applications:
         relationships:
             database: "database:postgresql"
             redis: "rediscache:redis"
+            rabbitmq: "queue:rabbitmq"

         hooks:
             build: |
    

Cuando el servicio RabbitMQ está instalado en un proyecto, se puede acceder a su interfaz de administración web abriendo primeramente el túnel:

        1
2
3
4
5
        $ symfony cloud:tunnel:open
$ symfony open:remote:rabbitmq

# when done
$ symfony cloud:tunnel:close
    

This work, including the code samples, is licensed under a Creative Commons BY-NC-SA 4.0 license.

TOC

Version