PHP使用Redis实现队列

简单说一下队列的作用，例如注册账户需要验证邮件，用户填写邮件地址之后点击发送邮件验证码，此时请求到了后端服务，后端再调用程序请求 SMTP 发送邮件，此时发送可能需要一定时间，这个时间根据服务器性能 / 网络延迟耗时 / 远程 SMTP 服务相应时间 等相关因素，快则一秒不到，慢则可能几分钟，如果每个用户点了发送验证码就立即发送然后有了发送结果再反回给用户，可能会导致超时连接，如果不超时也会导致用户等待时间过长用户体验不好。 为了解决这些不能明确知道所需耗时的服务，就需要使用异步队列了。

首先需要在环境上安装 redis ，如果环境是 Windows 可以看这篇文章：Windows下安装Redis和Redis PHP扩展

也可以直接使用 PHPStudy 集成环境，如果是 Linux 可以直接看官方，或者这篇文章：Centos编译安装Redis

除了 Redis 其实还有很多工具都可以作为队列驱动，例如 MySql / MongoDb 等。

队列的核心思想就是，入栈出栈，左进右出 或 右进左出：

博主写的简易代码实现加入队列：

$redis = new Redis();

$redis->connect('127.0.0.1', 6379);

$redis->lpush('www_bubaijun_com_queue', $_GET['push'] ?? '测试数据');

echo '队列入栈成功 / 加入队列成功';

访问这个写好的 PHP 会返回 “队列入栈成功 / 加入队列成功”，再看看 Redis 已经存储的数据：

此时再依次访问：

http://localhost/queue_push.php?push=1

http://localhost/queue_push.php?push=2

同样会加 push 参数存入 Redis：

加入队列成功了，接下来就是要写一个消费队列的：

$redis = new Redis();

$redis->connect('127.0.0.1', 6379);

queueExecute($redis);

echo '执行成功';

function queueExecute($redis)
{
	$value = $redis->rpop('www_bubaijun_com_queue');

	if ($value) {
		file_put_contents('queue_execute.txt', $value . PHP_EOL, FILE_APPEND);

		return queueExecute($redis);
	} else {
		return true;
	}
}

先执行一下这个 PHP 文件，也可以使用 PHP CLI 形式执行：

PS E:\soft\phpstudy_pro\www> php queue_pop.php
执行成功

此时目录下会生成了一个 queue_execute.txt 文件，打开这个文件可以看到里面的数据：

测试数据
1
2

可以看到，存入到 Redis 的时候 “测试数据” 这个值是在最后面的，而写入到文件的时候是第一个被写入的，也就是先入队列的将会被先消费。

队列的业务逻辑写好之后，需要将这个命令写入定时任务：

php (可以在这加入绝对路径)queue_pop.php

可以将定时任务设置为一分钟执行一次，这里也说一下上面消费队列的递归作用，在一分钟执行这个 PHP 的时候，如果 Redis 列表（本文实现的队列是用的 Redis 列表类型 如果不懂可以去看看 Redis 文档或者这方面的教程）里面还有数据就会继续执行消费队列。