Laravel进阶系列笔记--(八)Laravel 基于Reids的消息队列的使用
作者：温新
时间：2021-07-09
hi，我是温新，一名PHPer。
本篇文章紧接着 Laravel进阶系列笔记--(7)Laravel 基础数据库存储的消息队列的使用 篇文章，两篇文章之前的关系是紧密相连，同时，本篇 Redis消息队列的使用 是基于该篇的操作进行的。
基于Redis的队列任务
第一步：windows下安装Redis数据库与Redis扩展
关于Redis的安装请自行安装。
第二步：修改驱动为Redis
文件：.env
// 修改redis驱动
QUEUE_CONNECTION=redis
只要把驱动修改为
redis，其他的什么都不要动。没错，就是这样的简单，这样的优雅。
修改为Redis驱动，windows中打开Redis服务器与客户端。
第三步：创建任务类
php artisan make:job SendEamilToUser
该命令会在
app/Jobs目录下生成SendEamilToUser.php文件。
编辑SendEamilToUser.php文件进行消息队列任务的处理
<?php
namespace App\Jobs;
use App\Models\User;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Log;
class SendEamilToUser implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $user = null;
public function __construct(User $user)
{
$this->user = $user;
}
public function handle()
{
// 此处执行自定义任务
Log::info('发送邮件给 【' . $this->user->name . '】 用户成功' );
}
}
第四步：派发任务给队列
1）定义路由
// web.php
Route::get('queue', 'UserController@queue');
2）添加queue方法并编写任务代码
// UserController.php
use App\Jobs\SendEamilToUser;
public function queue()
{
$users = \App\Models\User::all();
foreach ($users as $user) {
// 为每个用户发送消息的任务
// 方式一
//dispatch(new SendEamilToUser($user));
// 方式二
SendEamilToUser::dispatch($user);
}
return '派发队列任务成功';
}
打开
jobs数据表就会看到相关的任务信息了。
3）访问路由添加队列任务
// 添加队列任务完成后，通过redis客户端进行查看。
127.0.0.1:6379> keys *
1) "laravel_database_queues:default:notify"
2) "laravel_database_queues:default"
127.0.0.1:6379> type laravel_database_queues:default:notify
list
第五步：执行队列任务
// 执行所有任务
php artisan queue:work
第六步：查询日志文件
[2021-07-09 13:35:43] local.INFO: 发送邮件给 【Dell Terry】 用户成功
[2021-07-09 13:35:43] local.INFO: 发送邮件给 【Thomas Bruen】 用户成功
如此，任务完成。
有没有注意到一个问题，要查看队列任务很不方便，与数据库相比，可观性太差了。好在，Laravel官方提供了Horizon扩展包解决了此问题。
可视化的Horizon队列系统解决方案
使用Horizon
第一步：安装Horizon
composer require laravel/horizon
报错： Install or enable PHP's pcntl extension.的解决方法
由于是在windows中，可能会报相关扩展的错误，错误如下：
- laravel/horizon[v5.7.0, ..., 5.x-dev] require ext-pcntl * -> it is missing from your system. Install or enable PHP's pcntl extension.
- Root composer.json requires laravel/horizon ^5.7 -> satisfiable by laravel/horizon[v5.7.0, ..., 5.x-dev].
解决方法如下：
1）打开composer.json文件，添加如下配置
"config": {
"optimize-autoloader": true,
"preferred-install": "dist",
"sort-packages": true,
"platform": {
"ext-pcntl": "7.2",
"ext-posix": "7.2"
}
},
2）安装
composer install
3）重新安装Horizon
第二步：发布资源并生成配置配置文件
php artisan horizon:install
config目录下生成horizon.php配置文件
第三步：访问后台
可以通过horizon路由对队列后台进行访问。
可以看到状态是Inactive未启动的状态，下面开始启动
第四步：运行Horizon
php artisan horizon
使用 php artisan horizon 报错：Call to undefined function Laravel\Horizon\Console\pcntl_async_signals()
很遗憾，pcntl扩展安装失败，虽然第一步的报错解决，显示也是安装成功，但是确实没有安装上。windows对此支持很是不友好，第四步无法执行成功。
windows下我没有找到解决方法，因此使用终端进行监控。
// 终端监控
php artisan queue:listen
到此使用horizon完毕
Horizon其他命令
暂停horizon
php artisan horizon:pause
继续horizon
php artisan horizon:continue
查看horizon状态
php artisan horizon:status
优雅的终止horizon
php artisan horizon:terminate
该命令会在所有当前正在执行的任务执行完成后退出horizon.
关于horizon还有一些其他的使用，请参考官方访访文档。
消息队列篇--完。
我是温新
每天进步一点点，就一点点