代码拉取完成，页面将自动刷新
redis-queue
composer install herosphp/redis-queue
composer vendor:publish "herosphp/redis-queue"
return [
'redis-queue' => [
'enable' => true,
'handler' => Consumer::class,
'count' => 1,
'constructor' => [
'consumer_dir' => APP_PATH.'queue',
],
],
];
<?php
declare(strict_types=1);
namespace app\queue;
use herosphp\plugin\queue\ConsumerInterface;
class DemoQueue implements ConsumerInterface
{
//要消费的队列名
public string $queue = 'demo';
// 连接名，对应 config/redis_queue.php 里的连接`
public string $connection = 'default';
public function consume(array $data): void
{
echo 'queue'.json_encode($data).PHP_EOL;
}
}
Client::send('demo', [1,2,3]); or Client::send('demo', [1,2,3],5); // delay 5s
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手