forseti/simple-queue

此包最新版本（1.1.1）没有可用的许可信息。

使用redis进行简单队列管理

维护者

详细信息

github.com/git-forseti/forseti-simple-queue

源代码

问题

安装: 39

依赖项: 0

建议者: 0

安全: 0

星星: 0

观察者: 16

分支: 2

开放问题: 0

1.1.1 2017-04-19 19:45 UTC

Requires

Requires (Dev)

Unknown License 895d0a04f2adb331ecf8c91dadcb9b79fdcfba74

  • Diego Saouda <diego.saouda.woop@forseit.com.br>

This package is not auto-updated.

Last update: 2024-09-28 19:25:55 UTC

README

项目目标是简化队列控制的使用。该项目受到Laravel Queue (illuminate/queue)的启发。

使用

客户端

<?php
require_once __DIR__ . '/../vendor/autoload.php';

$predis = new Predis\Client();
$queue = (new \Forseti\SimpleQueue\Connection($predis))->queue('queuename');

$job = new \Forseti\SimpleQueue\Job(['data' => 'value']);
$queue->push($job);

工作进程

<?php
require_once __DIR__ . '/../vendor/autoload.php';

$predis = new Predis\Client();
$connection = new \Forseti\SimpleQueue\Connection($predis);
$queue = $connection->queue('queuename');

while($job = $queue->pull()) {
    print_r($job);
    sleep(2);

    //remove da fila
    $queue->processed($job);
}

使用Composer安装

composer require forseti/simple-queue