PHP队列场景以及实现代码实例详解

PHP队列场景以及实现代码实例详解

什么是队列

队列是一种常用的数据结构，用来存储一系列等待处理的任务。队列通常用于异步处理，将任务添加到队列中后，就立刻返回响应给客户端，然后异步地执行队列中的任务。

队列的基本操作有添加（Push）和取出（Pop），具有先进先出（FIFO）的特点。

PHP队列的应用场景

在 PHP 应用开发中，有很多场景需要使用队列，下面列举了常见的场景。

1. 邮件队列

下单成功后，向用户发送订单信息的邮件。如果在同步的模式下，在邮件发送过程中，用户在前端的等待时间就会很长，而采用异步方式，可以将邮件发送任务添加到队列中，然后立刻返回响应给用户，后台再异步处理队列任务，提高了用户的交互体验。

2. 消息队列

在应用开发中，经常需要实现消息通知功能。当有新消息发送时，消息会立刻添加到消息队列中，然后异步处理消息队列，这样就可以保证即使消息量非常大，也能提供顺畅的消息发送服务。

3. 缓存队列

缓存队列的应用场景比较广泛，如：

• 图片缩略图生成
• PDF文档生成
• 商品图片处理等

在使用缓存队列时，缓存对象会被放入队列中，然后从队列中异步取出来处理。这样可以避免直接在页面中进行这些繁琐的操作而造成页面卡顿，提高了用户体验。

PHP队列的实现

在 PHP 中，有不少优秀的第三方队列，如：

• Beanstalkd
• RabbitMQ
• Redis

这里以 Beanstalkd 为例，下面介绍如何使用 PHP 和 Beanstalkd 实现队列。

1. 安装 Beanstalkd

先安装 Beanstalkd，具体可以参考官方文档：http://kr.github.io/beanstalkd/

2. 安装 pda/pheanstalk 库

使用 Composer 国内镜像安装：

composer config repo.packagist composer https://mirrors.aliyun.com/composer/

然后执行命令：

composer require pda/pheanstalk

3. 连接 Beanstalkd 服务端

require_once 'vendor/autoload.php';

use Pheanstalk\Pheanstalk;

$pheanstalk = new Pheanstalk('127.0.0.1');

4. 添加任务

$pheanstalk->useTube('my_queue')->put(json_encode(['id'=> 1, 'name'=> 'mark']));

5. 取出任务

$job = $pheanstalk->watch('my_queue')->reserve();
$payload = json_decode($job->getData());

// 处理任务

$pheanstalk->delete($job);

示例说明

下面给出两个示例，分别是邮件队列和消息队列的实现。

邮件队列示例

在邮件发送时采用异步的方式，将邮件加入到队列中，提高了页面的响应速度。

require_once 'vendor/autoload.php';

use Pheanstalk\Pheanstalk;

$pheanstalk = new Pheanstalk('127.0.0.1');

// 添加邮件任务到队列中
$pheanstalk->useTube('email')->put(json_encode([
    'to' => '[e-mail]',
    'subject' => 'Your order has been shipped',
    'body' => 'Hello, your order has been shipped. Thanks for your purchase!'
]));

// 取出队列中的邮件任务并发送邮件
$job = $pheanstalk->watch('email')->reserve();
$payload = json_decode($job->getData());

// 发送邮件
mail($payload->to, $payload->subject, $payload->body);

$pheanstalk->delete($job);

消息队列示例

使用消息队列的方式实现消息通知功能，可以提供即时通知服务。

require_once 'vendor/autoload.php';

use Pheanstalk\Pheanstalk;

$pheanstalk = new Pheanstalk('127.0.0.1');

// 发送消息到队列中
$pheanstalk->useTube('message')->put(json_encode([
    'to' => '[e-mail]',
    'content' => 'Hello, you have a new message!'
]));

// 取出队列中的消息并发送消息
$job = $pheanstalk->watch('message')->reserve();
$payload = json_decode($job->getData());

// 发送消息
sendNotification($payload->to, $payload->content);

$pheanstalk->delete($job);

以上就是 PHP 队列的场景以及实现代码的详解。