使用 Symfony Messenger 和 Inspector Bundle 增強(qiáng) Symfony 應(yīng)用程序可擴(kuò)展性

作為 Symfony 開發(fā)人員，優(yōu)化應(yīng)用程序性能和可擴(kuò)展性至關(guān)重要。 Symfony Messenger 組件為異步任務(wù)處理提供了強(qiáng)大的解決方案，但監(jiān)視這些后臺(tái)操作可能具有挑戰(zhàn)性。 本文介紹了 Inspector 包中的一項(xiàng)新功能，該功能提供對(duì) Symfony Messenger 后臺(tái)作業(yè)的全面可見性，無(wú)需手動(dòng)日志分析或自定義監(jiān)控代碼。

這項(xiàng)新功能可以自動(dòng)監(jiān)控后臺(tái)任務(wù)的各個(gè)方面。 從執(zhí)行時(shí)間和內(nèi)存消耗到數(shù)據(jù)庫(kù)查詢、錯(cuò)誤和潛在瓶頸，您可以通過(guò)用戶友好的儀表板獲得即時(shí)洞察 - 所有這些都需要零配置。

典型的開發(fā)人員挑戰(zhàn)仍然是：部署異步消息處理并希望后臺(tái)操作順利。 雖然 Symfony Messenger 很強(qiáng)大，但監(jiān)控后臺(tái)進(jìn)程歷來(lái)是一個(gè)盲點(diǎn)。 本文深入探討了實(shí)現(xiàn)細(xì)節(jié)，以強(qiáng)調(diào)對(duì)日常開發(fā)的顯著好處。

什么是隊(duì)列系統(tǒng)？

隊(duì)列系統(tǒng)是現(xiàn)代 Web 應(yīng)用程序中的關(guān)鍵元素，可以將時(shí)間密集型任務(wù)與主請(qǐng)求響應(yīng)周期分離。這些任務(wù)不是在用戶請(qǐng)求期間處理資源密集型操作（例如發(fā)送電子郵件、圖像處理、報(bào)告生成），而是排隊(duì)等待后臺(tái)工作人員異步處理。 這提高了應(yīng)用程序的響應(yīng)能力，因?yàn)橛脩舨槐氐却唛L(zhǎng)的操作，并通過(guò)控制并發(fā)任務(wù)處理來(lái)增強(qiáng)資源管理。 隊(duì)列系統(tǒng)通常包含重試機(jī)制，以確保任務(wù)失敗時(shí)的可靠性。 隨著應(yīng)用程序的擴(kuò)展，采用這種方法對(duì)于在不增加基礎(chǔ)設(shè)施成本的情況下為更多用戶提供服務(wù)變得至關(guān)重要。

Symfony Messenger 組件

Symfony Messenger 組件是 Symfony 框架內(nèi)的一個(gè)內(nèi)置的、強(qiáng)大的排隊(duì)系統(tǒng)。它有助于從各種隊(duì)列提供程序（AMQP、Redis、Doctrine）發(fā)布和使用消息。消息是包含表示任務(wù)的數(shù)據(jù)的簡(jiǎn)單類。

這是一條示例消息：

namespace App\Messenger;

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

從隊(duì)列中檢索消息時(shí)，相應(yīng)的處理程序會(huì)處理該消息：

namespace App\Messenger;

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

請(qǐng)注意 #[AsMessageHandler] 屬性以及 SmsNotification 方法中 __invoke 的類型提示。 這些是 Symfony 如何識(shí)別特定消息的處理程序。 messenger:consume 命令運(yùn)行后臺(tái)工作程序來(lái)處理排隊(duì)的消息并在請(qǐng)求-響應(yīng)周期之外執(zhí)行適當(dāng)?shù)奶??理程序。 異步發(fā)送消息：

namespace App\Messenger;

use Symfony\Component\Messenger\Attribute\AsMessageHandler;

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

Messenger 通過(guò)自動(dòng)消息序列化、中間件支持和重試策略等功能簡(jiǎn)化了復(fù)雜的異步處理。

Symfony Messenger 監(jiān)控中間件

監(jiān)控在用戶和開發(fā)人員視圖之外運(yùn)行的后臺(tái)進(jìn)程帶來(lái)了獨(dú)特的挑戰(zhàn)。 問(wèn)題出現(xiàn)了：處理程序需要多長(zhǎng)時(shí)間？ 是否正在執(zhí)行昂貴的數(shù)據(jù)庫(kù)操作？ 后臺(tái)作業(yè)是否會(huì)默默失?。?/p>

Inspector 通過(guò)提供用戶友好的界面來(lái)監(jiān)控后臺(tái)進(jìn)程，其效率與主應(yīng)用程序相同，從而解決了這些問(wèn)題。

Symfony Messenger 中間件架構(gòu)

Inspector 包注冊(cè)了一個(gè) Messenger 中間件來(lái)跟蹤消息處理的開始和結(jié)束。它利用現(xiàn)有功能在消息處理期間收集數(shù)據(jù)庫(kù)查詢和其他操作。 Symfony Messenger 中的中間件充當(dāng)消息處理的包裝器，允許在處理之前和之后執(zhí)行操作。 這利用了責(zé)任鏈設(shè)計(jì)模式。

檢查器中間件實(shí)現(xiàn)

中間件的實(shí)現(xiàn)是為了在消息處理之前和之后執(zhí)行代碼：

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

這個(gè)即插即用組件簡(jiǎn)化了更新應(yīng)用程序依賴項(xiàng)時(shí)的后臺(tái)進(jìn)程監(jiān)控。

升級(jí)到版本1.5

版本 1.5 是一個(gè)次要版本，可以通過(guò) composer update 輕松安裝。 Messenger 監(jiān)控自動(dòng)集成，無(wú)需更改代碼。

忽略消息

為了減少噪音，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 監(jiān)控您的 Symfony 應(yīng)用程序

Inspector 提供免費(fèi)的 HTTP 監(jiān)控、數(shù)據(jù)庫(kù)查詢洞察和警報(bào)轉(zhuǎn)發(fā)。 只需安裝 Symfony 包即可開始。 了解更多http://miracleart.cn/link/3a78f1864ab77dbd239fbe33cae90bbb

以上是Symfony Messenger 監(jiān)控簡(jiǎn)介的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！