funddy/worker

工作组件

维护者

详细信息

github.com/funddy/worker

主页

源码

问题

安装量: 1,415

依赖者: 0

建议者: 0

安全: 0

星标: 9

关注者: 2

分支: 0

开放问题: 0

v3.0.0 2015-09-12 13:07 UTC

Requires

Requires (Dev)

MIT 6be8c878805fa0d87139346588fef51419e5faff

  • Keyvan Akbary <keyvan.woop@funddy.com>

worker

This package is not auto-updated.

Last update: 2024-09-25 11:44:10 UTC

README

Build Status

基于Redis队列的简单异步工作库。

安装

composer require funddy/worker

用法

发布者

<?php

require 'vendor/autoload.php';

use Funddy\Worker\WorkerRedisClient\PredisWorkerRedisClient;
use Funddy\Worker\WorkQueue\RedisWorkQueue;
use Predis\Client;

$predisClient = new Client('tcp://');
$redisClient = new PredisWorkerRedisClient($predisClient);
$queue = new RedisWorkQueue('myqueue', $redisClient);

$queue->publish('Hello world!');

消费者

<?php

require 'vendor/autoload.php';

use Funddy\Worker\WorkerRedisClient\PredisWorkerRedisClient;
use Funddy\Worker\WorkQueue\RedisWorkQueue;
use Predis\Client;

$predisClient = new Client('tcp://');
$redisClient = new PredisWorkerRedisClient($predisClient);
$queue = new RedisWorkQueue('myqueue', $redisClient);

while(true) {
    $message = $queue->consume();//Blocking
    echo $message;
}