xiaolin/swoole-queue

queue library for swoole

0.3.1 2018-09-19 08:19 UTC

Requires

• php: >=7.0
• ext-swoole: >=1.10
• phalcon/dd: ^1.1
• predis/predis: ^1.1
• psr/log: ^1.0

Requires (Dev)

• phpunit/phpunit: >=5.6

Suggests

• php: >=7.1

MIT

• 小林

README

执行测试

php run tests/queue.php
vendor/bin/phpunit

使用

class TestQueue extends Task
{
    // 消息队列Redis键值 list lpush添加队列
    protected $queueKey = 'test:queue:queue';
    // 延时消息队列的Redis键值 zset
    protected $delayKey = 'test:queue:delay';
    // pid地址
    protected $pidPath = TESTS_PATH . '/queue.pid';

    public $file = TESTS_PATH . '/test.cache';

    /**
     * @param $recv
     * @return mixed|void
     */
    protected function handle($recv)
    {
        File::getInstance()->put($this->file, 'upgrade');
    }
}

$queue = new TestQueue();
$queue->setRedisConfig(127.0.0.1, 'xiaolin', 1, 8366)
    ->run();
    
$this->redis->lPush('test:queue:queue', 'xxxx');