配置队列

config/queue.php 大概长这个样子，有几种队列可以选择，这里直接去 .env 文件中修改 QUEUE_CONNECTION = redis

  1. <?php
  3. return [
  5.     'default' => env('QUEUE_CONNECTION', 'sync'),
  7.     'connections' => [
  9.         'sync' => [
  10.             'driver' => 'sync',
  11.         ],
  13.         'database' => [
  14.             'driver' => 'database',
  15.             'table' => 'jobs',
  16.             'queue' => 'default',
  17.             'retry_after' => 90,
  18.         ],
  20.         'beanstalkd' => [
  21.             'driver' => 'beanstalkd',
  22.             'host' => 'localhost',
  23.             'queue' => 'default',
  24.             'retry_after' => 90,
  25.             'block_for' => 0,
  26.         ],
  28.         'sqs' => [
  29.             'driver' => 'sqs',
  30.             'key' => env('AWS_ACCESS_KEY_ID'),
  31.             'secret' => env('AWS_SECRET_ACCESS_KEY'),
  32.             'prefix' => env('SQS_PREFIX', 'https://sqs.us-east-1.amazonaws.com/your-account-id'),
  33.             'queue' => env('SQS_QUEUE', 'your-queue-name'),
  34.             'region' => env('AWS_DEFAULT_REGION', 'us-east-1'),
  35.         ],
  37.         'redis' => [
  38.             'driver' => 'redis',
  39.             'connection' => 'default',
  40.             'queue' => env('REDIS_QUEUE', 'default'),
  41.             'retry_after' => 90,
  42.             'block_for' => null,
  43.         ],
  45.     ],
  47.     'failed' => [
  48.         'database' => env('DB_CONNECTION', 'mysql'),
  49.         'table' => 'failed_jobs',
  50.     ],
  52. ];

配置 Redis

config/database.php 中 redis 的配置如下：

'redis' => [

    'client' => env('REDIS_CLIENT', 'predis'),

    'options' => [
        'cluster' => env('REDIS_CLUSTER', 'predis'),
        'prefix'  => Str::slug(env('APP_NAME', 'laravel'), '_') . '_database_',
    ],

    'default' => [
        'host'     => env('REDIS_HOST', '127.0.0.1'),
        'password' => env('REDIS_PASSWORD', null),
        'port'     => env('REDIS_PORT', 6379),
        'database' => env('REDIS_DB', 0),
    ],

    'cache' => [
        'host'     => env('REDIS_HOST', '127.0.0.1'),
        'password' => env('REDIS_PASSWORD', null),
        'port'     => env('REDIS_PORT', 6379),
        'database' => env('REDIS_CACHE_DB', 1),
    ],

],

安装依赖

使用 Redis 需要安装：

composer require predis/predis

生成任务类

php artisan make:job ProcessPodcast

TODO