队列 1.0.2

支持Redis、RabbitMQ

安装后重启生效 php start.php restart -d

投递消息

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

消费，消费者在各模块jobs目录下，需要实现\app\queue\Consumer接口

  1. //app\test\jobs\Test
  2. class Test implements \app\queue\Consumer
  3. {
  4.     public $queue = 'test'; //队列名称
  6.     public $connection = 'default';
  8.     public $delay = true; // RabbitMQ延迟队列时
  10.     public function consume($data)
  11.     {
  12.         logs()->info('queue test, data is: ', $data);
  13.     }
  14. }

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

更新历史
  • 1.0.2
    2022-8-19

    新增支持RabbitMQ

  • 1.0.1
    2022-4-22

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

    1. <?php
    3. return [
    4.     'constom_consumer' => [
    5.         'enable' => true,
    6.         'handler' => app\queue\process\Consumer::class,
    7.         'count' => 8,
    8.         'constructor' => [
    9.             'dir' => 'constom_consumers'
    10.         ]
    11.     ]
    12. ];
  • 1.0.0
    2022-4-19
    首次发布
同意 《模块使用协议》
模块信息
名称：队列
标识：queue
版本：1.0.2
作者：Admin

Ta的其他作品