php之redis短線重連案例講解

更新時(shí)間：2021年08月06日 10:43:02 作者：flysnownet

這篇文章主要介紹了php之redis短線重連案例講解,本篇文章通過簡(jiǎn)要的案例,講解了該項(xiàng)技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下

php redis斷線重連，pconnect連接失敗問題

介紹

在swoole ,workerman等cli長連接模式下，遇到Redis異常斷開，后面又開啟的情況，一般得重新啟動(dòng)程序才能正常使用，

本文介紹在不重啟服務(wù)，實(shí)現(xiàn)原來的Redis斷線重連

原理

Redis 斷開的情況下調(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í)例沒有連接上，下次執(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ò)誤信息跟我們拋出的一樣，說明ping通了，否則拋出個(gè)異常，讓catch捕捉到執(zhí)行重連，

當(dāng)重連一次沒連上再次調(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建立連接后重連失敗問題

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

$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)求，但無法真正關(guān)閉redis長連接，連接在后續(xù)請(qǐng)求中仍然會(huì)被重用，直至fpm進(jìn)程生命周期結(jié)束。

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

所以長連接中請(qǐng)使用connect

到此這篇關(guān)于php之redis短線重連案例講解的文章就介紹到這了,更多相關(guān)php之redis短線重連內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: