php之redis短线重连的示例分析

这篇文章主要介绍了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

调用ping之前先抛出个notice异常，

调用ping

用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编程频道，更多相关知识等着你来学习!