本文給大家介紹的是關(guān)于PHP項(xiàng)目中redis短線重連的實(shí)現(xiàn)，下文有給大家介紹redis短線重連以及兩種實(shí)現(xiàn)，都有具體的代碼及詳解供大家參考，需要的朋友可以參考了解看看，那么接下來(lái)就跟隨小編一起了解一下吧。

    在swoole ,workerman等cli長(zhǎng)連接模式下，遇到Redis異常斷開(kāi)，后面又開(kāi)啟的情況，一般得重新啟動(dòng)程序才能正常使用，本文介紹在不重啟服務(wù)，實(shí)現(xiàn)原來(lái)的Redis斷線重連

    原理

    Redis 斷開(kāi)的情況下調(diào)用

$Redis->ping()會(huì)觸發(fā)Notice錯(cuò)誤，Notice: Redis::ping(): send of 14 bytes failed with errno=10054

    當(dāng)獲取redis實(shí)例時(shí)，如果ping不通或者出現(xiàn)異常，就重新連接

    實(shí)現(xiàn)1

    因?yàn)閠ry catch  捕捉不到notice異常，所以ping不通直接重新連接，catch捕捉新連接的實(shí)例沒(méi)有連接上，下次執(zhí)行ping觸發(fā)

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;
    }

    實(shí)現(xiàn)2

    1.調(diào)用ping之前先拋出個(gè)notice異常，

    2.調(diào)用ping

    3.用error_get_last獲取最后一個(gè)錯(cuò)誤，如果錯(cuò)誤信息跟我們拋出的一樣，說(shuō)明ping通了，否則拋出個(gè)異常 ，讓catch捕捉到執(zhí)行重連，

    當(dāng)重連一次沒(méi)連上再次調(diào)用$_instance->ping()會(huì)直接拋出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; //存儲(chǔ)對(duì)象
    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(){}
 
    /**
     * 其他方法自動(dòng)調(diào)用
     * @param $method
     * @param $args
     * @return mixed
     */
    public function __call($method,$args)
    {
        return call_user_func_array([self::$_instance, $method], $args);
    }
 
    /**
     * 靜態(tài)調(diào)用
     * @param $method
     * @param $args
     * @return mixed
     */
    public static function __callStatic($method,$args)
    {
        self::getInstance();
        return call_user_func_array([self::$_instance, $method], $args);
    }
 
 
 
}

    調(diào)用

$this->handler = Redis::getInstance();
        $key    = $this->getCacheKey($name);
        $value = $this->handler->get($key);

    補(bǔ)充

    pconnect建立連接后重連失敗問(wèn)題

    經(jīng)測(cè)試長(zhǎng)連接下使用pconnect建立連接后，redis超時(shí)被動(dòng)斷開(kāi)了鏈接，

$res = self::$_instance->pconnect($config['host'], $config['port']); 

    $res 會(huì)返回true,但不是新建的鏈接，調(diào)用$res-get()會(huì)報(bào)錯(cuò)

    原因

    研究發(fā)現(xiàn)

    使用pconnect，鏈接在php進(jìn)程的整個(gè)生命周期內(nèi)被重用， close的作用僅是使當(dāng)前php不能再進(jìn)行redis請(qǐng)求，但無(wú)法真正關(guān)閉redis長(zhǎng)連接，連接在后續(xù)請(qǐng)求中仍然會(huì)被重用，直至fpm進(jìn)程生命周期結(jié)束。

    長(zhǎng)連接中只有進(jìn)程被停止，連接才會(huì)斷開(kāi)，所以連接斷開(kāi)時(shí)new不起作用，返回連接成功，而事實(shí)上已經(jīng)斷了，還是最早的那個(gè)連接，從而導(dǎo)致不能進(jìn)行后續(xù)讀取數(shù)據(jù)操作，所以長(zhǎng)連接中請(qǐng)使用connect。

    關(guān)于PHP項(xiàng)目中redis短線重連的實(shí)現(xiàn)就介紹到這，本文方法有一定的參考價(jià)值，感興趣的朋友可以參考，希望能對(duì)大家有幫助，想要了解更多PHP的內(nèi)容，大家可以關(guān)注其它的相關(guān)文章。