TP5框架使用Redis进行队列处理（tp5使用redis入列）

TP5框架使用Redis进行队列处理

队列处理是一种常见的操作，在许多网站中，都有对短信发送，邮件发送，日志存储等业务的定时队列处理任务需求。TP5框架可以使用Redis作为队列的处理服务器，非常灵活且高效。

Redis是一种高性能的key-value数据库，在功能上可以看成是一个支持多种数据结构的专用服务器，而它能够实现高性能是因为它对数据的存储采用内存，而不是一般的硬盘存储。Redis一般用于存储文本或者对象，也可以用于队列处理，支持多种数据结构，例如list,set,sorted set等，且可以进行快速的插入和取出，简单易用，因此在TP5框架中使用Redis来做定时队列处理更是合适的。

在使用TP5框架的定时任务队列处理中，首先需要安装Redis，对于windows用户可以下载Redis的安装包，在安装过程中需要勾选运行Redis服务。安装完成后，可使用如下代码连接Redis服务：

$redis = new \Redis();
$redis->connect("127.0.0.1", 6379);
$redis->auth("password");

安装完Redis以后，下面我们就可以使用TP5框架进行定时任务队列处理。使用ThinkPHP5中Job类是构建队列处理任务最简单的方式。Job类继承自think\queue\Job，可以用来构建基于Redis处理队列任务，使用之前我们需要配置job.php，如下代码：

return [
    'connector' =>  'Redis',   // Redis 驱动
    'expire'   =>  60,    // 任务的过期时间，默认为60秒; 若要禁用，则设置为 null
    'default'  =>  'default',  // 默认的队列名称
    'host'     =>  '127.0.0.1',  // redis 主机ip
    'port'     =>  6379,   // redis 端口
    'password' =>  '',    // redis 密码
    'select'   =>  0,    // 使用哪一个 db，默认为 db0
    'timeout'  =>  0,    // redis连接的超时时间
    'persistent' => false,   // 是否是长连接
];

完成上述配置之后，我们就可以使用下面的代码创建任务：

$jobHandlerClassName = 'app\index\job\Hello';
$jobData = ['msg'=>'foo'];
$isPushed =$ttsQueue->push(new $jobHandlerClassName(),$jobData);

以上代码将会创建一个任务，调用Hello类的execute方法，同时传递一个参数‘msg’，其中的参数最终被传递至 Hello 类的execute方法中。通过以上配置，TP5框架就可以实现基于Redis的队列任务了，从而节省大量的协调、控制任务复杂性。