問題描述

redis服務(wù)正常，通過非命令行工具執(zhí)行隊(duì)列可正常消費(fèi)

程序代碼

protected function execute(InputInterface $input, OutputInterface $output){
    $queue = 'send-email';
    $data = ['to' => 'joe@gmail.com', 'content' => 'hello'];
    Client::send($queue, $data);
    return self::SUCCESS;
}

報(bào)錯(cuò)信息

Fatal error: Uncaught Error: Call to a member function add() on null in D:\Develop\gitJect\admin-api\vendor\workerman\workerman\Connection\AsyncTcpConnection.php:215
Stack trace:
#0 D:\Develop\gitJect\admin-api\vendor\workerman\redis\src\Client.php(450): Workerman\Connection\AsyncTcpConnection->connect()
#1 D:\Develop\gitJect\admin-api\vendor\workerman\redis\src\Client.php(274): Workerman\Redis\Client->connect()
#2 D:\Develop\gitJect\admin-api\vendor\workerman\redis-queue\src\Client.php(76): Workerman\Redis\Client->__construct('redis://127.0.0...', Array)
#3 D:\Develop\gitJect\admin-api\vendor\webman\redis-queue\src\Client.php(45): Workerman\RedisQueue\Client->__construct('redis://127.0.0...', Array)
#4 D:\Develop\gitJect\admin-api\vendor\webman\redis-queue\src\Client.php(58): Webman\RedisQueue\Client::connection('default')
#5 D:\Develop\gitJect\admin-api\app\command\OceanAgent.php(50): Webman\RedisQueue\Client::__callStatic('send', Array)
#6 D:\Develop\gitJect\admin-api\vendor\symfony\console\Command\Command.php(298): ap in D:\Develop\gitJect\admin-api\vendor\workerman\workerman\Connection\AsyncTcpConnection.php on line 215

操作系統(tǒng)及workerman/webman等框架組件具體版本

開發(fā)環(huán)境
window11
php7.4.3
webman 1.5.0
redis-queue 1.2