RabbitMQをメッセージのブローカーとして使う

RabbitMQはとても有名なメッセージブローカーで、PostgreSQLの代わりに使うことができます。

PostgreSQLからRabbitMQに切り替える

メッセージブローカーとしてPostgreSQLの代わりにRabbitMQを利用します:

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

メッセンジャー用にRabbitMQサポートを追加する必要があります:

        1
        $ symfony composer req amqp-messenger
    

既に予想していたかもしれませんが、RabbitMQを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:5-alpine
     ports: [6379]

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

Docker ComposeでRabbitMQ コンテナを扱わせるために、コンテナをすべて停止して再起動します:

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

RabbitMQを通っていくキューやメッセージを見たければ、RabbitMQのWeb管理画面を開きます:

        1
        $ symfony open:local:rabbitmq
    

あるいはWebデバッグツールバーからも見ることができます:

RabbitMQの管理画面には guest/guest アカウントを使ってログインします:

RabbitMQをプロダクションサーバーに追加するには、サービスのリストに追加します:

        1
2
3
4
5
6
7
8
9
10
11
        --- i/.platform/services.yaml
+++ w/.platform/services.yaml
@@ -19,3 +19,8 @@ files:

 rediscache:
     type: redis:5.0
+
+queue:
+    type: rabbitmq:3.7
+    disk: 1024
+    size: S
    

Webコンテナの設定でも参照し、 amqp PHP拡張を有効にします:

        1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
        --- i/.platform.app.yaml
+++ w/.platform.app.yaml
@@ -4,6 +4,7 @@ type: php:8.3

 runtime:
     extensions:
+        - amqp
         - apcu
         - blackfire
         - ctype
@@ -38,6 +39,7 @@ mounts:
 relationships:
     database: "database:postgresql"
     redis: "rediscache:redis"
+    rabbitmq: "queue:rabbitmq"
     
 hooks:
     build: |
    

RabbitMQサービスがプロジェクトにインストールされると、トンネルを使ってWeb管理画面にアクセスできるようになります:

        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