搜索
首页后端开发php教程Symfony Messenger 监控简介

使用 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)发布和使用消息。消息是包含表示任务的数据的简单类。

这是一条示例消息:

namespace App\Messenger;

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

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

namespace App\Messenger;

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

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

namespace App\Messenger;

use Symfony\Component\Messenger\Attribute\AsMessageHandler;

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

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

Symfony Messenger 监控中间件

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

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

Symfony Messenger 中间件架构

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

检查器中间件实现

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

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.');
    }
}

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

升级到版本1.5

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

忽略消息

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

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);
    }
}

使用 Inspector 监控您的 Symfony 应用程序

Inspector 提供免费的 HTTP 监控、数据库查询洞察和警报转发。 只需安装 Symfony 包即可开始。 了解更多https://www.php.cn/link/3a78f1864ab77dbd239fbe33cae90bbb

Introducing Symfony Messenger Monitoring

以上是Symfony Messenger 监控简介的详细内容。更多信息请关注PHP中文网其他相关文章!

声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
您如何防止与会议有关的跨站点脚本(XSS)攻击?您如何防止与会议有关的跨站点脚本(XSS)攻击?Apr 23, 2025 am 12:16 AM

要保护应用免受与会话相关的XSS攻击,需采取以下措施:1.设置HttpOnly和Secure标志保护会话cookie。2.对所有用户输入进行输出编码。3.实施内容安全策略(CSP)限制脚本来源。通过这些策略,可以有效防护会话相关的XSS攻击,确保用户数据安全。

您如何优化PHP会话性能?您如何优化PHP会话性能?Apr 23, 2025 am 12:13 AM

优化PHP会话性能的方法包括:1.延迟会话启动,2.使用数据库存储会话,3.压缩会话数据,4.管理会话生命周期,5.实现会话共享。这些策略能显着提升应用在高并发环境下的效率。

什么是session.gc_maxlifetime配置设置?什么是session.gc_maxlifetime配置设置?Apr 23, 2025 am 12:10 AM

thesession.gc_maxlifetimesettinginphpdeterminesthelifespanofsessiondata,setInSeconds.1)它'sconfiguredinphp.iniorviaini_set().2)abalanceIsiseededeedeedeedeedeedeedto to to avoidperformance andununununununexpectedLogOgouts.3)

您如何在PHP中配置会话名?您如何在PHP中配置会话名?Apr 23, 2025 am 12:08 AM

在PHP中,可以使用session_name()函数配置会话名称。具体步骤如下:1.使用session_name()函数设置会话名称,例如session_name("my_session")。2.在设置会话名称后,调用session_start()启动会话。配置会话名称可以避免多应用间的会话数据冲突,并增强安全性,但需注意会话名称的唯一性、安全性、长度和设置时机。

您应该多久再生一次会话ID?您应该多久再生一次会话ID?Apr 23, 2025 am 12:03 AM

会话ID应在登录时、敏感操作前和每30分钟定期重新生成。1.登录时重新生成会话ID可防会话固定攻击。2.敏感操作前重新生成提高安全性。3.定期重新生成降低长期利用风险,但需权衡用户体验。

如何在PHP中设置会话cookie参数?如何在PHP中设置会话cookie参数?Apr 22, 2025 pm 05:33 PM

在PHP中设置会话cookie参数可以通过session_set_cookie_params()函数实现。1)使用该函数设置参数,如过期时间、路径、域名、安全标志等;2)调用session_start()使参数生效;3)根据需求动态调整参数,如用户登录状态;4)注意设置secure和httponly标志以提升安全性。

在PHP中使用会议的主要目的是什么?在PHP中使用会议的主要目的是什么?Apr 22, 2025 pm 05:25 PM

在PHP中使用会话的主要目的是维护用户在不同页面之间的状态。1)会话通过session_start()函数启动,创建唯一会话ID并存储在用户cookie中。2)会话数据保存在服务器上,允许在不同请求间传递数据,如登录状态和购物车内容。

您如何在子域中分享会议?您如何在子域中分享会议?Apr 22, 2025 pm 05:21 PM

如何在子域名间共享会话?通过设置通用域名的会话cookie实现。1.在服务器端设置会话cookie的域为.example.com。2.选择合适的会话存储方式,如内存、数据库或分布式缓存。3.通过cookie传递会话ID,服务器根据ID检索和更新会话数据。

See all articles

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

Video Face Swap

Video Face Swap

使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

安全考试浏览器

安全考试浏览器

Safe Exam Browser是一个安全的浏览器环境,用于安全地进行在线考试。该软件将任何计算机变成一个安全的工作站。它控制对任何实用工具的访问,并防止学生使用未经授权的资源。

Atom编辑器mac版下载

Atom编辑器mac版下载

最流行的的开源编辑器

EditPlus 中文破解版

EditPlus 中文破解版

体积小,语法高亮,不支持代码提示功能

SecLists

SecLists

SecLists是最终安全测试人员的伙伴。它是一个包含各种类型列表的集合,这些列表在安全评估过程中经常使用,都在一个地方。SecLists通过方便地提供安全测试人员可能需要的所有列表,帮助提高安全测试的效率和生产力。列表类型包括用户名、密码、URL、模糊测试有效载荷、敏感数据模式、Web shell等等。测试人员只需将此存储库拉到新的测试机上,他就可以访问到所需的每种类型的列表。