异步队列

异步队列区别于 RabbitMQ Kafka 等消息队列，它只提供一种异步处理和异步延时处理的能力。

安装

  1. composer require hyperf/async-queue

配置

暂时只支持 Redis Driver。

配置类型默认值备注
driverstringHyperf\AsyncQueue\Driver\RedisDriver::class无
channelstringqueue队列前缀
retry_secondsint5失败后重新尝试间隔
processesint1消费进程数
  1. <?php
  3. return [
  4.     'default' => [
  5.         'driver' => Hyperf\AsyncQueue\Driver\RedisDriver::class,
  6.         'channel' => 'queue',
  7.         'retry_seconds' => 5,
  8.         'processes' => 1,
  9.     ],
  10. ];

使用

消费消息

组件已经提供了默认子进程，只需要将子进程配置到 processes.php 中即可。

  1. <?php
  3. return [
  4.     Hyperf\AsyncQueue\Process\ConsumerProcess::class,
  5. ];

发布消息

首先我们定义一个消息，如下

  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Jobs;
  7. use Hyperf\AsyncQueue\Job;
  9. class ExampleJob extends Job
  10. {
  11.     public function handle()
  12.     {
  13.         var_dump('hello world');
  14.     }
  15. }

发布消息

  2. <?php
  4. declare(strict_types=1);
  6. use Psr\Container\ContainerInterface;
  7. use Hyperf\AsyncQueue\Driver\DriverFactory;
  9. class DemoService
  10. {
  11.     protected $driver;
  13.     public function __construct(DriverFactory $driverFactory)
  14.     {
  15.         $this->driver = $driverFactory->get('default');
  16.     }
  18.     public function publish()
  19.     {
  20.         return $this->driver->push(new ExampleJon());
  21.     }
  22. }