laravel队列
laravel的特性：laravel队列可以基于不同的后台存储服务提供统一的api，后台存储服务包括 Redis MySQL等。队列实现了业务解耦，异步处理，错误重试的功能。比如调用第三方api，无法保证api的可靠性，我们就需要用队列来重试，比如发送邮件，我们可以从主业务中解耦出来。
生成db文件
我们的失败任务会放到fail_job表，这个表不需要我们手动创建，执行以下命令即可
php artisan queue:table
如果使用redis 则不用
- 生成failed_jobs
如果失败的任务会存储表里面
php artisan queue:failed-table
- 生成表
php artisan migrate
- migrations会记录哪些表执行过，执行过的不在执行
配置文件
- .env
首先，我们需要在env中配置queue的连接方式，是Redis还是MySQL，我这里先以Redis为例。
QUEUE_CONNECTION=redis
- 在config/database.php里面配置redis的连接信息，默认使用default连接
'redis' => ['client' => env('REDIS_CLIENT', 'phpredis'),'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),],],
- 在config/queue.php配置queue的connections，我们先配置redis
'redis' => ['driver' => 'redis',//队列缓存服务器'connection' => 'default',//使用default的连接'queue' => env('REDIS_QUEUE', 'site_queue'),//队列名称'retry_after' => 90,//重试'block_for' => null,],
生成job
我们先创建一个job对象，用这个对象的api来消费和生产数据php artisan make:job SendQueueDemoMsg ,我计划是使用command命令每1秒生成一个时间戳给队列，队列打印时间戳
<?phpnamespace App\Jobs;use Exception;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;class SendQueueDemoMsg implements ShouldQueue
{use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;protected $data;/*** Create a new job instance.** @return void*/public function __construct($data){$this->data = $data;}/*** Execute the job.** @return void* @throws Exception*/public function handle(){if ($this->data < 9) {throw new Exception("随机数小于2");}echo PHP_EOL . "消费成功";}/*** 任务失败处理** @param Exception $exception* @return void*/public function failed(Exception $exception){// 失败时执行的逻辑，例如发送通知或者记录日志echo ("任务处理失败: " . $exception->getMessage()) . PHP_EOL;}
}生产消息
上面我们配置的队列的相关信息，接下来我们使用command来生产几条消息试一下。生成一个command文件 php artisan make:command QueueDemo。刚才我创建的队列实例接收的是article类型的数据，我们来发送一下。
<?phpnamespace App\Console\Commands;use App\Jobs\SendQueueDemoMsg;
use Illuminate\Console\Command;class QueueDemo extends Command
{/*** The name and signature of the console command.** @var string*/protected $signature = 'QueueDemo';/*** The console command description.** @var string*/protected $description = 'QueueDemo';/*** Create a new command instance.** @return void*/public function __construct(){parent::__construct();}/*** Execute the console command.** @return mixed*/public function handle(){while (1) {sleep(1);$rand_num = random_int(1, 10);$set = SendQueueDemoMsg::dispatch($rand_num)->onQueue("time_queue");var_dump($set);}}}查看Redis
因为我们用的Redis存储，是否存储成功，我们看Redis，我们发现有两个队列，一个是我们定义的art
> 127.0.0.1@6379 connected!
> keys *
queues:time_queue:notify
queues:time_queue
> llen queues:time_queue
37消费消息
- 那么我们怎么消费消息呢，我们使用以下命令，指定redis，就不再读取mysql了，指定队列名字，注意，如果不指定队列名，那么默认执行default的队列，default队列的名字在queue.php文件中命名的。
php artisan queue:work redis --queue=time_queue
- 记录消费失败的值
