php redis斷線重連，pconnect連接失敗問(wèn)題
介紹
在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類(lèi)完整代碼
?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之redis短線重連案例講解的文章就介紹到這了,更多相關(guān)php之redis短線重連內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- 詳解PHP解決守護(hù)進(jìn)程Redis假死
- thinkphp5redis緩存新增方法實(shí)例講解
- PHP使用Redis隊(duì)列執(zhí)行定時(shí)任務(wù)實(shí)例講解
- php基于redis的分布式鎖實(shí)例詳解
- Thinkphp5+Redis實(shí)現(xiàn)商品秒殺代碼實(shí)例講解
- PHP操作Redis常用命令的實(shí)例詳解
- php在linux環(huán)境中如何使用redis詳解
- php操作redis命令及代碼實(shí)例大全
