最近，我在使用 laravel 開發一個需要嚴格按照順序處理任務的項目時，遇到了一個棘手的問題。amazon 的 sqs fifo 隊列非常適合這種需求，但 laravel 的內置隊列驅動程序無法正確處理 fifo 隊列，這導致了任務處理的混亂和延遲。經過一番研究，我找到了 shiftonelabs/laravel-sqs-fifo-queue 這個包，它專門為 laravel 和 lumen 提供了對 amazon sqs fifo 隊列的支持。
安裝
使用 Composer 安裝這個包非常簡單：
composer require shiftonelabs/laravel-sqs-fifo-queue
對于 Laravel 9.x、10.x 和 11.x 版本，這個包支持自動包發現，因此無需手動注冊服務提供者。對于 Lumen 用戶，需要在 bootstrap/app.php 中手動注冊服務提供者。
配置
配置也很簡單，只需在 config/queue.php 文件中添加一個新的連接配置：
'sqs-fifo' => [ 'driver' => 'sqs-fifo', 'key' => env('AWS_Access_KEY_ID'), 'secret' => env('AWS_SECRET_ACCESS_KEY'), 'prefix' => env('SQS_FIFO_PREFIX', 'https://sqs.us-east-1.amazonaws.com/your-account-id'), 'queue' => env('SQS_FIFO_QUEUE', 'default.fifo'), 'suffix' => env('SQS_FIFO_SUFFIX'), 'region' => env('AWS_DEFAULT_REGION', 'us-east-1'), 'after_commit' => false, 'group' => 'default', 'deduplicator' => env('SQS_FIFO_DEDUPLICATOR', 'unique'), 'allow_delay' => env('SQS_FIFO_ALLOW_DELAY', false), ],
然后在 .env 文件中設置相應的環境變量。
使用
使用這個包與 Laravel 的內置隊列驅動程序非常相似，但需要注意一些 FIFO 隊列的特定功能，如消息分組和去重。可以通過 onMessageGroup() 方法為每個任務指定消息組，通過 withDeduplicator() 方法設置去重策略。
例如，定義一個任務類：
use ShiftOneLabsLaravelSqsFifoQueueBusSqsFifoQueueable; class ProcessCoin implements ShouldQueue { use InteractsWithQueue, Queueable, SqsFifoQueueable, SerializesModels; // ... }
然后在使用時可以這樣分派任務：
dispatch( (new AppJobsProcessCoin()) ->onMessageGroup('quarter') ->withDeduplicator('unique') );
優勢與效果
使用 shiftonelabs/laravel-sqs-fifo-queue 包后，我能夠輕松地將 FIFO 隊列集成到 Laravel 項目中，解決了任務處理順序的問題。它的配置簡單，使用靈活，能夠滿足不同環境下的需求。特別是消息分組和去重功能，使得任務處理更加高效和可靠。
總的來說，這個包大大提升了我的項目在處理順序敏感任務時的效率和穩定性。如果你在使用 Laravel 時也遇到了類似的 FIFO 隊列問題，不妨嘗試一下這個包，它可能會給你帶來意想不到的效果。
