Phpredis के लिए एक त्रुटि हैंडलर लिखना

यह सब इस तथ्य के साथ शुरू हुआ कि हमारी कंपनी में हमने एक प्रॉक्सी / लोड बैलेंसर बनाने का फैसला किया, जो कुंजी के आधार पर एक विशेष रेडिस उदाहरण के लिए एक अनुरोध भेजेगा। चूँकि कुछ भी पूरी तरह से काम नहीं करता है, मूली के साथ काम करने वाली php में लिखी गई एक परियोजना (phpredis का उपयोग करके) इसी बैलेंसर के माध्यम से महत्वपूर्ण नियमितता के साथ महत्वपूर्ण त्रुटियों के साथ दुर्घटनाग्रस्त हो गया। काश, प्रॉक्सी हमेशा जटिल सर्वर प्रतिक्रियाओं को सही ढंग से एकत्र नहीं करता ...
हर 10 लाइनों के कोड में रेडिस के साथ काम करना, और कोशिश में हर कॉल को लपेटना, पकड़ने की थोड़ी सी भी इच्छा नहीं थी, लेकिन निरंतर क्रैश के साथ डिबगिंग बहुत सुविधाजनक नहीं थी। फिर मुझे रेडिस ऑब्जेक्ट को अपने साथ बदलने के लिए विचार आया, जिसके अंदर से मैं पहले से ही वास्तविक तरीकों को कॉल करूंगा ...

स्रोत वर्ग के सभी तरीकों को डुप्लिकेट करना स्वाभाविक है, बहुत महंगा है, और क्यों नहीं, क्योंकि एक अद्भुत __call तरीका है जिसे किसी ऑब्जेक्ट विधि को कॉल करते समय एक्सेस किया जाता है जो मौजूद नहीं है। इनपुट पर, हमें अनुरोधित विधि और तर्कों का एक नाम मिलता है, जिसके बाद हम call_user_func_array का उपयोग करके स्रोत ऑब्जेक्ट की वांछित विधि को सफलतापूर्वक कॉल करते हैं। इस प्रकार, कोशिश में लपेटें, पकड़ें, हमें केवल एक कॉल call_user_func_array की आवश्यकता है।
कुल __call विधि इस प्रकार है:

public function __call($name, $arguments) { $i=0; while(true) { try{ return call_user_func_array(array($this->obj, $name), $arguments); break; } catch (Exception $e) { $this->handle_exception($e,$name,$arguments); if($i<5) $i++; else die('5 time redis lug'); } } } 

यदि कोई त्रुटि होती है, तो हम इसे हैंडलर को भेजते हैं, और हम उसी विधि को कॉल करने के लिए फिर से प्रयास करते हैं। 5 असफल कॉल के बाद, हम प्रॉक्सी को पीड़ा देना बंद कर देते हैं और धूम्रपान लॉग पर जाते हैं ...

कक्षा का पहला संस्करण इस तरह देखा गया:

 class RedisErrHandler { private $obj; private $ip; private $port; private $timeout; public function __construct($ip,$port,$timeout=0) { $this->ip=$ip; $this->port=$port; $this->timeout=$timeout; $this->rconnect(); } private function rconnect() { $this->obj=new Redis; $this->obj->connect($this->ip,$this->port,$this->timeout) or die('Error connecting redis'); } public function __call($name, $arguments) { $i=0; while(true) { try{ return call_user_func_array(array($this->obj, $name), $arguments); break; } catch (Exception $e) { $this->handle_exception($e,$name,$arguments); if($i<5) $i++; else die('5 time redis lug'); } } } private function handle_exception($e,$name,$args) { $err=$e->getMessage(); $msg="Caught exception: ".$err."\tcall ".$name."\targs ".implode(" ",$args)."\n"; if($_SERVER['LOG']) { $handle2=fopen('redis_log.txt','a'); fwrite($handle2,date('H:i:s')."\t$msg"); fclose($handle2); } echo $msg; if(substr(trim($err),0,37)=='Caught exception: protocol error, got') die('bye'); $this->rconnect(); } } 

