Symfony 메신저 모니터링 소개-PHP 튜토리얼-php.cn

Symfony Messenger 및 Inspector 번들로 Symfony 애플리케이션 확장성을 강화하세요

Symfony 개발자로서 애플리케이션 성능과 확장성을 최적화하는 것이 무엇보다 중요합니다. Symfony Messenger 구성 요소는 비동기 작업 처리를 위한 강력한 솔루션을 제공하지만 이러한 백그라운드 작업을 모니터링하는 것은 어려울 수 있습니다. 이 기사에서는 Symfony Messenger 백그라운드 작업에 대한 포괄적인 가시성을 제공하여 수동 로그 분석이나 사용자 정의 모니터링 코드가 필요 없는 Inspector 번들의 새로운 기능을 소개합니다.

이 새로운 기능을 사용하면 백그라운드 작업의 모든 측면을 자동으로 모니터링할 수 있습니다. 실행 시간 및 메모리 소비부터 데이터베이스 쿼리, 오류 및 잠재적인 병목 현상에 이르기까지 사용자 친화적인 대시보드를 통해 즉각적인 통찰력을 얻을 수 있습니다. 모든 구성이 필요하지 않습니다.

일반적인 개발자의 과제는 비동기식 메시지 처리를 배포하고 원활한 백그라운드 작업을 기대하는 것입니다. Symfony Messenger는 강력하지만 백그라운드 프로세스 모니터링은 역사적으로 사각지대였습니다. 이 기사에서는 일상적인 개발에 있어 중요한 이점을 강조하기 위해 구현 세부 사항을 자세히 설명합니다.

큐 시스템이란 무엇인가요?

Introducing Symfony Messenger Monitoring

대기열 시스템은 최신 웹 애플리케이션에서 중요한 요소로, 시간 집약적인 작업을 기본 요청-응답 주기에서 분리할 수 있게 해줍니다. 사용자 요청(예: 이메일 전송, 이미지 처리, 보고서 생성) 중에 리소스를 많이 사용하는 작업을 처리하는 대신 이러한 작업은 백그라운드 작업자의 비동기 처리를 위해 대기열에 추가됩니다. 이를 통해 사용자가 긴 작업을 기다리지 않아도 되므로 애플리케이션 응답성이 향상되고 동시 작업 처리를 제어하여 리소스 관리가 향상됩니다. 대기열 시스템은 작업 실패 시 안정성을 위해 재시도 메커니즘을 통합하는 경우가 많습니다. 애플리케이션이 확장됨에 따라 인프라 비용을 증가시키지 않고 더 많은 사용자에게 서비스를 제공하려면 이 접근 방식을 채택하는 것이 필수적입니다.

심포니 메신저 구성요소

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는 자동 메시지 직렬화, 미들웨어 지원, 재시도 전략과 같은 기능을 통해 복잡한 비동기 처리를 단순화합니다.

심포니 메신저 모니터링 미들웨어

사용자 및 개발자 관점 외부에서 작동하는 백그라운드 프로세스를 모니터링하는 것은 고유한 과제를 제시합니다. 질문이 생깁니다: 핸들러는 얼마나 오래 걸리나요? 비용이 많이 드는 데이터베이스 작업을 수행하고 있습니까? 백그라운드 작업이 조용히 실패하고 있나요?

Inspector는 기본 애플리케이션과 동일한 효율성으로 백그라운드 프로세스를 모니터링할 수 있는 사용자 친화적인 인터페이스를 제공하여 이러한 문제를 해결합니다.

심포니 메신저 미들웨어 아키텍처

Inspector 패키지는 메시지 처리의 시작과 끝을 추적하기 위해 메신저 미들웨어를 등록합니다. 메시지 처리 중에 데이터베이스 쿼리 및 기타 작업을 수집하기 위한 기존 기능을 활용합니다. Symfony Messenger의 미들웨어는 메시지 처리에 대한 래퍼 역할을 하여 처리 전후에 작업을 수행할 수 있습니다. 이는 Chain of Responsibility 디자인 패턴을 활용합니다.

Inspector 미들웨어 구현

미들웨어는 메시지 처리 전후에 코드를 실행하도록 구현됩니다.

<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을 통해 쉽게 설치할 수 있습니다. 메신저 모니터링은 코드 변경 없이 자동으로 통합됩니다.

메시지 무시

노이즈를 줄이기 위해 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>

로그인 후 복사