步骤 32: 使用 RabbitMQ 作为消息代理

RabbitMQ 是一个非常流行的消息代理，你可以用它来代替 PostgreSQL。

从 PostgreSQL 切换到 RabbitMQ

要使用 RabbitMQ 作为消息代理来代替 PostgreSQL：

patch_file

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

--- 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 服务：

为了强制让 RabbitMQ 容器在 Docker Compose 中生效，把容器都关闭，并且重启它们：

$ docker-compose stop
$ docker-compose up -d

$ sleep 10

探索 RabbitMQ 的网站管理界面

如果你想要看到 RabbitMQ 中往来的队列和消息，打开它的网站管理界面：

$ symfony open:local:rabbitmq

或者从网站调试工具栏打开：

使用 guest/guest 作为账号密码来登录 RabbitMQ 的管理界面：

部署 RabbitMQ

将 RabbitMQ 加入服务列表，就可以把它加进生产服务器。

patch_file

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

也可以在网站容器配置中找到它，然后启动 amqp 这个 PHP 扩展：

patch_file

--- 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 服务，你可以通过先打开隧道来访问它的网站管理界面：

$ symfony tunnel:open
$ symfony open:remote:rabbitmq
# when done
$ symfony tunnel:close

深入学习

• RabbitMQ 文档。

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