PHP使用Beanstalkd消息队列
作者：
秒速五厘米
文章简介：
Beanstalkd，一个高性能、轻量级的分布式内存队列系统 安装参考GitHub：https://github.com/kr/beanstalkd 启动Beanstalkd : beanstalkd -l 127.0.0.1 -p 11300
Beanstalkd，一个高性能、轻量级的分布式内存队列系统 安装参考GitHub：https://github.com/kr/beanstalkd 启动Beanstalkd : beanstalkd -l 127.0.0.1 -p 11300
队列的使用场景：异步处理、系统解耦、定时处理。
Beanstalk的特性
1.优先级（priority）
2.延迟（delay）
3.持久化（persistent data）
4.预留（buried）
5.任务超时重发（time-to-run）
Beanstalk的核心元素
1.管道（tube）
2.任务（job）
Beanstalk的任务状态
1.ready 任务就绪，随时可以被消费
2.delayed 任务延迟，延迟时间到时进入ready状态
3.buried 任务预留，此状态会重新进入ready
4.delete 删除任务
5.reserved 任务正在消费中，此状态可以进入delayed、ready、buried、delete
PHP操作Beanstalkd需要安装Pheanstalk
通过composer安装 composer require pda/pheanstalk
require 'vendor/autoload.php';
use Pheanstalk\Pheanstalk;
$pheanstalk = new Pheanstalk('127.0.0.1','11300');通过 new Pheanstalk(host, port) 可以得到Pheanstalk的实例来操作Beanstalkd
Pheanstalk类常用操作
1.stats() 查看队列状态
2.listTubes() 查看当前所有管道
3.statsTube(tubeName) 查看指定管道信息
4.statsJob(job) 查看指定任务信息
5.useTube(tubeName) 指定管道
6.put(Job, [priority]) 添加任务
7.putInTube(tubeName, Job, [priority]) 同useTube和put组合
8.delete(job) 删除任务
9.watch(tubeName) 设置要监听的管道，可以同时设置多个
10.reserve([time]) 以阻塞的方式监听管道，可以设置阻塞时间,不设置默认永久
栗子
选择demo管道添加一个任务
然后打印管道状态
$pheanstalk->useTube('demo')->put("test");
print_r($pheanstalk->statsTube('demo'));
current-jobs-ready表示当前ready状态的任务数量，其他current-jobs同理。
total-jobs 表示当前管道所有任务数量
current-using 当前有多少个生产者正在使用这个管道（使用useTube累计+1）
current-watching 当前有多少个消费者正在使用这个管道（使用watch累计+1）
current-waiting 当前有多少消费者正在等待任务（使用watch阻塞等待中累计+1）
-----------------------------------------------------------------------------------------------
监听demo管道，打印任务信息
$job = $pheanstalk->watch('demo')->reserve();
//一般任务被reserve读出后，业务处理完成时应及时进行delete操作，防止重新被放回管道
print_r($pheanstalk->statsJob($job));
//$pheanstalk->delete($job);
id 为当前任务的唯一id
tube 为当前任务所在的管道
state 当前任务的状态
pri 当前任务的优先级，默认1024，数字越小优先级越大
age 表示当前任务存在秒数
delay 表示当前任务延迟秒数
ttr 表示任务超时时间，默认60秒
time-left 表示当前任务在reserved状态已经维持了多少秒，超过ttr时间将重新放回管道
file 如果没有开启文件缓存此处数值为0
reserves 已经被reserves次数
---------------------
视频教程：https://www.imooc.com/learn/912
原文：https://blog.csdn.net/luke__/article/details/79439264