搜尋

首頁 >後端開發 >php教程 >PHP操作Beanstalkd的方法及參數註釋

PHP操作Beanstalkd的方法及參數註釋

不言
不言原創
2018-07-06 16:52:202461瀏覽

這篇文章主要介紹了關於PHP操作Beanstalkd的方法及參數註釋，有著一定的參考價值，現在分享給大家，有需要的朋友可以參考一下

Beanstalkd介紹

#什麼是Beanstalkd

Beanstalk，一個高性能、輕量級的分散式記憶體佇列系統，最初設計的目的是想透過後台非同步執行耗時的任務來降低高容量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      |  |
                       |    `-------------&#39;   |
                       |                      |
                       | kick                 |
                       |                      |
                       |       bury           |
                    [BURIED] <---------------&#39;
                       |
                       |  delete
                        `--------> *poof*

Beanstalkd安裝

安裝略過，如需請參考點擊參考

註：需要安裝Composer，教學連結Composer安裝方法

Pheanstalk安裝

用於操作Beanstalkd 的PHP 第三方函式庫，安裝略過，如需請參考點擊參考

# Pheanstalk操作

連接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);
?>

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(&#39;default&#39;)->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(&#39;default&#39;);

向管道插入資料

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

或：

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

Beanstalkd消費者方法

#監聽管道

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

移除不需要監聽的管道

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

# #以堵塞的方式監聽管道

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

列出所有已經監聽的管道

$pheanstalk->listTubesWatched();

watch reserve 方法

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

刪除目前任務

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

將目前任務重新放入管道

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

為任務續命（當處理任務的時間小於目前任務執行時間時）

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

將任務預留

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

#將預留任務釋放（變成reday狀態）

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

批次將預留任務釋放

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

讀取目前準備就緒的任務（ready）

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

讀取目前處於延遲狀態的任務（delayed）

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

對管道設定延遲

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

取消對管道的延遲#

$pheanstalk->resumeTube(&#39;default&#39;);
以上就是本文的全部內容，希望對大家的學習有所幫助，更多相關內容請關注PHP中文網！

相關推薦：

PHP實作的內網穿透應用Spike重構完成


php呼叫phantomjs給微信小程式分享

以上是PHP操作Beanstalkd的方法及參數註釋的詳細內容。更多資訊請關注PHP中文網其他相關文章！

陳述：
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
上一篇：利用Swoole同時更新多台伺服器的程式碼下一篇：利用Swoole同時更新多台伺服器的程式碼

相關文章

看更多