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