Блог

У меня запущен проект Symfony 4.4 с messenger и RabbitMQ. У меня есть асинхронный транспорт с 2 очередями.

     transports:
        # https://symfony.com/doc/current/messenger.html#transport-configuration
      async:
        dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
        options:
          exchange:
            name: myexchange
            type: direct
          queues:
            email:
              binding_keys:
                - email
            extranet:
              binding_keys:
                  - extranet
        # failed: 'doctrine://default?queue_name=failed'
        # sync: 'sync://'

    routing:
        # Route your messages to the transports
        'AppMessageExtranetMessage': async
        'SymfonyComponentMailerMessengerSendEmailMessage': async
  

Мне нужно отправить электронное письмо с symfony/mailer компонентом в очередь электронной почты.

 public function contact(Request $request, MailerInterface $mailer)
{
    if($request->isXmlHttpRequest())
    {
        //dd($request->request->all());
        $body =
            'Nouveau message depuis le front<br />
             Nom = '.$request->request->get('nom').'<br />
             Prénom = '.$request->request->get('prenom').'<br />
             Société = '.$request->request->get('societe').'<br />
             Email = '.$request->request->get('mail').'<br />';

        $email = (new Email())
            ->from('from@email.tld')
            ->replyTo($request->request->get('mail'))
            ->to('$request->request->get('mail')')
            ->subject('test')
            ->html($body);

        $mailer->send($email);

        return new JsonResponse('OK', 200);
    }
}
  

Как я могу добавить binding_key mailer в, чтобы RabbitMQ знал, как обрабатывать электронную почту?

Ключи маршрутизации могут быть указаны с помощью штампов. К сожалению, интеграция с почтовой программой не предоставляет способа их добавления, она просто отправляет сообщение в очередь по умолчанию. Но вы все равно можете отправить сообщение вручную:

 $this->dispatchMessage(new SendEmailMessage($email), [new AmqpStamp('email')]);
  

Этот подход имеет некоторые ограничения: поскольку он не использует mailer код, MessageEvent он не будет отправлен, а панель «Электронные письма» в профилировщике будет пустой.

Другой вариант — добавить штамп с помощью промежуточного программного обеспечения:

1. Создайте промежуточное программное обеспечение

 // src/Messenger/StampEmailMessageMiddleware.php
class StampEmailMessageMiddleware implements MiddlewareInterface
{
    const bindingKey = 'email';

    public function handle(Envelope $envelope, StackInterface $stack): Envelope
    {
        // Add the stamp. Since the middleware gets called both when dispatching and 
        // consuming the message, we make sure there's no stamp already added.
        if (
            $envelope->getMessage() instanceof SendEmailMessage amp;amp; 
            null === $envelope->last(AmqpStamp::class)
        ) {
            $envelope = $envelope->with(new AmqpStamp(self::bindingKey));
        }

        return $stack->next()->handle($envelope, $stack);
    }
}

  

2. Добавьте промежуточное программное обеспечение в конфигурацию шины:

 # config/packages/messenger.yaml
messenger:
    buses:
        messenger.bus.default:
            middleware:
                - 'AppMessengerStampEmailMessageMiddleware'

  

3. Отправьте сообщение в обычном режиме:

 $mailer->send($email);
  

Хорошо, я нашел ответ при поиске полной ссылки на конфигурацию messenger.

Для обработки сообщений без ключа привязки default_publish_routing_key необходимо добавить запись. Теперь конфигурация выглядит так :

     transports:
        # https://symfony.com/doc/current/messenger.html#transport-configuration
      async:
        dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
        options:
          exchange:
            name: myexchange
            type: direct
            default_publish_routing_key: email
          queues:
            email:
              binding_keys:
                - email
            extranet:
              binding_keys:
                  - extranet
        # failed: 'doctrine://default?queue_name=failed'
        # sync: 'sync://'

    routing:
        # Route your messages to the transports
        'AppMessageExtranetMessage': async
        'SymfonyComponentMailerMessengerSendEmailMessage': async
  

Это позволяет компоненту messenger обрабатывать событие сообщений, если для них не указана какая-либо очередь.

В качестве альтернативы вы можете определить отдельные транспорты для каждой очереди, используя разные имена exchange.

     transports:
      async_email:
        dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
        options:
          exchange:
            name: messages_email
          queues:
            email: ~
      async_extranet:
        dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
        options:
          exchange:
            name: messages_extranet
          queues:
            extranet: ~

    routing:
        'AppMessageExtranetMessage': async_extranet
        'SymfonyComponentMailerMessengerSendEmailMessage': async_email
  

В этом случае вам не нужно указывать ключ привязки при каждой отправке сообщения или создавать пользовательское промежуточное программное обеспечение.