2

我有一个使用 messenger 和 rabbitMQ 正在运行的 Symfony 4.4 项目。我有一个带有 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
        'App\Message\ExtranetMessage': async
        'Symfony\Component\Mailer\Messenger\SendEmailMessage': 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 知道如何处理电子邮件？

4

3 回答 3

2

路由键可以通过 stamps指定。不幸的是，邮件程序集成没有公开添加它们的方法，它只是将消息分派到默认队列。但是您仍然可以手动发送消息：

$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 && 
            null === $envelope->last(AmqpStamp::class)
        ) {
            $envelope = $envelope->with(new AmqpStamp(self::bindingKey));
        }

        return $stack->next()->handle($envelope, $stack);
    }
}
  1. 将中间件添加到总线配置中：
# config/packages/messenger.yaml
messenger:
    buses:
        messenger.bus.default:
            middleware:
                - 'App\Messenger\StampEmailMessageMiddleware'
  1. 正常发送消息：
$mailer->send($email);
于 2020-10-15T14:23:46.823 回答
1

好的，我在搜索完整的 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
        'App\Message\ExtranetMessage': async
        'Symfony\Component\Mailer\Messenger\SendEmailMessage': async

如果没有指定任何队列，这允许信使组件处理消息事件。

于 2020-10-15T08:47:48.557 回答
0

或者，您可以使用不同的交换名称为每个队列定义单独的传输。

    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:
        'App\Message\ExtranetMessage': async_extranet
        'Symfony\Component\Mailer\Messenger\SendEmailMessage': async_email

在这种情况下，您不需要在每个消息分发上指定绑定键或创建自定义中间件。

于 2021-10-20T15:34:38.260 回答