轻量级消息队列benastalkd

原创
2016/10/25 16:09
阅读数 1K

Beanstalkd设计里面的核心概念:

◆ job

一个需要异步处理的任务,是Beanstalkd中的基本单元,需要放在一个tube中。

◆ tube

一个有名的任务队列,用来存储统一类型的job,是producer和consumer操作的对象。

◆ producer

Job的生产者,通过put命令来将一个job放到一个tube中。

◆ consumer

Job的消费者,通过reserve/release/bury/delete命令来获取job或改变job的状态。 Beanstalkd中一个job的生命周期如图所示。一个job有READY, RESERVED, DELAYED, BURIED四种状态。当producer直接put一个job时,job就处于READY状态,等待consumer来处理,如果选择延迟put,job就先到DELAYED状态,等待时间过后才迁移到READY状态。consumer获取了当前READY的job后,该job的状态就迁移到RESERVED,这样其他的consumer就不能再操作该job。当consumer完成该job后,可以选择delete, release或者bury操作;delete之后,job从系统消亡,之后不能再获取;release操作可以重新把该job状态迁移回READY(也可以延迟该状态迁移操作),使其他的consumer可以继续获取和执行该job;有意思的是bury操作,可以把该job休眠,等到需要的时候,再将休眠的job kick回READY状态,也可以delete BURIED状态的job。正是有这些有趣的操作和状态,才可以基于此做出很多意思的应用,比如要实现一个循环队列,就可以将RESERVED状态的job休眠掉,等没有READY状态的job时再将BURIED状态的job一次性kick回READY状态。

一、安装beanstalkd

sudo apt-get install beanstalkd

源码安装 tar -zxvf /usr/bin/beanstalkd/beanstalkd-1.9.tar.gz cd beanstalkd make install PERFIX=/usr/bin/beanstalkd

后台启动:

beanstalkd -l 地址 -p 端口号 -z 最大的任务大小(byte) -c &

ps:如果是外部客户端连接,ip地址要写外网地址,这样才能连接上

例:/usr/bin/beanstalkd -l 192.168.50.233 -p 11311

二、示例

//1.链接benstalkd
require 'beanstalkd.php';
$baenstalkd=new beanstalkd();
$pheanstalk=$baenstalkd->getBeanstalkd('192.168.50.233','11311');
$tube='test';//tube名
//2.生产任务
$info=array('name'=>'tjj','sex'=>'男');
$ret=$baenstalkd->send2queue($pheanstalk,$tube,json_encode($info));//發送消息队列

//2.消费(处理任务) //消費队列消息

while($job=$pheanstalk->watch($tube)->ignore('default')->reserve()){
    $ret=$job->getData();
    var_dump($ret);
    $pheanstalk->delete($job);
    
}

三、上述代码下载https://git.oschina.net/tanjiajun/share.git

展开阅读全文
打赏
0
16 收藏
分享
加载中
更多评论
打赏
0 评论
16 收藏
0
分享
返回顶部
顶部