用官方的redis-queue插件参考了官方的示例,队列数据是出现了,但是一直在wait,测试环境为win11
public function getOaList()
{
// 队列名
$queue = 'send-mail';
// 数据,可以直接传数组,无需序列化
$data = ['to' => 'tom@gmail.com', 'content' => 'hello'];
Redis::send($queue, $data);
}
declare(strict_types=1);
use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;
use PhpOffice\PhpSpreadsheet\Cell\Coordinate;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use PhpOffice\PhpSpreadsheet\Writer\Xlsx as WriterXlsx;
use Webman\RedisQueue\Consumer;
class ComputeOrder implements Consumer
{
/**
* 要消费的队列名
*
* @var string
*/
public $queue = 'send-mail';
/**
* 连接名,对应 plugin/webman/redis-queue/redis.php 里的连接
*
* @var string
*/
public $connection = 'default';
/**
* 队列消费操作
*
* @param array $data 操作数据
* @return mixed
*/
public function consume($data)
{
var_export($data);
logInfo('operation', " 传入参数", $data);
}



哥哥们,别看这个问题了,自己sb了,
namespace错了 或者 消费类 名称错误了吧
是的,复制了一份消费代码,没注意namespace没写