使用redis-queue队列投递正常可以存入redis,消费时提示redis 连接超时
消费在哪里?
class MyMailSend implements Consumer { // 要消费的队列名 public $queue = 'test_dyj';
// 连接名,对应 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']); }
}
你使用的那个redis类?
use Webman\RedisQueue\Redis;
之前我们也遇到了这个问题,暂时是如下解决的:
config/plugin/webman/redis-queue/redis.php
options
'connect_timeout' => 60, // 链接超时时间,单位秒,默认为5s
报错相关源码在vendor/workerman/redis/src/Client.php,第443行附近
vendor/workerman/redis/src/Client.php
redis是否必须ssl链接
消费在哪里?
class MyMailSend implements Consumer
{
// 要消费的队列名
public $queue = 'test_dyj';
}
你使用的那个redis类?
use Webman\RedisQueue\Redis;
之前我们也遇到了这个问题,暂时是如下解决的:
config/plugin/webman/redis-queue/redis.php
options
中,添加'connect_timeout' => 60, // 链接超时时间,单位秒,默认为5s
报错相关源码在
vendor/workerman/redis/src/Client.php
,第443行附近redis是否必须ssl链接