队列 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'; //队列名称
  5. public $connection = 'default';
  6. public $delay = true; // RabbitMQ延迟队列时
  7. public function consume($data)
  8. {
  9. logs()->info('queue test, data is: ', $data);
  10. }
  11. }

该模块基于 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
    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
    2022-4-19
    首次发布

模块信息
名称:队列
标识:queue
版本:1.0.2
作者:Admin

Ta的其他作品