邮件发送失败时队列的处理流程-Symfony5全面开发

您需要登录后才可观看此视频

为了更好的为您提供服务,请您登录后再查看本课程。

立即登录 注册账号

查看messenger.yaml配置文件,在transports配置下有个failed传输,failed传输使用了doctrine传输,队列的名称是failed。我们取消行前的注释,在第4行messenger组件提供了failure_transport配置。我们取消第4行行前的注释,当consume命令行消费一条消息时,可能会出现一些错误。当出现错误时,命令行会向传输中发送一条失败的消息,传输队列即将失败的消息调度到指定的失败传输队列中,现在我们配置了两个transports。

我们打开控制台,重新启动一下consume命令行,输入-vv,现在提示让我们选择一个传输队列。我们选择0。回到浏览器,我们来退出mailcatcher,让邮件发送失败。点击退出。

回到管理端,我们新增一篇文章,文章的标题叫做Hello Failed,点击添加回到控制台。现在命令行就收到了消息,等待10秒钟之后,提示了一条错误。然后再等待1秒钟之后进行第1次重试。现在再次获取消息,在等待2秒钟之后进行了第2次重试。等待4秒钟之后进行了第3次重试,然后进行第4次获取消息,现在提示我们,当前的消息已经被拒绝了。并且会将消息发送到failure transport

我们打开数据库客户端,查看一下数据库中的消息,当前消息就是我们发送失败的消息。但是队列的名称并不是之前的名称了,现在队列的名称修改为了failed

回到项目,我们可以查看一下messenger提供的所有命令行。输入symfony console list messenger,messenger组件提供的命令行中有三条是关于发送失败时的命令行,我们可以使用messenger:failed:show来查看一下队列中所有失败的消息。

输入symfony console,粘贴,当前队列中有一条失败的消息。我们可以使用messenger:failed:retry,重新尝试发送这条消息。输入symfony console,retry。

我们当前没有启动mailcatcher,它提示我们需要重新尝试吗,我们输入yes,现在仍然会发送失败,直接就退出了命令行。

我们启动mailcatcher,重新执行命令行,输入yes。这次没有报错。回到浏览器,查看邮件列表,我们收到了新的邮件。回到项目,我们查看一下失败时处理的流程。当消息处理失败时,它会进行几次重试,每次重试时都会进行一个时间的延迟,我们可以查看一下messenger配置文件,所有可以配置的配置选项。

打开新的控制台输入symfony console config:dump framework messenger,我们查看transports配置,首先我们可以设置transports的名称,然后设置dsn。

在下面有个重试策略,最大的重试次数,默认值为3。每次重试时都会有一个延迟,这里设置为1秒,如果重试次数大于1,那么在每次进行重试时,都会在延迟时间上乘以2。我们可以修改配置来调整重试的次数以及延迟的时间。

我们来修改async配置,注释这行代码,添加async,设置dsn。dsn还使用之前的配置。然后我们设置重试策略,复制配置项,粘贴。最大的重试次数,我们修改一下,这里修改为5。延迟时间,这里仍然设置为1秒钟,延迟时间的乘数,这里我们设置为3。

#config/packages/messenger.yaml

framework:
    messenger:
        # Uncomment this (and the failed transport below) to send failed messages to this transport for later handling.
        failure_transport: failed

        transports:
            # https://symfony.com/doc/current/messenger.html#transport-configuration
#            async: '%env(MESSENGER_TRANSPORT_DSN)%'
            async:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                retry_strategy:
                    max_retries: 5
                    delay: 1000
                    multiplier: 3
            failed: 'doctrine://default?queue_name=failed'
            # sync: 'sync://'

        routing:
            # Route your messages to the transports
            'App\Message\SendEmailMessage': async

我们修改了messenger.yaml配置文件,每次修改messenger.yaml配置文件之后,我们都要暂停之前的consume命令行,然后再重新启动命令行。messenger提供了一个命令行来暂停所有的工作者进程,我们复制messenger:stop-workers命令行。

输入symfony console,粘贴,现在就暂停了所有的工作者进程,我们重新启动consume命令行。选择async传输队列,我们退出mailcatcher,点击确定。新增一篇文章,点击添加,我们查看底部控制台。

在等待10秒钟之后进行了第1次重试,然后进行第2次重试,重试的间隔就变成了3秒。现在consume命令行会按照我们的配置进行自动重试,consume命令行可以叫做工作者进程,在进行5次尝试之后会将失败的消息发送到失败队列。

我们的配置已经生效了,在下节课,我们来学习常用的AMQP队列。

课程讨论

当前内容评论功能已关闭。