# Ubuntu에서 Redis 설치
sudo apt update
sudo apt install redis-server

# Redis 서비스 시작
sudo systemctl start redis-server

composer require predis/predis

// 큐에 작업 추가하기 (Producer)
<?php
require 'vendor/autoload.php';

$redis = new Predis\Client();

// 작업 데이터 준비
$job = [
    'id' => uniqid(),
    'type' => 'email',
    'data' => [
        'to' => 'user@example.com',
        'subject' => '안녕하세요!',
        'body' => '큐 시스템 테스트 메일입니다.'
    ],
    'created_at' => time()
];

// 작업을 큐에 추가
$redis->lpush('email_queue', json_encode($job));
echo "작업이 큐에 추가되었습니다: " . $job['id'];
?>

// 큐에서 작업 처리하기 (Consumer)
<?php
require 'vendor/autoload.php';

$redis = new Predis\Client();

// 큐에서 작업 가져오기
$jobData = $redis->rpop('email_queue');

if ($jobData) {
    $job = json_decode($jobData, true);
    
    echo "작업 처리 중: " . $job['id'] . "\n";
    
    // 이메일 발송 로직 구현
    // mail($job['data']['to'], $job['data']['subject'], $job['data']['body']);
    
    echo "이메일이 발송되었습니다: " . $job['data']['to'] . "\n";
} else {
    echo "처리할 작업이 없습니다.\n";
}
?>

// 블로킹 방식으로 작업 처리하기
<?php
require 'vendor/autoload.php';

$redis = new Predis\Client();

echo "작업 대기 중...\n";

// 최대 30초 동안 대기하며 작업 가져오기
$result = $redis->brpop(['email_queue'], 30);

if ($result) {
    // $result[0]은 큐 이름, $result[1]은 작업 데이터
    $job = json_decode($result[1], true);
    
    echo "작업 처리 중: " . $job['id'] . "\n";
    
    // 이메일 발송 로직
    // ...
    
    echo "작업 완료!\n";
} else {
    echo "30초 동안 작업이 없었습니다.\n";
}
?>

-- 이메일 작업 테이블
CREATE TABLE email_jobs (
    id INT AUTO_INCREMENT PRIMARY KEY,
    status ENUM('pending', 'processing', 'completed', 'failed') DEFAULT 'pending',
    priority TINYINT DEFAULT 5,
    to_email VARCHAR(255) NOT NULL,
    subject VARCHAR(255) NOT NULL,
    body TEXT NOT NULL,
    template VARCHAR(100),
    data JSON,
    attempts TINYINT DEFAULT 0,
    last_error TEXT,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
);

-- 이메일 발송 로그 테이블
CREATE TABLE email_logs (
    id INT AUTO_INCREMENT PRIMARY KEY,
    email_job_id INT,
    status ENUM('sent', 'failed') NOT NULL,
    message TEXT,
    sent_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    FOREIGN KEY (email_job_id) REFERENCES email_jobs(id)
);

// app/Jobs/SendEmail.php
<?php

namespace App\Jobs;

use App\Models\EmailJob;
use App\Models\EmailLog;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Mail;
use Exception;

class SendEmail implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $emailJob;
    
    // 재시도 설정
    public $tries = 3;
    public $backoff = [30, 60, 120]; // 재시도 간격 (초)

    /**
     * 작업 인스턴스 생성
     */
    public function __construct(EmailJob $emailJob)
    {
        $this->emailJob = $emailJob;
        
        // 우선순위 설정
        if ($emailJob->priority <= 3) {
            $this->onQueue('high_priority_emails');
        } else if ($emailJob->priority <= 7) {
            $this->onQueue('normal_priority_emails');
        } else {
            $this->onQueue('low_priority_emails');
        }
    }

    /**
     * 작업 실행
     */
    public function handle()
    {
        try {
            // 작업 상태 업데이트
            $this->emailJob->status = 'processing';
            $this->emailJob->attempts += 1;
            $this->emailJob->save();
            
            // 템플릿 데이터 준비
            $data = json_decode($this->emailJob->data, true) ?? [];
            
            // 이메일 발송
            Mail::send($this->emailJob->template, $data, function ($message) {
                $message->to($this->emailJob->to_email)
                        ->subject($this->emailJob->subject);
            });
            
            // 성공 로그 기록
            $this->emailJob->status = 'completed';
            $this->emailJob->save();
            
            EmailLog::create([
                'email_job_id' => $this->emailJob->id,
                'status' => 'sent',
                'message' => '이메일 발송 성공'
            ]);
            
        } catch (Exception $e) {
            // 실패 처리
            $this->emailJob->status = 'failed';
            $this->emailJob->last_error = $e->getMessage();
            $this->emailJob->save();
            
            EmailLog::create([
                'email_job_id' => $this->emailJob->id,
                'status' => 'failed',
                'message' => $e->getMessage()
            ]);
            
            // 예외를 다시 던져서 큐 시스템이 재시도하도록 함
            throw $e;
        }
    }
    
    /**
     * 작업 실패 처리
     */
    public function failed(Exception $exception)
    {
        // 최대 재시도 횟수를 초과한 경우의 처리
        if ($this->attempts() >= $this->tries) {
            // 관리자에게 알림 등의 추가 처리
        }
    }
}

