Methods and parameter comments for operating Beanstalkd in PHP-PHP Tutorial-php.cn

Methods and parameter comments for operating Beanstalkd in PHP

不言

Release： 2023-04-02 18:08:02

Original

2424 people have browsed it

This article mainly introduces the methods and parameter comments about operating Beanstalkd in PHP. It has certain reference value. Now I share it with everyone. Friends in need can refer to it

Beanstalkd introduction

What is Beanstalkd

Beanstalk is a high-performance, lightweight distributed memory queue system. It was originally designed to reduce the page access of high-volume web application systems by asynchronously executing time-consuming tasks in the background. Delay, supported the Facebook Causes application with 9.5 million users.
Later open sourced, PostRank is now deployed and used on a large scale, processing millions of tasks every day. Beanstalkd is a typical Memcached-like design. The protocol and usage are the same, so users who have used memcached will feel that Beanstalkd looks familiar.

Beanstalkd running process

job typical life cycle

   put            reserve               delete
  -----> [READY] ---------> [RESERVED] --------> *poof*

Copy after login

job possible state migration

   put with delay               release with delay
  ----------------> [DELAYED] <------------.
                        |                   |
                 kick   | (time passes)     |
                        |                   |
   put                  v     reserve       |       delete
  -----------------> [READY] ---------> [RESERVED] --------> *poof*
                       ^  ^                |  |
                       |   \  release      |  |
                       |    `-------------&#39;   |
                       |                      |
                       | kick                 |
                       |                      |
                       |       bury           |
                    [BURIED] <---------------&#39;
                       |
                       |  delete
                        `--------> *poof*

Copy after login

Beanstalkd installation

Skip the installation, if necessary please refer to click reference

Note: Composer needs to be installed, tutorial link Composer installation method

Pheanstalk installation

The PHP third-party library used to operate Beanstalkd, the installation is skipped, if necessary, please refer to the reference

Pheanstalk operation

Connect Beanstalkd

<?php
require __DIR__ . &#39;/vendor/autoload.php&#39;;

use Pheanstalk\Pheanstalk;

/**
 * 实例化beanstalk
 * 参数依次为：ip地址 端口号默认11300 连接超时时间 是否长连接
 */
$pheanstalk = new Pheanstalk(&#39;127.0.0.1&#39;, 11300, 3, false);
?>

Copy after login

Beanstalkd status method

Beanstalkd status

$stats = $pheanstalk->stats();

Copy after login

Return:

Copy after login

Current pipeline list

$listTubes = $pheanstalk->listTubes();

Copy after login

View pipeline details

$stats = $pheanstalk->statsTube();

Copy after login

Return:

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
        )
)

Copy after login

View task details

$job =  $pheanstalk->watch(&#39;default&#39;)->reserve();
$job_stats = $pheanstalk->statsJob($job);

Copy after login

Return:

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 //释放预留任务次数
        )
)

Copy after login

View task details (by ID)

$job =  $pheanstalk->peek(1);
$job_stats = $pheanstalk->statsJob($job);

Copy after login

Beanstalkd producer method

Specify the pipeline to be used

$tube = $pheanstalk->useTube(&#39;default&#39;);

Copy after login

Insert data into the pipe

$tube = $pheanstalk->useTube(&#39;default&#39;);
$put = $tube->put(
    'hello, beanstalk', // 任务内容
    1024, // 任务的优先级
    10,  // 不等待直接放到ready队列中
    60 // 处理任务的时间
);

Copy after login

Or:

$pheanstalk->putInTube(&#39;default&#39;,  &#39;test1&#39;, 1024, 10, 60);

Copy after login

Beanstalkd consumer method

Listening pipe

$tube =  $pheanstalk->watch(&#39;user&#39;);

Copy after login

Remove pipes that do not need to be monitored

$tube =  $pheanstalk->watch(&#39;user&#39;)->ignore(&#39;default&#39;);

Copy after login

Listen to the pipe in a blocked manner

$job =  $pheanstalk->watch(&#39;user&#39;)->reserve(4); //堵塞时间为4秒

Copy after login

List all monitored pipes

$pheanstalk->listTubesWatched();

Copy after login

watch reserve method

$pheanstalk->reserveFromTube(&#39;default&#39;)

Copy after login

Delete the current task

$job =  $pheanstalk->watch(&#39;default&#39;)->reserve();
$pheanstalk->delete($job);

Copy after login

Reset the current task Put it into the pipe

$job =  $pheanstalk->watch(&#39;default&#39;)->reserve();
$pheanstalk->release($job);

Copy after login

to extend the life of the task (when the time to process the task is less than the current task execution time)

$job =  $pheanstalk->watch(&#39;default&#39;)->reserve();
$pheanstalk->touch($job);
//TODO

Copy after login

Reserve the task

$job =  $pheanstalk->watch(&#39;default&#39;)->reserve();
$pheanstalk->bury($job);

Copy after login

Release the reserved task (change to reday status)

$job = $pheanstalk->peekBuried(&#39;default&#39;);
$pheanstalk->kickJob($job);

Copy after login

Release reserved tasks in batches

$pheanstalk->userTube(&#39;default&#39;)->kick(999); //将id小于999的预留任务全部释放

Copy after login

Read the currently ready tasks (ready)

$job = $pheanstalk->peekReady(&#39;default&#39;);

Copy after login

Read the task currently in delayed state (delayed)

$job = $pheanstalk->peekDelayed(&#39;default&#39;);

Copy after login

Set delay for pipeline

$pheanstalk->pauseTube(&#39;default&#39;, 100); //设置100秒延迟

Copy after login

Cancel the delay on the pipeline

$pheanstalk->resumeTube(&#39;default&#39;);

Copy after login

The above is the entire content of this article, I hope it will be useful for everyone’s learning Help, please pay attention to the PHP Chinese website for more related content!

Related recommendations:

The intranet penetration application Spike implemented by PHP has been reconstructed

php calls phantomjs to WeChat Mini program sharing

The above is the detailed content of Methods and parameter comments for operating Beanstalkd in PHP. For more information, please follow other related articles on the PHP Chinese website!