hyperf/zh/async-queue.md

异步队列

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

安装

composer require hyperf/async-queue

配置

暂时只支持 Redis Driver。

配置	类型	默认值	备注
driver	string	Hyperf\AsyncQueue\Driver\RedisDriver::class	无
channel	string	queue	队列前缀
retry_seconds	int	5	失败后重新尝试间隔
processes	int	1	消费进程数

<?php

return [
    'default' => [
        'driver' => Hyperf\AsyncQueue\Driver\RedisDriver::class,
        'channel' => 'queue',
        'retry_seconds' => 5,
        'processes' => 1,
    ],
];

使用

消费消息

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

<?php

return [
    Hyperf\AsyncQueue\Process\ConsumerProcess::class,
];

发布消息

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

<?php

declare(strict_types=1);

namespace App\Jobs;

use Hyperf\AsyncQueue\Job;

class ExampleJob extends Job
{
    public function handle()
    {
        var_dump('hello world');
    }
}

发布消息

<?php

declare(strict_types=1);

use Psr\Container\ContainerInterface;
use Hyperf\AsyncQueue\Driver\DriverFactory;

class DemoService
{
    protected $driver;

    public function __construct(DriverFactory $driverFactory)
    {
        $this->driver = $driverFactory->get('default');
    }

    public function publish()
    {
        return $this->driver->push(new ExampleJon());
    }
}