php之redis短線重連案例講解
php redis斷線重連,pconnect連接失敗問題
介紹
在swoole ,workerman等cli長連接模式下,遇到Redis異常斷開,后面又開啟的情況,一般得重新啟動程序才能正常使用,
本文介紹在不重啟服務(wù),實(shí)現(xiàn)原來的Redis斷線重連
原理
Redis 斷開的情況下調(diào)用
$Redis->ping()會觸發(fā)Notice錯誤,Notice: Redis::ping(): send of 14 bytes failed with errno=10054
當(dāng)獲取redis實(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之前先拋出個notice異常,
2.調(diào)用ping
3.用error_get_last獲取最后一個錯誤,如果錯誤信息跟我們拋出的一樣,說明ping通了,否則拋出個異常 ,讓catch捕捉到執(zhí)行重連,
當(dāng)重連一次沒連上再次調(diào)用$_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(){} /** * 其他方法自動調(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)測試長連接下使用pconnect建立連接后,redis超時被動斷開了鏈接,
$res = self::$_instance->pconnect($config['host'], $config['port']);
$res 會返回true,但不是新建的鏈接,調(diào)用$res-get()會報錯
原因
研究發(fā)現(xiàn)
使用pconnect,鏈接在php進(jìn)程的整個生命周期內(nèi)被重用, close的作用僅是使當(dāng)前php不能再進(jìn)行redis請求,但無法真正關(guān)閉redis長連接,連接在后續(xù)請求中仍然會被重用,直至fpm進(jìn)程生命周期結(jié)束。
長連接中只有進(jìn)程被停止,連接才會斷開,所以連接斷開時new不起作用,返回連接成功,而事實(shí)上已經(jīng)斷了,還是最早的那個連接,從而導(dǎo)致不能進(jìn)行后續(xù)讀取數(shù)據(jù)操作
所以長連接中請使用connect
到此這篇關(guān)于php之redis短線重連案例講解的文章就介紹到這了,更多相關(guān)php之redis短線重連內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
WordPress中獲取指定分類及其子分類下的文章數(shù)目
這篇文章主要介紹了WordPress中獲取指定分類及其子分類下的文章數(shù)目的方法,文中總結(jié)了一些相關(guān)內(nèi)置函數(shù)的使用,需要的朋友可以參考下2015-12-12Laravel中表單size驗(yàn)證數(shù)字示例詳解
Laravel 的驗(yàn)證功能非常強(qiáng)大,基本上常見的需求都有對應(yīng)的驗(yàn)證規(guī)則,下面這篇文章主要給大家介紹了關(guān)于Laravel中表單size驗(yàn)證數(shù)字的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),需要的朋友可以參考下2018-07-07php獲取目標(biāo)函數(shù)執(zhí)行時間示例
這篇文章主要介紹了php獲取目標(biāo)函數(shù)執(zhí)行時間示例,需要的朋友可以參考下2014-03-03