📚 PHP 최상급 - 2주차: 메시지 큐 (Message Queue) 활용 - 03 PHP에서 메시지 큐 연동 및 활용 (Laravel Queue 등)

- 설명

안녕하세요. #PHP 최상급 과정 2주차에서는 메시지 큐를 #PHP 애플리케이션에 실제 연동하고 활용하는 구체적인 방법을 다룹니다. 특히, #PHP 생태계에서 가장 널리 사용되는 #Laravel 프레임워크의 #Queue 시스템을 중심으로 실습에 가까운 내용을 알아보겠습니다.

PHP 메시지 큐 연동의 이해

순수 #PHP 환경에서 #메시지 큐를 사용하려면, #RabbitMQ, #Redis, #Beanstalkd, #AWS SQS 등 원하는 메시지 브로커와 통신하기 위한 클라이언트 라이브러리를 설치하고 직접 코드를 작성해야 합니다.

🛠️ 주요 메시지 브로커와 PHP 라이브러리

• RabbitMQ: #AMQP(Advanced Message Queuing Protocol) 기반의 강력한 메시지 브로커로, #php-amqplib 라이브러리를 주로 사용합니다.

• Redis: 인메모리 데이터 구조 저장소이지만, 리스트(List) 자료구조를 활용하여 간단한 #작업 큐로 많이 활용됩니다. #Predis나 #phpredis 확장을 사용합니다.

• Beanstalkd: 가볍고 빠르며, 작업을 'Tube'에 저장하고 워커가 가져가는 방식으로 작동하는 전용 작업 큐입니다.

하지만 이러한 로우레벨(Low-Level) 연동은 복잡하고 오류 처리가 까다롭습니다. 이 문제를 해결하기 위해 많은 #PHP 프레임워크는 #추상화된 #Queue 컴포넌트를 제공합니다.

Laravel Queue 시스템: 연동 및 설정

#Laravel의 #Queue 시스템은 다양한 백엔드(브로커)를 일관된 #API로 사용할 수 있게 해주는 강력한 추상화 계층입니다.

⚙️ 설정 (config/queue.php)

Laravel의 큐 설정 파일에서는 여러 #큐 드라이버를 정의할 수 있습니다.

• sync: 큐를 사용하지 않고 작업을 즉시 실행 (개발 및 테스트용).

• database: 작업을 DB 테이블에 저장하고, 워커가 DB를 폴링하여 가져감 (간단한 환경에서 유용).

• redis: #Redis를 백엔드로 사용 (가장 빠르고 널리 사용되는 옵션 중 하나).

• rabbitmq/sqs/beanstalkd: 전용 브로커 드라이버 (설치 및 설정 필요).

예시 (Redis 드라이버 설정):

PHP

'redis' => [
    'driver' => 'redis',
    'connection' => 'default', // Redis 연결 설정 이름
    'queue' => 'default',      // 기본 큐 이름
    'retry_after' => 90,       // 재시도까지 대기 시간 (초)
    'block_for' => 5,          // 작업이 없을 때 최대 대기 시간 (초)
],

🧑‍💻 작업 (Job) 생성 및 디스패치

#큐에 넣을 작업은 Job 클래스로 정의합니다.

PHP

// app/Jobs/SendWelcomeEmail.php
namespace AppJobs;

use IlluminateBusQueueable;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;

class SendWelcomeEmail implements ShouldQueue
{
    use Dispatchable, Queueable;

    protected $user;

    public function __construct(User $user)
    {
        $this->user = $user;
    }

    // 실제 작업 로직을 수행하는 메서드
    public function handle()
    {
        // 이메일 발송 로직
        Mail::to($this->user->email)->send(new WelcomeMail());
    }
}

작업 디스패치: 컨트롤러나 서비스에서 작업을 큐에 넣습니다.

PHP

use AppJobsSendWelcomeEmail;

// ...
SendWelcomeEmail::dispatch($user); 
// 또는
SendWelcomeEmail::dispatch($user)->onQueue('emails'); // 특정 큐 지정

워커 프로세스 실행 및 관리

#Laravel은 #워커 프로세스를 구동하여 큐에 쌓인 작업을 처리합니다.

🏃 워커 구동

터미널에서 다음 명령어를 사용하여 워커를 실행합니다.

Bash

php artisan queue:work --tries=3 --timeout=60

• queue:work: 큐를 지속적으로 모니터링하며, 메시지를 가져오면 처리하고 종료하지 않고 다음 메시지를 기다립니다.

• --tries=3: 작업 실패 시 최대 3번까지 재시도합니다.

• --timeout=60: 작업이 60초를 초과하면 타임아웃 처리합니다.

🏭 워커 프로세스 관리

실제 운영 환경에서는 #PM2, #Supervisor 또는 #Laravel Horizon(Redis 기반 큐 관리 도구)와 같은 프로세스 관리 도구를 사용하여 워커 프로세스를 안정적으로 실행하고 모니터링해야 합니다.

• Supervisor: 워커 프로세스가 종료되거나 실패했을 때 자동으로 재시작하여 고가용성을 유지시켜 줍니다.

• Laravel Horizon: #Redis 큐 전용 대시보드로, #큐의 상태, #작업 처리량, #실패한 작업 등을 실시간으로 모니터링하고 관리할 수 있게 해줍니다.

작업 실패 처리와 재시도 (Retries)

비동기 작업은 네트워크 오류, 외부 서비스 장애 등 다양한 이유로 실패할 수 있습니다. 큐 시스템은 이러한 실패에 대응하는 메커니즘을 제공합니다.

🗑️ 실패한 작업 (Failed Jobs)

작업이 최대 재시도 횟수를 초과하여도 실패하면, 해당 작업은 #실패한 작업(Failed Jobs) 테이블(또는 별도의 저장소)로 이동합니다.

Bash

// 실패한 작업 목록 보기
php artisan queue:failed

// 실패한 특정 작업 재시도
php artisan queue:retry 123

💀 데드 레터 큐 (Dead Letter Queue, DLQ)

보다 전문적인 메시지 브로커(예: RabbitMQ, AWS SQS)를 사용할 경우, 재시도 후에도 처리되지 않은 메시지를 별도로 격리하는 데드 레터 큐 (DLQ) 기능을 활용하여 나중에 수동으로 분석하거나 처리할 수 있습니다.

Laravel의 Queue 시스템을 숙달하는 것은 #대규모 #PHP 애플리케이션의 성능과 안정성을 확보하는 데 필수적인 최상급 기술입니다.

무료체험, 끊김없이 빠른VPN VPN, 국내 다량IP, 모바일가능, 본사 품질관리 신뢰할 수 있는 보안성 높은 VPN 서비스

https://vpn.luzensoft.com