limingxinleo / x-swoole-queue
Queue library for swoole
Installs: 3 443
Dependents: 2
Suggesters: 0
Security: 0
Stars: 6
Watchers: 3
Forks: 1
Open Issues: 0
Requires
- php: >=7.0
- ext-swoole: >=1.10
- limingxinleo/x-console-color: ^1.0
- limingxinleo/x-redis: ^1.0
- limingxinleo/x-support-file: ^1.0
- psr/log: ^1.0
Requires (Dev)
- limingxinleo/support-str: ^1.0
- limingxinleo/x-trait-common: ^1.0
- phpunit/phpunit: >=5.6
Suggests
- php: >=7.1
README
安装
composer require limingxinleo/x-swoole-queue
基本使用办法
消息队列使用
<?php use Xin\Swoole\Queue\Job; $config = include TESTS_PATH . '/_ci/config.php'; $host = $config['redisHost']; $auth = $config['redisAuth']; $db = $config['redisDb']; $port = $config['redisPort']; $queue = new Job(); $queue->setRedisConfig($host, $auth, $db, $port) ->setPidPath(TESTS_PATH . 'queue2.pid') ->run();
消息类
<?php namespace Tests\Test\App; use Xin\Support\File; use Xin\Swoole\Queue\JobInterface; class TestJob implements JobInterface { public $data; public $file = TESTS_PATH . '/test.cache'; public function __construct($data) { $this->data = $data; } public function handle() { File::getInstance()->put($this->file, $this->data); } }
载入消费队列的方法
<?php use Tests\Test\App\TestJob; use Xin\Redis; $redis = Redis::getInstance(); $job = new TestJob('upgrade by test job!'); $redis->lPush('swoole:queue:queue', serialize($job));
高级使用办法
实现我们自己的消息队列类
<?php namespace Tests\Test\App; use Xin\Swoole\Queue\Job; class Queue extends Job { public function __construct() { $config = include TESTS_PATH . '/_ci/config.php'; $host = $config['redisHost']; $auth = $config['redisAuth']; $db = $config['redisDb']; $port = $config['redisPort']; $this->setRedisConfig($host, $auth, $db, $port); $this->setPidPath(TESTS_PATH . '/queue2.pid'); } }
启动我们的消息队列
<?php require __DIR__ . '/bootstrap.php'; use Tests\Test\App\Queue; $config = include TESTS_PATH . '/_ci/config.php'; $host = $config['redisHost']; $auth = $config['redisAuth']; $db = $config['redisDb']; $port = $config['redisPort']; $queue = new Queue(); $queue->run();
载入消费数据
<?php use Tests\Test\App\Queue; use Xin\Swoole\Queue\JobInterface; class TestJob implements JobInterface { public $msg; public function __construct($msg) { $this->msg = $msg; } public function handle() { echo $this->msg; } } $job = new TestJob('upgrade by test job, when the queue push it!'); $queue = new Queue(); $queue->push($job);