README

具有不同事件结构的消费者队列 Illuminate 模式

安装

composer require arquivei/laravel-sqs-queue-connector

在您的 config/queue.php 文件中的 connections 部分添加队列配置

    'sqs-custom' => [
        'driver' => 'sqs-custom',
        'key' => env('AWS_KEY', 'your-public-key'),
        'secret' => env('AWS_SECRET', 'your-secret-key'),
        'prefix' => env('AWS_SQS_PREFIX', 'https://sqs.us-east-1.amazonaws.com/your-account-id'),
        'queue' => env('AWS_EVENTS_QUEUE', 'your-queue-name'),
        'region' => env('AWS_REGION', 'us-east-1'),
        'consumers' => [
            [
                'validation' => [
                    'key' => [],
                    'value' => '',
                ],
                'job' => YourConsumerJob::class,
            ],
            [
                'validation' => [
                    'key' => [],
                    'value' => '',
                ],
                'job' => YourConsumerJob::class,
            ],
        ],
    ],

重要

• 您的消费者应该实现接口： SqsQueueConnector\Queue\Contracts\SqsQueueInterface

用法

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use SqsQueueConnector\Queue\Contracts\SqsQueueInterface;

class ConsumerJob implements ShouldQueue, SqsQueueInterface
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    private $data;

    public function __construct(\stdClass $data)
    {
        $this->data = $data;
    }

    public function handle()
    {
        print_r([
            'data' => $this->data,
        ]);
    }
}

运行测试

$ vendor/phpunit/phpunit/phpunit tests

待办事项

• 为默认消费者添加验证
• 为单个消费者添加任何验证选项