php之redis短线重连案例讲解
php redis断线重连，pconnect连接失败问题
介绍
在swoole ,workerman等cli长连接模式下，遇到Redis异常断开，后面又开启的情况，一般得重新启动程序才能正常使用，
本文介绍在不重启服务，实现原来的Redis断线重连
原理
Redis 断开的情况下调用
$Redis->ping()会触发Notice错误，Notice: Redis::ping(): send of 14 bytes failed with errno=10054当获取redis实例时，如果ping不通或者出现异常，就重新连接
实现1
因为try catch 捕捉不到notice异常，所以ping不通直接重新连接，catch捕捉新连接的实例没有连接上，下次执行ping触发
Redis server went away 异常
public static function getInstance( )
{
try {
if (!self::$_instance) {
new self();
} else {
if (!self::$_instance->ping())
new self();
}
} catch (\Exception $e) {
// 断线重连
new self();
}
return self::$_instance;
}实现2
1.调用ping之前先抛出个notice异常，
2.调用ping
3.用error_get_last获取最后一个错误，如果错误信息跟我们抛出的一样，说明ping通了，否则抛出个异常 ，让catch捕捉到执行重连，
当重连一次没连上再次调用$_instance->ping()会直接抛出Redis server went away异常让catch捕捉到
public static function getInstance( )
{
if (!self::$_instance) {
new self();
}
else{
try {
@trigger_error('flag', E_USER_NOTICE);
self::$_instance->ping();
$error = error_get_last();
if($error['message'] != 'flag')
throw new \Exception('Redis server went away');
} catch (\Exception $e) {
// 断线重连
new self();
}
}
return self::$_instance;
}Redis类完整代码
<?php
namespace lib;
class Redis
{
private static $_instance; //存储对象
private function __construct( ){
$config = Config::get('redis');
self::$_instance = new \Redis();
//从配置读取
self::$_instance->pconnect($config['host'], $config['port']);
if ('' != $config['password']) {
self::$_instance->auth($config['password']);
}
}
public static function getInstance( )
{
if (!self::$_instance) {
new self();
}
else{
try {
@trigger_error('flag', E_USER_NOTICE);
self::$_instance->ping();
$error = error_get_last();
if($error['message'] != 'flag')
throw new \Exception('Redis server went away');
} catch (\Exception $e) {
// 断线重连
new self();
}
}
return self::$_instance;
}
// public static function getInstance( )
// {
// try {
// if (!self::$_instance) {
// new self();
// } else {
// if (!self::$_instance->ping())
// new self();
// }
// } catch (\Exception $e) {
// // 断线重连
// new self();
// }
// return self::$_instance;
// }
private function __clone(){}
public function __call($method,$args)
{
return call_user_func_array([self::$_instance, $method], $args);
}
public static function __callStatic($method,$args)
{
self::getInstance();
return call_user_func_array([self::$_instance, $method], $args);
}
}调用
$this->handler = Redis::getInstance();
$key = $this->getCacheKey($name);
$value = $this->handler->get($key);补充
pconnect建立连接后重连失败问题
经测试长连接下使用pconnect建立连接后，redis超时被动断开了链接，
$res = self::$_instance->pconnect($config['host'], $config['port']); $res 会返回true,但不是新建的链接，调用$res-get()会报错
原因
研究发现
使用pconnect，链接在php进程的整个生命周期内被重用， close的作用仅是使当前php不能再进行redis请求，但无法真正关闭redis长连接，连接在后续请求中仍然会被重用，直至fpm进程生命周期结束。
长连接中只有进程被停止，连接才会断开，所以连接断开时new不起作用，返回连接成功，而事实上已经断了，还是最早的那个连接，从而导致不能进行后续读取数据操作
所以长连接中请使用connect
到此这篇关于php之redis短线重连案例讲解的文章就介绍到这了,更多相关php之redis短线重连内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
