問題描述

用redis-queque 異步投遞 會(huì)連接超時(shí)

程序代碼

use Webman\RedisQueue\Client as RedisClient;

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

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

         //執(zhí)行的代碼
class msgQueue implements Consumer
{
    // 要消費(fèi)的隊(duì)列名
    public $queue = 'push_msg';

    // 連接名，對(duì)應(yīng) plugin/webman/redis-queue/redis.php 里的連接`
    public $connection = 'default';

    // 消費(fèi)
    public function consume($data)
    {

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

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

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

截圖報(bào)錯(cuò)信息里報(bào)錯(cuò)文件相關(guān)代碼

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