脚本宝典收集整理的这篇文章主要介绍了php之redis短线重连案例讲解，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。
php redis断线重连，pconnect连接失败问题
在swoole ,workerman等cli长连接模式下，遇到Redis异常断开，后面又开启的情况，一般得重新启动程序才能正常使用，
本文介绍在不重启服务，实现原来的Redis断线重连
Redis 断开的情况下调用
当获取redis实例时，如果ping不通或者出现异常，就重新连接
因为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;
}
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; // } /** * 禁止clone */ private function __clone(){} /** * 其他方法自动调用 * @param $method * @param $args * @return mixed */ public function __call($method,$args) { return call_user_func_array([self::$_instance, $method], $args); } /** * 静态调用 * @param $method * @param $args * @return mixed */ 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短线重连内容请搜索脚本宝典以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本宝典！
以上是脚本宝典为你收集整理的php之redis短线重连案例讲解全部内容，希望文章能够帮你解决php之redis短线重连案例讲解所遇到的问题。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。