PHP使用Beanstalkd消息队列

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的核心元素

  • 管道(tube)
  • 任务(job) 
    Beanstalk核心元素管道与任务

Beanstalk的任务状态

  • ready 任务就绪,随时可以被消费
  • delayed 任务延迟,延迟时间到时进入ready状态
  • buried 任务预留,此状态会重新进入ready
  • delete 删除任务
  • reserved 任务正在消费中,此状态可以进入delayed、ready、buried、delete

Beanstalk的任务状态


PHP操作Beanstalkd需要安装Pheanstalk 
通过composer安装 composer require pda/pheanstalk

require 'vendor/autoload.php';

use Pheanstalk\Pheanstalk;

$pheanstalk = new Pheanstalk('127.0.0.1','11300');
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6

通过 new Pheanstalk(host, port) 可以得到Pheanstalk的实例来操作Beanstalkd

Pheanstalk类常用操作

  • stats() 查看队列状态
  • listTubes() 查看当前所有管道
  • statsTube(tubeName) 查看指定管道信息
  • statsJob(job) 查看指定任务信息
  • useTube(tubeName) 指定管道
  • put(Job, [priority]) 添加任务
  • putInTube(tubeName, Job, [priority]) 同useTube和put组合
  • delete(job) 删除任务
  • watch(tubeName) 设置要监听的管道,可以同时设置多个
  • reserve([time]) 以阻塞的方式监听管道,可以设置阻塞时间,不设置默认永久

栗子

选择demo管道添加一个任务 
然后打印管道状态

$pheanstalk->useTube('demo')->put("test");
print_r($pheanstalk->statsTube('demo'));
  • 1
  • 2

tube状态

current-jobs-ready表示当前ready状态的任务数量,其他current-jobs同理。 
total-jobs 表示当前管道所有任务数量 
current-using 当前有多少个生产者正在使用这个管道(使用useTube累计+1) 
current-watching 当前有多少个消费者正在使用这个管道(使用watch累计+1) 
current-waiting 当前有多少消费者正在等待任务(使用watch阻塞等待中累计+1)


监听demo管道,打印任务信息

    $job = $pheanstalk->watch('d$pheanstalk->delete($job);emo')->reserve();
    //一般任务被reserve读出后,业务处理完成时应及时进行delete操作,防止重新被放回管道
    print_r($pheanstalk->statsJob($job));
    //$pheanstalk->delete($job);
  • 1
  • 2
  • 3
  • 4

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

文章来源: PHP使用Beanstalkd消息队列

人吐槽 人点赞

猜你喜欢

发表评论

用户名: 密码:
验证码: 匿名发表

你可以使用这些语言

查看评论:PHP使用Beanstalkd消息队列