首页 > 杂文归档 正文
php之redis短线重连案例讲解

 2021-08-06 14:00:06     

php redis断线重连,pconnect连接失败问题
介绍
在swoole ,workerman等cli长连接模式下,遇到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) {
    https:// 断线重连
    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) {
https:// 断线重连
new self();
    }
}
return self::$_instance;
    }

Redis类完整代码

<?php
 
 
namespace lib;
 
 
class Redis
{
 
    private static $_instance; https://存储对象
    private function __construct( ){
$config = Config::get('redis');
self::$_instance = new \Redis();
https://从配置读取
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) {
https:// 断线重连
new self();
    }
}
return self::$_instance;
    }
 
https://    public static function getInstance( )
https://    {
https://try {
https://    if (!self::$_instance) {
https://new self();
https://    } else {
https://if (!self::$_instance->ping())
https://    new self();
https://    }
https://} catch (\Exception $e) {
https://    https:// 断线重连
https://    new self();
https://}
https://return self::$_instance;
https://    }
 
 
 
    /**
    * 禁止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

原文链接:http://www.yuepc.com/a/152411.html

http://www.yuepc.com 为 “沈一博客” 唯一官方服务平台,请勿相信其他任何渠道。

  •  标签: