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短线重连案例讲解的文章就介绍到这了,更多相关php之redis短线重连内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com！