Symfony Messenger と Inspector バンドルで Symfony アプリケーションのスケーラビリティを強(qiáng)化

Symfony 開発者として、アプリケーションのパフォーマンスとスケーラビリティを最適化することが最重要です。 Symfony Messenger コンポーネントは、非同期タスク処理のための強(qiáng)力なソリューションを提供しますが、これらのバックグラウンド操作を監(jiān)視するのは困難な場(chǎng)合があります。 この記事では、Symfony Messenger のバックグラウンド ジョブを包括的に可視化し、手動(dòng)のログ分析やカスタム監(jiān)視コードの必要性を排除する Inspector バンドルの新機(jī)能を紹介します。

この新しい機(jī)能により、バックグラウンド タスクのあらゆる側(cè)面を自動(dòng)的に監(jiān)視できます。 実行時(shí)間やメモリ消費(fèi)量からデータベース クエリ、エラー、潛在的なボトルネックに至るまで、ユーザーフレンドリーなダッシュボードを通じて即座に洞察を得ることができます。すべて構(gòu)成は必要ありません。

開発者の典型的な課題は依然として殘っています。それは、非同期メッセージ処理を展開し、スムーズなバックグラウンド操作を期待することです。 Symfony Messenger は堅(jiān)牢ですが、バックグラウンド プロセスの監(jiān)視は歴史的に盲點(diǎn)でした。 この記事では、実裝の詳細(xì)を掘り下げて、日々の開発における大きなメリットを明らかにします。

キュー システムとは何ですか?

キュー システムは、現(xiàn)代の Web アプリケーションにおける重要な要素であり、時(shí)間のかかるタスクをメインの要求/応答サイクルから分離できるようになります。ユーザーのリクエスト中にリソースを大量に消費(fèi)する操作 (電子メールの送信、畫像処理、レポートの生成など) を処理する代わりに、これらのタスクはバックグラウンド ワーカーによる非同期処理のためにキューに入れられます。 これにより、ユーザーが長(zhǎng)時(shí)間の操作を待たなくなるため、アプリケーションの応答性が向上し、同時(shí)タスク処理を制御することでリソース管理が強(qiáng)化されます。 キュー システムには、タスクが失敗した場(chǎng)合の信頼性を高めるために、再試行メカニズムが組み込まれていることがよくあります。 アプリケーションが拡大するにつれて、インフラストラクチャのコストを増大させることなくより多くのユーザーにサービスを提供するには、このアプローチの採(cǎi)用が不可欠になります。

Symfony メッセンジャーコンポーネント

Symfony Messenger コンポーネントは、Symfony フレームワーク內(nèi)に組み込まれた強(qiáng)力なキュー システムです。これにより、さまざまなキュー プロバイダー (AMQP、Redis、Doctrine) からのメッセージのパブリッシュと消費(fèi)が容易になります。メッセージは、タスクを表すデータを含む単純なクラスです。

メッセージの例は次のとおりです:

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 が特定のメッセージのハンドラーを識(shí)別する方法です。 messenger:consume コマンドは、バックグラウンド ワーカーを?qū)g行してキューに入れられたメッセージを処理し、要求と応答のサイクルの外で適切なハンドラーを?qū)g行します。 メッセージを非同期にディスパッチするには:

namespace App\Messenger;

use Symfony\Component\Messenger\Attribute\AsMessageHandler;

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

メッセンジャーは、自動(dòng)メッセージ シリアル化、ミドルウェア サポート、再試行戦略などの機(jī)能により、複雑な非同期処理を簡(jiǎn)素化します。

Symfony メッセンジャー監(jiān)視ミドルウェア

ユーザーや開発者の視點(diǎn)を超えて動(dòng)作するバックグラウンド プロセスの監(jiān)視には、特有の課題が伴います。 ハンドラーにはどれくらいの時(shí)間がかかりますか?という疑問(wèn)が生じます。 コストのかかるデータベース操作が実行されていますか? バックグラウンドジョブはサイレントに失敗していますか?

Inspector は、メイン アプリケーションと同じ効率でバックグラウンド プロセスを監(jiān)視するための使いやすいインターフェイスを提供することで、これらの問(wèn)題に対処します。

Symfony Messenger ミドルウェアのアーキテクチャ

Inspector パッケージは、メッセージ処理の開始と終了を追跡するメッセンジャー ミドルウェアを登録します。メッセージ処理中にデータベース クエリやその他のアクションを収集するための既存の機(jī)能を利用します。 Symfony Messenger のミドルウェアはメッセージ処理のラッパーとして機(jī)能し、処理の前後にアクションを?qū)g行できます。 これには、責(zé)任連鎖設(shè)計(jì)パターンが利用されています。

Inspector ミドルウェアの実裝

ミドルウェアはメッセージ処理の前後にコードを?qū)g行するように実裝されています:

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

このプラグアンドプレイ コンポーネントは、アプリケーションの依存関係を更新する際のバックグラウンド プロセスの監(jiān)視を簡(jiǎn)素化します。

バージョン 1.5 へのアップグレード

バージョン 1.5 はマイナー リリースであり、composer update 経由で簡(jiǎn)単にインストールできます。 Messenger Monitoring は、コードを変更することなく自動(dòng)的に統(tǒ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 を使用して Symfony アプリケーションを監(jiān)視します

Inspector は、無(wú)料の HTTP モニタリング、データベース クエリの洞察、アラート転送を提供します。 Symfony パッケージをインストールするだけで開始できます。 詳細(xì)については、http://www.miracleart.cn/link/3a78f1864ab77dbd239fbe33cae90bbb

以上がSymfony Messenger モニタリングの紹介の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。