README

phpque

轻量级且快速的Disque PHP客户端，无外部依赖。支持PHP 5.3、5.4、5.5、5.6和HHVM。

安装

composer require s12v/phpque

使用

<?php

use Phpque\Client;
use Phpque\Connection\ConnectionException;

require '../vendor/autoload.php';

try {
    // Connect to a server pool
    $client = new Client(['tcp://127.0.0.1:7711', 'tcp://127.0.0.1:7712']);

    // ... or to a single server
    $client = new Client('tcp://127.0.0.1:7711');
} catch (ConnectionException $e) {
    // Handle connection errors
    throw $e;
}

// Add a job with payload "some data" and timeout 1 sec
$client->addJob('test_queue', 'some data', 1000);

// Get a job from the queue
$job = $client->getJob(array('test_queue'));

// Acknowledge the job
$client->ackJob($job);

API

参考Disque文档和ClientInterface

开发

运行测试

./vendor/bin/phpunit

s12v / phpque

维护者

详细信息

README

phpque

安装

使用

API

开发