// app/Http/Controllers/EmailController.php
<?php

namespace App\Http\Controllers;

use App\Models\EmailJob;
use App\Jobs\SendEmail;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Validator;

class EmailController extends Controller
{
    /**
     * 이메일 발송 요청 처리
     */
    public function send(Request $request)
    {
        // 요청 유효성 검사
        $validator = Validator::make($request->all(), [
            'to_email' => 'required|email',
            'subject' => 'required|string|max:255',
            'template' => 'required|string',
            'priority' => 'integer|min:1|max:10',
            'data' => 'array'
        ]);
        
        if ($validator->fails()) {
            return response()->json(['errors' => $validator->errors()], 422);
        }
        
        // 이메일 작업 생성
        $emailJob = EmailJob::create([
            'to_email' => $request->to_email,
            'subject' => $request->subject,
            'body' => '', // 템플릿에서 생성됨
            'template' => $request->template,
            'data' => json_encode($request->data ?? []),
            'priority' => $request->priority ?? 5
        ]);
        
        // 큐에 작업 추가
        SendEmail::dispatch($emailJob);
        
        return response()->json([
            'message' => '이메일 발송 요청이 큐에 추가되었습니다.',
            'job_id' => $emailJob->id
        ]);
    }
    
    /**
     * 이메일 발송 상태 조회
     */
    public function status($id)
    {
        $emailJob = EmailJob::with('logs')->findOrFail($id);
        
        return response()->json([
            'status' => $emailJob->status,
            'attempts' => $emailJob->attempts,
            'last_error' => $emailJob->last_error,
            'logs' => $emailJob->logs
        ]);
    }
    
    /**
     * 실패한 이메일 재시도
     */
    public function retry($id)
    {
        $emailJob = EmailJob::findOrFail($id);
        
        if ($emailJob->status === 'failed') {
            $emailJob->status = 'pending';
            $emailJob->save();
            
            SendEmail::dispatch($emailJob);
            
            return response()->json([
                'message' => '이메일 발송이 재시도됩니다.'
            ]);
        }
        
        return response()->json([
            'message' => '재시도할 수 없는 상태입니다.'
        ], 422);
    }
}

# Supervisor 설정 파일 예시 (/etc/supervisor/conf.d/email-workers.conf)

[program:email-high-priority]
process_name=%(program_name)s_%(process_num)02d
command=php /path/to/artisan queue:work --queue=high_priority_emails --sleep=3 --tries=3
autostart=true
autorestart=true
numprocs=2
user=www-data
redirect_stderr=true
stdout_logfile=/path/to/logs/email-high-priority.log

[program:email-normal-priority]
process_name=%(program_name)s_%(process_num)02d
command=php /path/to/artisan queue:work --queue=normal_priority_emails --sleep=3 --tries=3
autostart=true
autorestart=true
numprocs=3
user=www-data
redirect_stderr=true
stdout_logfile=/path/to/logs/email-normal-priority.log

[program:email-low-priority]
process_name=%(program_name)s_%(process_num)02d
command=php /path/to/artisan queue:work --queue=low_priority_emails --sleep=3 --tries=3
autostart=true
autorestart=true
numprocs=1
user=www-data
redirect_stderr=true
stdout_logfile=/path/to/logs/email-low-priority.log