初步使用小、巧、快消息队列组件beanstalkd

àì夳堔傛蜴生んèń 2022-05-28 01:49 163阅读 0赞

### 一、简介： ###

##### 1、Beanstalkd是什么？ #####

> Beanstalkd是一个高性能，轻量级的分布式内存队列，当你用过memcache,你会有种熟悉感觉，因为它是类似 memcached 的轻量级通讯协议，具有有很高的性能

##### 2、Beanstalkd特性 #####

1.  支持优先级(支持任务插队)
2.  延迟(实现定时任务)
3.  持久化(定时把内存中的数据刷到binlog日志)
4.  预留(把任务设置成预留，消费者无法取出任务，等某个合适时机再拿出来处理)
5.  任务超时重发(消费者必须在指定时间内处理任务，如果没有则认为任务失败，重新进入队列)
6.    
    上面介绍那么多个特性中，跟redis或者mysql中实现的消息队列的方法比较，其中最大特点就是可以**实现优先级**，还有**定时执行**。

### 二、安装 ###

##### 1、系统环境centos7 #####

rpm -Uvh http://download.fedoraproject.org/pub/epel/6/i386/epel-release-6-8.noarch.rpm  #安装额外的库 
    yum install beanstalkd --enablerepo=epel

##### 2、启动beanstalkd #####

/usr/bin/beanstalkd -l 0.0.0.0 -p 11300 -b /var/lib/beanstalkd/binlog -F

##### 3、后台启动 #####

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

### 三、php客户端调用 ###

##### 1、安装composer #####

> curl -sS https://getcomposer.org/installer | php
    > mv composer.phar /usr/local/bin/composer
    #墙内配置下源
    >composer config -g repo.packagist composer https://packagist.phpcomposer.com
    > composer require pda/pheanstalk

##### 2、常用方法 #####

###### 2.1、维护方法 ######

stats() 查看状态方法 listTubes() 目前存在的管道 listTubesWatched() 目前监听的管道 statsTube() 管道的状态 useTube() 指定使用的管道 statsJob() 查看任务的详细信息 peek() 通过任务ID获取任务

###### 2.2、生产者方法 ######

putInTube() 往管道中写入数据 put() 配合useTube()使用

###### 2.3、消费者方法 ######

watch() 监听管道，可以同时监听多个管道 ignore() 不监听管道 reserve() 以阻塞方式监听管道，获取任务 reserveFromTube() release() 把任务重新放回管道 bury() 把任务预留 peekBuried() 把预留任务读取出来 kickJob() 把buried状态的任务设置成ready kick() 批量把buried状态的任务设置成ready peekReady() 把准备好的任务读取出来 peekDelayed() 把延迟的任务读取出来 pauseTube() 给管道设置延迟 resumeTube() 取消管道延迟 touch() 让任务重新计算ttr时间，给任务续命

##### 3、具体简单使用 #####

查看信息，新建info.php

<?php require './vendor/autoload.php'; use Pheanstalk\Pheanstalk; $p = new Pheanstalk('127.0.0.1', 11300); //查看beanstalkd当前的状态信息 var_dump($p->stats());

结果：

![71c5c58dgy1fpccj611i3j20cu08baa0.jpg][]

生产者producer.php代码如下：

<?php require './vendor/autoload.php'; use Pheanstalk\Pheanstalk; //创建一个Pheanstalk对象 $p = new Pheanstalk('127.0.0.1', 11300); $data = array( 'id' => 1, 'name' => 'test', ); //向userReg管道中添加任务，返回任务ID //put()方法有四个参数 //第一个任务的数据 //第二个任务的优先级，值越小，越先处理 //第三个任务的延迟 //第四个任务的ttr超时时间 $id = $p->useTube('userReg')->put(json_encode($data)); //获取任务 $job = $p->peek($id); //查看任务状态 print_r($p->statsJob($job));

结果：

![71c5c58dgy1fpccl4uqybj20dh0bda9z.jpg][]

消费者consumer.php代码如下：

<?php
    require './vendor/autoload.php';
    
    use Pheanstalk\Pheanstalk;
    
    //创建一个Pheanstalk对象
    $p = new Pheanstalk('127.0.0.1', 11300);
    
    //监听userReg管道，忽略default管道
    $job = $p->watch('userReg')->ignore('default')->reserve();
    
    $data = json_decode($job->getData());
    //打印任务中的数据
    print_r($data);
    
    //最后删除任务，表示任务处理完成
    $p->delete($job);

结果：

![71c5c58dgy1fpccm16a3ij207q02q741.jpg][]

参考：

[官网][Link 1]

[https://segmentfault.com/a/1190000002784775][https_segmentfault.com_a_1190000002784775]

[https://www.cnblogs.com/mangoVic/p/6198077.html][https_www.cnblogs.com_mangoVic_p_6198077.html]

[https://github.com/pda/pheanstalk/][https_github.com_pda_pheanstalk]

[中文文档][Link 2]

[beanstalkd分享pdf文档][beanstalkd_pdf]

[71c5c58dgy1fpccj611i3j20cu08baa0.jpg]: /images/20220528/7f70f5ab37904d80b71435794497f9b0.png
[71c5c58dgy1fpccl4uqybj20dh0bda9z.jpg]: /images/20220528/f797625a0a464d3dbf1ee046ae5e10a0.png
[71c5c58dgy1fpccm16a3ij207q02q741.jpg]: /images/20220528/0a14df85718c49dc912174a46008234c.png
[Link 1]: https://kr.github.io/beanstalkd/
[https_segmentfault.com_a_1190000002784775]: https://segmentfault.com/a/1190000002784775
[https_www.cnblogs.com_mangoVic_p_6198077.html]: https://www.cnblogs.com/mangoVic/p/6198077.html
[https_github.com_pda_pheanstalk]: https://github.com/pda/pheanstalk/
[Link 2]: http://www.fzb.me/2015-3-21-beanstalkd-protocol-chinese-version.html
[beanstalkd_pdf]: http://ongx1e5a0.bkt.clouddn.com/Beanstalkd-share-slides.pdf