什么是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;
// }
/**
* 禁止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短线重连？有什么作用呢？的介绍，本文内容仅供参考，有需要的朋友可以借鉴了解看看，希望对大家学习或工作，想要了解更多欢迎关注网络，小编每天都会为大家更新不同的知识。
声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！
若转载请注明出处： 什么是php之redis短线重连？有什么作用呢？
本文地址： https://pptw.com/jishu/652595.html