用redis-queque 异步投递

问题描述

用redis-queque 异步投递 会连接超时

程序代码

use Webman\RedisQueue\Client as RedisClient;

        $msg .= "合:{$data['before_num']}{$num}={$data['after_num']}";
        $data['msg'] = $msg;

        RedisClient::send($queue, $data);

         //执行的代码
class msgQueue implements Consumer
{
    // 要消费的队列名
    public $queue = 'push_msg';

    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    // 消费
    public function consume($data)
    {

        //发送微信消息
        Wechat::wechat_msg($data['wx_id'] ?? '', $data['fromWxid'] ?? '', $data['msg']);
        // 无需反序列化
        // var_dump($data); // 输出 ['to' => 'tom@gmail.com', 'content' => 'hello']
    }
}

报错信息

2023-09-29 13:14:24 pid:10654 RedisException: Connection refused in phar:///www/wwwroot/118.178.238.162/webman.phar/vendor/illuminate/redis/Connectors/PhpRedisConnector.php:153

截图报错信息里报错文件相关代码

操作系统及workerman/webman等框架组件具体版本