使用redis-queue隊(duì)列投遞正常可以存入redis,消費(fèi)時(shí)提示redis 連接超時(shí)
消費(fèi)在哪里?
class MyMailSend implements Consumer
{
// 要消費(fèi)的隊(duì)列名
public $queue = 'test_dyj';
// 連接名,對(duì)應(yīng) plugin/webman/redis-queue/redis.php 里的連接`
public $connection = 'default';
// 消費(fèi)
public function consume($data)
{
// 無(wú)需反序列化
var_export($data); // 輸出 ['to' => 'tom@gmail.com', 'content' => 'hello']
$key = 'test_dyj';
// Redis::set($key, '已消費(fèi)' . $data['content']);
}
}
之前我們也遇到了這個(gè)問(wèn)題,暫時(shí)是如下解決的:
config/plugin/webman/redis-queue/redis.php
options
中,添加'connect_timeout' => 60, // 鏈接超時(shí)時(shí)間,單位秒,默認(rèn)為5s
報(bào)錯(cuò)相關(guān)源碼在vendor/workerman/redis/src/Client.php
,第443行附近