beanstalkd介绍什么是beanstalkdbeanstalk，一个高性能、轻量级的分布式内存队列系统，最初设计的目的是想通过后台异步执行耗时的任务来降低高容量web应用系统的页面访问延迟，支持过有9.5 million用户的facebook causes应用。
后来开源，现在有postrank大规模部署和使用，每天处理百万级任务。beanstalkd是典型的类memcached设计，协议和使用方式都是同样的风格，所以使用过memcached的用户会觉得beanstalkd似曾相识。
beanstalkd运行流程job典型的生命周期
put reserve delete -----> [ready] ---------> [reserved] --------> *poof*
job可能的状态迁移
put with delay release with delay ----------------> [delayed] <------------. | | kick | (time passes) | | | put v reserve | delete -----------------> [ready] ---------> [reserved] --------> *poof* ^ ^ | | | \ release | | | `-------------' | | | | kick | | | | bury | [buried] <---------------' | | delete `--------> *poof*
beanstalkd安装安装略过，如需请参考 点击参考
注：需要安装composer，教程链接 composer安装方法pheanstalk安装用于操作beanstalkd 的php 第三方库，安装略过，如需请参考 点击参考
pheanstalk操作连接beanstalkd<?phprequire __dir__ . '/vendor/autoload.php';use pheanstalk\pheanstalk;/** * 实例化beanstalk * 参数依次为：ip地址 端口号默认11300 连接超时时间 是否长连接 */$pheanstalk = new pheanstalk('127.0.0.1', 11300, 3, false);?>
beanstalkd状态方法beanstalkd状态
$stats = $pheanstalk->stats();
返回：
pheanstalk\response\arrayresponse object( [_name:pheanstalk\response\arrayresponse:private] => ok [storage:arrayobject:private] => array ( [current-jobs-urgent] => 0 //当前存在优先级的任务数 [current-jobs-ready] => 0 //当前准备就绪的任务数 [current-jobs-reserved] => 0 //当前处于阻塞的任务数 [current-jobs-delayed] => 0 //当前处于延迟状态的任务数 [current-jobs-buried] => 0 //当前预留的任务数 [cmd-put] => 0 //cmd命令为累计运行次数 [cmd-peek] => 0 [cmd-peek-ready] => 0 [cmd-peek-delayed] => 0 [cmd-peek-buried] => 0 [cmd-reserve] => 0 [cmd-reserve-with-timeout] => 0 [cmd-delete] => 0 [cmd-release] => 0 [cmd-use] => 0 [cmd-watch] => 0 [cmd-ignore] => 0 [cmd-bury] => 0 [cmd-kick] => 0 [cmd-touch] => 0 [cmd-stats] => 1 [cmd-stats-job] => 0 [cmd-stats-tube] => 0 [cmd-list-tubes] => 3 [cmd-list-tube-used] => 0 [cmd-list-tubes-watched] => 0 [cmd-pause-tube] => 0 [job-timeouts] => 0 //超时的任务 [total-jobs] => 0 //任务总数 [max-job-size] => 65535 //任务字符串大小 [current-tubes] => 1 //当前的管道数 [current-connections] => 1 //当前打开的连接数 [current-producers] => 0 //当前生产者数量 [current-workers] => 0 //当前消费者数量 [current-waiting] => 0 //发出reserved指令，但没有响应的数量 [total-connections] => 4 //累计链接数量 [pid] => 530 //beanstalkd进程id [version] => 1.10 [rusage-utime] => 0.003545 [rusage-stime] => 0.007473 [uptime] => 105855 //运行时间（秒） [binlog-oldest-index] => 0 [binlog-current-index] => 0 [binlog-records-migrated] => 0 [binlog-records-written] => 0 [binlog-max-size] => 10485760 [id] => 4199e3eca8bfdea8 [hostname] => lmmlwendemacbook-air.local ))
当前的管道列表
$listtubes = $pheanstalk->listtubes();
查看管道的详细信息
$stats = $pheanstalk->statstube();
返回：
pheanstalk\response\arrayresponse object( [_name:pheanstalk\response\arrayresponse:private] => ok [storage:arrayobject:private] => array ( [name] => default //当前管道名 [current-jobs-urgent] => 0 //当前管道存在优先级的任务数 [current-jobs-ready] => 0 //当前管道准备就绪的任务书 [current-jobs-reserved] => 0 //当前管道处于阻塞的任务数 [current-jobs-delayed] => 0 //当前管道处于延迟状态的任务数 [current-jobs-buried] => 0 //当前管道预留的任务数 [total-jobs] => 0 //当前管道总任务数 [current-using] => 1 //当前管道生产者数量 [current-watching] => 1 //当前管道消费者数量 [current-waiting] => 0 //发出reserved指令，但没有响应的数量 [cmd-delete] => 0 [cmd-pause-tube] => 0 [pause] => 0 [pause-time-left] => 0 ))
查看任务的详细信息
$job = $pheanstalk->watch('default')->reserve();$job_stats = $pheanstalk->statsjob($job);
返回：
pheanstalk\response\arrayresponse object( [_name:pheanstalk\response\arrayresponse:private] => ok [storage:arrayobject:private] => array ( [id] => 1 //任务job id [tube] => test //所处管道 [state] => reserved //当前状态 [pri] => 1024 //任务优先级（默认1024） [age] => 469 //任务存活时间（秒） [delay] => 0 //任务延迟时间（秒） [ttr] => 60 //任务执行时间 [time-left] => 59 //任务在reserve状态维持的秒数 [file] => 0 // binlog-4 默认-0 [reserves] => 2 //总共reserve次数 [timeouts] => 0 //任务超时次数 [releases] => 0 //重设任务次数 [buries] => 0 //预留次数 [kicks] => 0 //释放预留任务次数 ))
查看任务的详细信息（通过id）
$job = $pheanstalk->peek(1);$job_stats = $pheanstalk->statsjob($job);
beanstalkd生产者方法指定需要使用的管道
$tube = $pheanstalk->usetube('default');
向管道插入数据
$tube = $pheanstalk->usetube('default');$put = $tube->put( 'hello, beanstalk', // 任务内容 1024, // 任务的优先级 10, // 不等待直接放到ready队列中 60 // 处理任务的时间);
或者：
$pheanstalk->putintube('default', 'test1', 1024, 10, 60);
beanstalkd消费者方法监听管道
$tube = $pheanstalk->watch('user');
去除不需要监听的管道
$tube = $pheanstalk->watch('user')->ignore('default');
以堵塞的方式监听管道
$job = $pheanstalk->watch('user')->reserve(4); //堵塞时间为4秒
列出所有已经监听的管道
$pheanstalk->listtubeswatched();
watch + reserve 方法
$pheanstalk->reservefromtube('default')
删除当前任务
$job = $pheanstalk->watch('default')->reserve();$pheanstalk->delete($job);
将当前任务重新放入管道
$job = $pheanstalk->watch('default')->reserve();$pheanstalk->release($job);
为任务续命（当处理任务的时间小于当前任务执行时间时）
$job = $pheanstalk->watch('default')->reserve();$pheanstalk->touch($job);//todo
将任务预留
$job = $pheanstalk->watch('default')->reserve();$pheanstalk->bury($job);
将预留任务释放（变为reday状态）
$job = $pheanstalk->peekburied('default');$pheanstalk->kickjob($job);
批量将预留任务释放
$pheanstalk->usertube('default')->kick(999); //将id小于999的预留任务全部释放
读取当前准备就绪的任务（ready）
$job = $pheanstalk->peekready('default');
读取当前处于延迟状态的任务（delayed）
$job = $pheanstalk->peekdelayed('default');
对管道设置延迟
$pheanstalk->pausetube('default', 100); //设置100秒延迟
取消对管道的延迟
$pheanstalk->resumetube('default');
以上就是本文的全部内容，希望对大家的学习有所帮助，更多相关内容请关注！
相关推荐：
php实现的内网穿透应用spike重构完成
php调用phantomjs给微信小程序分享
以上就是php操作beanstalkd的方法及参数注释的详细内容。