वह "प्रोटोकॉल त्रुटि" त्रुटि के साथ प्रस्थान पर प्रत्येक प्रस्थान पर "और" मर गया, क्योंकि यह ठीक ऐसी त्रुटियां थीं जिनके लिए हम शिकार थे।

इसके एकीकरण के लिए, सभी को प्रतिस्थापित किया जाना था

 $r=new Redis(); $r->connect('127.0.0.1',6379,10); 

पर

 $r=new RedisErrHandler('127.0.0.1',6379,10); 

इस विकल्प ने समय के लिए ठीक काम किया, जब तक कि एक बार स्क्रिप्ट मल्टी के साथ काम करते समय दुर्घटनाग्रस्त नहीं हुई। चूंकि फ़्रेड्रिस में लेनदेन के लिए एक अलग ऑब्जेक्ट आवंटित किया गया है, इसलिए यह स्पष्ट हो गया कि आपको इसके लिए एक आवरण भी लिखना होगा।
सबसे पहले, बहु विधि को उपरोक्त वर्ग में जोड़ा गया:

 public function multi($type) { return new RedisMultiErrHandler($this->obj,$type,$this->ip,$this->port,$this->timeout); } 

ठीक है, एक लेनदेन वस्तु में त्रुटियों को संभालने के लिए एक वर्ग लिखा गया है, पिछले एक के अनुरूप

 class RedisMultiErrHandler { private $obj; private $ip; private $port; private $timeout; private $m; private $type; private $commands; public function __construct(&$redis,$type,$ip,$port,$timeout=0) { $this->ip=$ip; $this->port=$port; $this->timeout=$timeout; $this->type=$type; $this->obj=$redis; $this->m=$this->obj->multi($type); } private function rconnect() { $this->obj=new Redis; $this->obj->connect($this->ip,$this->port,$this->timeout) or die('Error connecting redis'); $this->m=$this->obj->multi($this->type); } public function __call($name, $arguments) { $this->commands[]=array('name'=>$name, 'arguments'=>$arguments); return $this; } private function handle_exception($e) { $err=$e->getMessage(); $msg=''; foreach($this->commands as $command) { $msg.="Multi sent\tcall ".$command['name']."\targs ".implode(" ",$command['arguments'])."\n"; } $msg.="Caught exception: ".$err."\n"; if($_SERVER['LOG']) { $handle2=fopen('redis_multi_log.txt','a'); fwrite($handle2,date('H:i:s')."\t$msg"); fclose($handle2); } echo $msg; if(substr(trim($err),0,37)=='Caught exception: protocol error, got') die('bye'); $this->rconnect(); } public function exec() { $i=0; while(true) { foreach($this->commands as $command) { call_user_func_array(array($this->m, $command['name']), $command['arguments']); } try{ return $this->m->exec(); break; } catch (Exception $e) { $this->handle_exception($e); if($i<5) $i++; else die('5 time mredis lug'); } } } } 

प्रस्थान पर सभी लेनदेन आदेशों को फिर से भेजने में सक्षम होने के लिए, निष्पादन को छोड़कर सभी कॉल (), जो सीधे लेनदेन को पूरा करता है, को सरणी में दर्ज किया गया था और बाद में कॉल किए जाने पर सर्वर को भेजा गया था। हमारे कोड में त्याग का उपयोग नहीं किया जाता है क्योंकि कक्षा में यह अलग से नहीं खड़ा हो सकता है।

यह देखते हुए कि कभी-कभी, हालांकि बेहद मुश्किल से, मूली कनेक्शन का उपयोग किए बिना भी मूली कनेक्शन फ्रीज हो जाता है, रैपर डेटा आज तक सफलतापूर्वक उपयोग किया गया है।