队列 1.0.1

Redis队列

投递消息

  1. ev('QueueSend', '队列名称', [参数])

消费,消费者在各模块jobs目录下,并实现\app\queue\Consumer接口

  1. //app\test\jobs\Test
  2. class Test implements \app\queue\Consumer
  3. {
  4. public $queue = 'test'; //队列名称
  5. public $connection = 'default';
  6. public function consume($data)
  7. {
  8. logs()->info('queue test, data is: ', $data);
  9. }
  10. }

该模块基于 https://github.com/webman-php/redis-queue

更新历史
  • 1.0.1
    6月前

    新增支持自定义消费者目录
    比如在模块根目录新增process.php文件, 重启后系统将开启8个进程处理constom_consumers目录下的消费者

    1. <?php
    2. return [
    3. 'constom_consumer' => [
    4. 'enable' => true,
    5. 'handler' => app\queue\process\Consumer::class,
    6. 'count' => 8,
    7. 'constructor' => [
    8. 'dir' => 'constom_consumers'
    9. ]
    10. ]
    11. ];
  • 1.0.0
    6月前
    首次发布
下载

模块信息
名称:队列
标识:queue
版本:1.0.1
作者:01Soft
私信Ta

Ta的其他作品