摘要:后来开源,现在有大规模部署和使用,每天处理百万级任务。是典型的类设计,协议和使用方式都是同样的风格,所以使用过的用户会觉得似曾相识。
Beanstalkd介绍 什么是Beanstalkd
Beanstalk,一个高性能、轻量级的分布式内存队列系统,最初设计的目的是想通过后台异步执行耗时的任务来降低高容量Web应用系统的页面访问延迟,支持过有9.5 million用户的Facebook Causes应用。
后来开源,现在有PostRank大规模部署和使用,每天处理百万级任务。Beanstalkd是典型的类Memcached设计,协议和使用方式都是同样的风格,所以使用过memcached的用户会觉得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 Beanstalkd状态方法Beanstalkd状态
$stats = $pheanstalk->stats();
返回:
PheanstalkResponseArrayResponse Object ( [_name:PheanstalkResponseArrayResponse: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();
返回:
PheanstalkResponseArrayResponse Object ( [_name:PheanstalkResponseArrayResponse: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);
返回:
PheanstalkResponseArrayResponse Object ( [_name:PheanstalkResponseArrayResponse: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");
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/28870.html
摘要:的消费者,通过命令来获取或改变的状态。不再维持这些消息。持久化可以通过将及其状态记录到文件里面,在下次启动时可以通过读取来恢复之前的及状态。 一、安装 1、官网 https://kr.github.io/beanstalkd/ 2、安装 yum install beanstalkd --enablerepo=epel 3、启动 /usr/bin/beanstalkd -l 0.0.0....
摘要:说明队列配置文件存放在。每一种队列驱动的配置都可以在该文件中找到,包括数据库,,,,以及同步本地使用驱动。其中还包含了一个队列驱动用于那些放弃队列的任务。 showImg(https://segmentfault.com/img/remote/1460000012384126?w=888&h=280); 说明 队列配置文件存放在 config/queue.php。 每一种队列驱动的配...
摘要:项目地址框架目的基于和实现多进程处理消息队列。文件用于配置消息队列管道及其处理类项目配置文件文件夹下为方式运行下产生的日志内容是运行时的进程信息命令查看的状态信息查看的信息启动启动停止重启其它子进程异常退出时将会自动重启。 项目地址 SWBT框架 https://github.com/YWNA/SWBT 目的 基于Swoole和beanstalkd实现多进程处理消息队列。 安装 com...
摘要:几小时前刚刚发布的为队列功能提供了官方原生的驱动器,完全取代了本软件包的功能。不过这也并不意味着就是虚拟主机没戏,必须云主机起跳的小网站杀手。性能确实低下受制于,绝对禁止用于大数量高密度任务的场合。虚拟主机肯定不会提供。 几小时前刚刚发布的 Larevel 5.0 为队列功能提供了官方原生的database驱动器,完全取代了本软件包的功能。 对于Laravel 5及以上版本,本文的内...
摘要:上一篇文章讲了通道建议先去看上篇文章与把队列添加到数据表中把队列添加到内存中安装依赖安装到项目根目录修改访问路由数据将写入到内存中执行命令打开日志文件打印的消息完结下一篇文章讲能更直观的看到数据添加到内存中 上一篇文章讲了 database 通道 建议先去看上篇文章 1.beanstalkd 与 database database:把队列添加到数据表中beanstalkd:把队列添加到...
阅读 1974·2021-11-22 19:20
阅读 2618·2021-11-22 13:54
阅读 1932·2021-09-04 16:40
阅读 1814·2021-08-13 11:54
阅读 2628·2019-08-30 15:55
阅读 3456·2019-08-29 13:51
阅读 519·2019-08-29 11:09
阅读 2997·2019-08-26 14:06