Symfony Messenger 监控简介-php教程-PHP中文网

使用 Symfony Messenger 和 Inspector Bundle 增强 Symfony 应用程序可扩展性

作为 Symfony 开发人员，优化应用程序性能和可扩展性至关重要。 Symfony Messenger 组件为异步任务处理提供了强大的解决方案，但监视这些后台操作可能具有挑战性。本文介绍了 Inspector 包中的一项新功能，该功能提供对 Symfony Messenger 后台作业的全面可见性，无需手动日志分析或自定义监控代码。

这项新功能可以自动监控后台任务的各个方面。从执行时间和内存消耗到数据库查询、错误和潜在瓶颈，您可以通过用户友好的仪表板获得即时洞察 - 所有这些都需要零配置。

典型的开发人员挑战仍然是：部署异步消息处理并希望后台操作顺利。虽然 Symfony Messenger 很强大，但监控后台进程历来是一个盲点。本文深入探讨了实现细节，以强调对日常开发的显着好处。

什么是队列系统？

Introducing Symfony Messenger Monitoring

队列系统是现代 Web 应用程序中的关键元素，可以将时间密集型任务与主请求响应周期分离。这些任务不是在用户请求期间处理资源密集型操作（例如发送电子邮件、图像处理、报告生成），而是排队等待后台工作人员异步处理。这提高了应用程序的响应能力，因为用户不必等待冗长的操作，并通过控制并发任务处理来增强资源管理。队列系统通常包含重试机制，以确保任务失败时的可靠性。随着应用程序的扩展，采用这种方法对于在不增加基础设施成本的情况下为更多用户提供服务变得至关重要。

Symfony Messenger 组件

Symfony Messenger 组件是 Symfony 框架内的一个内置的、强大的排队系统。它有助于从各种队列提供程序（AMQP、Redis、Doctrine）发布和使用消息。消息是包含表示任务的数据的简单类。

这是一条示例消息：

<code class="language-php">namespace App\Messenger;

class SmsNotification
{
    public function __construct(private string $content) {}
    public function getContent(): string { return $this->content; }
}</code>

登录后复制

从队列中检索消息时，相应的处理程序会处理该消息：

<code class="language-php">namespace App\Messenger;

class SmsNotification
{
    public function __construct(private string $content) {}
    public function getContent(): string { return $this->content; }
}</code>

登录后复制

请注意 #[AsMessageHandler] 属性以及 SmsNotification 方法中 __invoke 的类型提示。这些是 Symfony 如何识别特定消息的处理程序。 messenger:consume 命令运行后台工作程序来处理排队的消息并在请求-响应周期之外执行适当的处理程序。异步发送消息：

<code class="language-php">namespace App\Messenger;

use Symfony\Component\Messenger\Attribute\AsMessageHandler;

#[AsMessageHandler]
class SmsNotificationHandler
{
    public function __invoke(SmsNotification $message)
    {
        // ... send SMS message ...
    }
}</code>

登录后复制

Messenger 通过自动消息序列化、中间件支持和重试策略等功能简化了复杂的异步处理。

Symfony Messenger 监控中间件

监控在用户和开发人员视图之外运行的后台进程带来了独特的挑战。问题出现了：处理程序需要多长时间？是否正在执行昂贵的数据库操作？后台作业是否会默默失败？

Inspector 通过提供用户友好的界面来监控后台进程，其效率与主应用程序相同，从而解决了这些问题。

Symfony Messenger 中间件架构

Inspector 包注册了一个 Messenger 中间件来跟踪消息处理的开始和结束。它利用现有功能在消息处理期间收集数据库查询和其他操作。 Symfony Messenger 中的中间件充当消息处理的包装器，允许在处理之前和之后执行操作。这利用了责任链设计模式。

检查器中间件实现

中间件的实现是为了在消息处理之前和之后执行代码：

<code class="language-php">namespace App\Controller;

use App\Messenger\SmsNotification;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Component\Routing\Attribute\Route;

class HomeController extends AbstractController
{
    #[Route('/', name: 'home')]
    public function home(MessageBusInterface $bus)
    {
        $bus->dispatch(new SmsNotification("New Message!"));
        return new Response('SMS notification dispatched.');
    }
}</code>

登录后复制

这个即插即用组件简化了更新应用程序依赖项时的后台进程监控。

升级到版本1.5

版本 1.5 是一个次要版本，可以通过 composer update 轻松安装。 Messenger 监控自动集成，无需更改代码。

忽略消息

为了减少噪音，Inspector 允许使用 ignore_messages 中的 inspector.yaml 属性忽略特定消息或模式：

<code class="language-php">namespace App\Messenger\Middlewares;

use Symfony\Component\Messenger\Middleware\MiddlewareInterface;
use Symfony\Component\Messenger\Middleware\StackInterface;

class MessengerMonitoringMiddleware implements MiddlewareInterface
{
    public function handle(Envelope $envelope, StackInterface $stack): Envelope
    {
        // Before handling
        $this->beforeHandle($envelope);

        // Handle the message
        $envelope = $stack->next()->handle($envelope, $stack);

        // After handling
        $this->afterHandle($envelope);
    }
}</code>

登录后复制