Symfony：通过电子邮件发送失败的消息

Question

我有一个简单的 Messanger 配置：

framework:
    messenger:
        failure_transport: failed
        transports:
            async:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                retry_strategy:
                    max_retries: 2
                    delay: 10000
            failed: 'doctrine://default?queue_name=failed'

        routing:
            someInterface: async

我想知道路由到失败传输的每封邮件 f.e。系统应该在消息重定向时向我发送电子邮件通知。我唯一的想法是定期查看 messenger_messages table，其中包含存储在失败传输中的消息，但我认为这不是 symfony 方式的解决方案。你知道这个功能更聪明的解决方案吗？

我正在使用 symfony/messenger 版本 5。*

Answer 1

我认为不可能通过配置来实现，但您可以创建自定义中间件并自行发送电子邮件。 https://symfony.com/doc/current/messenger.html#middleware

您可以查看FailedMessageProcessingMiddleware以供参考https://github.com/symfony/messenger/blob/master/Middleware/FailedMessageProcessingMiddleware.php

Answer 2

最终，我应用了以下解决方案：

<?php
/**
 * Author: writ3it
 */

namespace App\Maintenance\Messenger;


use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
use Symfony\Component\Messenger\MessageBusInterface;

class FailedMessageListener implements EventSubscriberInterface
{

    /**
     * @var MessageBusInterface
     */
    private MessageBusInterface $bus;

    public function __construct(MessageBusInterface $bus)
    {
        $this->bus = $bus;
    }

    public function onMessageFailed(WorkerMessageFailedEvent $event)
    {
        if ($event->willRetry()) {
            return;
        }
        $envelope = $event->getEnvelope();
        $message = $envelope->getMessage();

        $subject = sprintf("Message added to failed transport. Message: %s", \get_class($message));
        $content = serialize($message);

        $notification = new FailedMessageNotificationEvent();
        $notification->setSubject($subject)
            ->setContent($content);
        $this->bus->dispatch($notification);
    }

    /**
     * @return array
     */
    public static function getSubscribedEvents()
    {
        return [
            WorkerMessageFailedEvent::class => ['onMessageFailed', -256],
        ];
    }
}

FailedMessageNotificationEvent 是一条将被我的邮件处理程序捕获的消息。 FailedMessageListener class 应标记为 kernel.event_subscriber 或自动配置。

我没有使用中间件，因为 Messenger 直接将消息发送到失败的传输，没有中间件。

Symfony：通过电子邮件发送失败的消息

Symfony: send failed messages via email

php

symfony

message-queue

symfony5