PHP या किसी अन्य चैट इतिहास में एसिंक्रोनस रूप से कार्य करें

मैं इस बात से बहुत प्रसन्न हूं कि पिछले कुछ वर्षों में पीएचपी कितनी तेजी से विकसित हुआ है। शायद आप भी। लगातार नए अवसर आते हैं जो उत्साही लोगों को इस मंच पर बने रहने से रोकते हैं। हाल ही में हैक की रिलीज के बारे में क्या खबर है।

निश्चित रूप से कोई भी इस लेख का शीर्षक पढ़कर मुस्कुराएगा और सोच सकता है: "महाशय विकृतियों के बारे में बहुत कुछ जानते हैं!" इस या उस भाषा की शीतलता के बारे में बहस कभी कम नहीं होती है, लेकिन जैसा कि यह हो सकता है, खुद के लिए मैं व्यक्तिगत रूप से भाषा को बदलने के लिए इतनी सारी स्थितियां नहीं देखता, क्योंकि मैं पूरी तरह से पूरे स्टैक को बदलने से पहले सभी संभावनाओं को निचोड़ना पसंद करता हूं। हाल ही में टॉरनेडो पर एक चैट बनाने के बारे में एक प्रकाशन था, और मैं इस बारे में बात करना चाहता था कि मैंने PHP का उपयोग करके इसी तरह की समस्या को कैसे हल किया।

प्रागितिहास

एक बढ़िया दिन, मैंने वेबस्केट्स को जानने का फैसला किया। मुझे प्रौद्योगिकी द्वारा अंतर्ग्रहीत किया गया था, हालांकि मैं यह नहीं कह सकता था कि यह केवल कल दिखाई दिया, और यह एक सामाजिक-संबंधित चैट सेवा के शुभारंभ के साथ हुआ, जो बहुत सारी खामियों से ग्रस्त था। इससे मुझे प्रतिस्पर्धी दौड़ में हिस्सा लेने का उत्साह मिला। वेब सॉकेट का उपयोग करना बिल्कुल नए और आशाजनक समाधान की तरह लग रहा था।

कनेक्शन निरंतर और द्विदिश स्थापित किया जाता है, और क्लाइंट पक्ष पर, कार्य को 4 ईवेंट्स में संसाधित करने के लिए कम किया जाता है: ओनोपेन , ऑन्क्लोज , ऑनरोर , और निश्चित रूप से ऑन्समेस । सेटअंटरवल, अत्यधिक ट्रैफ़िक और सर्वर लोड के माध्यम से कोई और अनुरोध नहीं।

मैं उन लोगों के लिए यहां एक छोटा सा विषयांतर करूं जो यह नहीं समझते कि यह किस बारे में है।
जो लोग 2000 के शुरुआती दौर से परिचित हैं, वे चैट सेवाओं की विविधता को याद कर सकते हैं, जहां सब कुछ धीमा हो गया और अजीब तरह से काम किया।
एजेक्स थोड़ी देर बाद दिखाई दिया और बहुत बेहतर हो गया, लेकिन संक्षेप में सिद्धांत बदल नहीं गया। क्लाइंट पार्ट ने अभी भी टाइमर के अनुसार एक निश्चित आवृत्ति पर सर्वर को तब तक प्रदूषित किया, जब तक कि डेटा के कम मात्रा में भेजे जाने के कारण iframes का उपयोग करने और सर्वर पर लोड को कम करने से इनकार करना संभव नहीं था।
दरअसल, जिस चैट सर्विस का जिक्र किया गया वह एक क्लासिक अजाक्स चैट थी।

चुने हुए दृष्टिकोण में सत्य और सिक्के का दूसरा पहलू है:

• पुराने ब्राउज़र पर समर्थन की कमी
• कनेक्शन के रखरखाव का मैनुअल नियंत्रण
• सर्वर डेमॉन उपयोग

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

1. आप केवल डेमॉन को पुनरारंभ करके कोड को अपडेट कर सकते हैं - तदनुसार, चैटलैन के लिए, यह एक डिग्री या किसी अन्य के लिए होता है
2. घातक त्रुटियां और अनियंत्रित अपवाद के कारण डेमॉन क्रैश हो जाता है - कोड को "बुलेटप्रूफ" लिखा जाना चाहिए
3. डेमॉन को एक समर्पित मुक्त बंदरगाह का उपयोग करना चाहिए - यह उन लोगों के लिए एक समस्या है जो एक सख्त फ़ायरवॉल के पीछे बैठे हैं
4. गैर-अवरुद्ध सुविधाओं का उपयोग करें

जिन लोगों ने कभी नहीं सुना है कि एक "निवासी कार्यक्रम" क्या है, और केवल एक वेब पेज के लिए कोड लिखा है जो "रन-रन-रन-डाई" के सिद्धांत पर काम करता है, पहली बार डेमन लिखते समय एक पैटर्न ब्रेक का अनुभव करता है। उदाहरण के लिए, यह पता चला है कि तात्कालिक वस्तुएं लंबे समय तक "जीवित" रह सकती हैं और डेटाबेस प्रकार के भंडारण का उपयोग किए बिना जानकारी संग्रहीत कर सकती हैं, और जिस तक पहुंच प्राप्त की जा सकती है वह विभिन्न कनेक्शन से डेमॉन तक पहुंच सकती है। शायद यह उनके लेखन के दौरान है कि एक सबसे अवरुद्ध कार्यों की समस्या का सामना कर सकता है और एसिंक्रोनसी के लिए बस पीएचपी की कमी को कम कर सकता है।

सामान्य रूप से अतुल्यकालिक क्या है? यदि एक सरल तरीके से, तो यह कोड की "समानांतर" करने की क्षमता है, कोड के कई टुकड़ों को एक-दूसरे से स्वतंत्र रूप से निष्पादित करने के लिए ।
UPD: alekciy ने ठीक टिप्पणी की:

भ्रमित होने की आवश्यकता नहीं है। अतुल्यकालिक! = समानांतर। क्लासिक जेएस एसिंक्रोनस रूप से चल सकता है, लेकिन समानांतर में नहीं (एकल-थ्रेडेड वीएम का उपयोग करके)। उपयोगी पढ़ना: कैसे जावास्क्रिप्ट में काम करते हैं टाइमर

अतुल्यकालिक - असंगत कोड निष्पादन की संभावना। Concurrency - एक ही समय में एक ही कोड को निष्पादित करने की क्षमता।

मुझे उम्मीद है कि पाठक कम से कम जावास्क्रिप्ट की मूल बातें से परिचित होंगे। अधिकांश ने कम से कम एक बार कुछ लिखा:

var myDomElement.onclick = function() { alert("I'm hit!"); } 

प्राथमिक, सही? पृष्ठ के कुछ तत्व पर क्लिक करने के लिए ईवेंट हैंडलर निर्धारित किया जाता है। लेकिन क्या होगा अगर हम PHP में कुछ ऐसा ही करने की कोशिश करें?

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

लेकिन ReactPHP दृश्य पर दिखाई देता है और जादू करता है।

सामग्री

• सर्वर साइड शाफ़्ट पैकेज पर आधारित था, जो अनिवार्य रूप से WebSockets के साथ काम करने के लिए ReactPHP पर एक ऐड-ऑन है।
• एक जावास्क्रिप्ट फ्रेमवर्क का उपयोग करने का एक विचार था, जो कि AngularJS जैसा कुछ था, लेकिन उस समय मैं जल्द से जल्द एक परियोजना शुरू करना चाहता था और एक नया ढांचा सीखना तंग अनुसूची में फिट नहीं था। तो, शुरुआत में, नंगे जावास्क्रिप्ट था, फिर भी जुड़ा हुआ jQuery।
• लेआउट और डिज़ाइन के साथ, मैं परेशान नहीं करना चाहता था, इसलिए मैंने ट्विटर बूटस्ट्रैप 3 की ओर रुख किया
• मैंने सोचा था कि पेज टाइटल या साउंड नोटिफिकेशन को ब्लिंक करने के बजाय HTML5 नोटिफिकेशन का उपयोग करना काफी महत्वपूर्ण होगा।
• परिणामी डेमॉन को अपने अलग पोर्ट की आवश्यकता थी, इसलिए फ़ायरवॉल समस्या को हल करने के लिए, मैंने nginx का उपयोग किया और WebSockets प्रॉक्सी को सेट किया। ब्याज की खातिर, मैंने एसएसएल प्रमाणपत्र भी खराब कर दिया

संक्षिप्त संरचना

सर्वर भाग में दो असममित कोड भाग होते हैं: कैसिक वेब पेज (इंडेक्स, पासवर्ड रिकवरी) और एक डेमो चैट सेवा।
मुख्य पृष्ठ क्लाइंट वेब एप्लिकेशन को लोड करने के कार्यों को हल करता है, साथ ही साथ सत्र को प्रारंभ करता है।

डेमन मूल रूप से MyApp / Chat वर्ग के रूप में शाफ़्ट पैकेज से MessageComponentInterface इंटरफ़ेस का एक कार्यान्वयन है। कार्यान्वित किए गए तरीके onOpen , onClose , onError और onMessage घटनाओं को संभालते हैं ।
ऑनरर के अपवाद के साथ प्रत्येक हैंडलर, चेन-ऑफ-रिस्पॉन्सिबिलिटी पैटर्न है। कोड का सबसे बड़ा टुकड़ा ऑनमैसेज था, जहां इसे नियंत्रकों में विघटित कर दिया गया था।

समस्याओं और समाधान

1. पहली बात जो मुझे सामने आई, वह यह थी कि वेटल्स, कस्टम हैंडलर के बिना कोई त्रुटि, और बिना किसी अपवाद के डेमॉन को मार डालो। वसा और अपवादों के साथ, समस्या केवल परीक्षणों की मदद से हल की जाती है। मेरी शर्म की बात है कि समय की भारी कमी के कारण हाथ परीक्षणों तक नहीं पहुंच पाए, लेकिन फिर भी यह होगा। सरल त्रुटियां, शायद आप स्वयं जानते हैं, बस कस्टम ErrorHandler + लॉगिंग का उपयोग करके हल किया जाता है।
2. एक समस्या तब सामने आई, जब कई दिनों के ऑपरेशन के बाद, किसी ने डिस्कनेक्ट कर दिया और चैट डेमॉन ने 100% सीपीयू खाना शुरू कर दिया, हालांकि चैट में कोई ब्रेक नहीं थे। GitHub पर पाए गए लेखक शाफ़्ट से एक पैच को ठीक किया। हालाँकि, किसी कारण से यह अभी भी ReactPHP पैकेज में शामिल नहीं है।
   
   पैच

   diff --it / a / seller / reaction / stream / React / Stream / Buffer.php b / वेंडर / प्रतिक्रिया / स्ट्रीम / प्रतिक्रिया / स्ट्रीम / बफर / एफपी
   सूचकांक e516628..4560ad9 100644
   @@ -83.8 +83.8 @@ क्लास बफ़र EventEmitter को लागू करता है WritableStreamInterface
   
   सार्वजनिक समारोह संभाल ()
   {
   - if (! is_resource ($ यह-> स्ट्रीम) || ('generic_socket' === $ this-> मेटा ['stream_type'] && feof ($ this-> stream)) {
   - $ यह-> उत्सर्जन ('त्रुटि', सरणी (नई \ RuntimeException ('बंद या अमान्य स्ट्रीम पर लिखने की कोशिश की)');
   + अगर (is_resource ($ यह-> स्ट्रीम)) {
   + $ यह-> उत्सर्जन ('त्रुटि', सरणी (नया \ RuntimeException (अमान्य स्ट्रीम में लिखने की कोशिश की।)), इस $);
   
   वापसी;
   }
   @@ -107.6 +107.12 @@ क्लास बफ़र EventEmitter को लागू करता है WritableStreamInterface
   वापसी;
   }
   
   + अगर (0 === $ भेजा गया && feof ($ यह-> स्ट्रीम)) {
   + $ यह-> उत्सर्जन ('त्रुटि', सरणी (नई \ RuntimeException ('बंद स्ट्रीम में लिखने की कोशिश की।), इस $));
   +
   + वापसी;
   +}
   +
   $ लेन = स्ट्रलेन ($ यह-> डेटा);
   if ($ len> = $ this-> softLimit && $ len - $ भेजा <$ this-> softLimit) {!!!!
   $ यह-> उत्सर्जन ('नाली');
   
   
   
3. कनेक्शन प्रतिधारण शायद एक महत्वपूर्ण मुद्दा है। एक वायर्ड नेटवर्क या सभ्य वाई-फाई के माध्यम से सामान्य कनेक्शन पर, सब कुछ ठीक था। हालांकि, जब मोबाइल इंटरनेट से कॉल किया गया, तो यह पता चला कि मोबाइल ऑपरेटर स्थायी कनेक्शन पसंद नहीं करते हैं और उन्हें जाहिर तौर पर कई शर्तों के आधार पर काट दिया जाता है। उदाहरण के लिए, यदि बीएस कमजोर रूप से भरा हुआ है और हर कोई चैट में चुप है, तो इसे 30 सेकंड के बाद बाहर निकाला जा सकता है। और इसे फेंका भी नहीं जा सकता है। इसलिए, रोकथाम के लिए, मैंने गतिविधि बनाने के लिए सर्वर को पिंग कमांड का एक चक्रीय भेज दिया। लेकिन जैसा कि यह निकला, एक अधिक व्यस्त बीएस के साथ, यह काम नहीं किया।
   सामान्य तौर पर, एल्गोरिथ्म का कार्यान्वयन एक लंबे समय के लिए पूछ रहा था: समय समाप्त होने के बाद मौजूद उपयोगकर्ताओं के सरणी से उपयोगकर्ता के वियोग में देरी। जाहिर है, इसके लिए अतुल्यकालिक कोड के उपयोग की आवश्यकता होती है। स्वाभाविक रूप से, कोई भी नींद () यहां अच्छी नहीं थी। मैंने सभी प्रकार के कार्यान्वयन विकल्पों को आश्चर्यचकित किया, जिसमें कतार सर्वर भी शामिल था। समाधान पाया गया था और सरल और सुरुचिपूर्ण निकला: ReactPHP आपको टाइमप्ले का उपयोग करने की अनुमति देता है जो EventLoop पर लटकाए जाते हैं। यह कुछ इस तरह दिखता है:
   

    private function handleDisconnection(User $user) { $loop = MightyLoop::get()->fetch(); //   EventLoop,      $detacher = function() use ($user) { //         ... }; if ($user->isAsyncDetach()) { $timer = $loop->addTimer(30, $detacher); // 30  $user->setTimer($timer); } else { $detacher(); } $user->getConnection()->close(); } 

   
   
4. डेमॉन मोड में डेटाबेस से कनेक्ट करना प्रदर्शन कारणों से इसे खुला रखने और कनेक्शन त्रुटियों के साथ लॉग के क्लॉगिंग को कम करने के लिए समझ में आता है। किसी भी मामले में, मुझे पीडीओ रैपर के लिए एक बैसाखी विधि को जोड़ना था जो डेटाबेस से कनेक्शन की गारंटी देने के प्रत्येक अनुरोध से पहले बुलाया गया था:
   

    protected function checkConnection() { try { $this->dbh->query('select 1'); } catch (\Exception $e) { $this->init(); } } 

   
   काश, मैं एक और अधिक सुंदर समाधान नहीं मिला। हमें अभी भी रेडिस के साथ प्रयोग करने की आवश्यकता है, विशेष रूप से चूंकि एक तैयार- पूर्व- तैयार किए गए प्रीसिंक-एस्कॉन पैकेज है।
5. प्रत्येक ब्राउज़र टैब एक नया कनेक्शन उत्पन्न करता है। और किसी तरह मैं उपयोगकर्ता को क्लोनिंग द्वारा प्रचारित करने की अनुमति नहीं देना चाहता था। मुझे उसी सत्र से कनेक्शन पर प्रतिबंध लगाना पड़ा। यह व्यवहार क्लासिक चैट से अलग है, जो एक सत्र के साथ खिड़कियों या टैब की एक मनमानी संख्या में एक साथ काम करना आसान बनाता है।

अब क्या चैट कर सकते हैं और क्या सीखना है

मुख्य विशेषताओं में से:

• चैट डेमॉन को मेमोरी में लगभग 20mb लगता है और यह आंकड़ा स्थिर है। यह बुरा नहीं है;
• अनिवार्य पंजीकरण की कमी, उपयोगकर्ता तुरंत चैट में प्रवेश करता है;
• पंजीकरण, प्राधिकरण और पासवर्ड वसूली;
• निजी सत्र और निजी संदेश (एक अलग चैनल बनाने के बिना) करने में सक्षम;
• व्यक्तिगत ब्लैकलिस्ट;
• सोशियल टाइप चैट रूलेट;
• उपयोगकर्ता के लिए अदृश्य रूप से, जब कनेक्शन काट दिया जाता है, तो पुन: संयोजन किया जाता है;
• कनेक्शन के दोहराव की रोकथाम;
• बाढ़ नियंत्रण।

क्या बुरा है:

• कोई सभ्य ORM, स्व-निर्मित;
• सत्र हैंडलर भी स्व-निर्मित है;
• कोई परीक्षण नहीं;
• कोई मल्टीथ्रेडिंग नहीं।

अंतिम रूप दिए जाने की उम्मीद है:

• NoSQL डेटाबेस के साथ प्रयोग, उदाहरण के लिए Redis;
• अलग चैनल के कमरे;
• डाउनलोड करने योग्य अवतार;
• विभिन्न प्रकार की सूचनाएं स्थापित करना;
• उपयोगकर्ताओं पर व्यक्तिगत नोट्स सेट करना;
• निजी चैनलों में संकेत "अब प्रिंट"।

परियोजना के विकास के 2 महीने बाद क्या निष्कर्ष निकाला जा सकता है? PHP में अभी भी क्षमता है। कम से कम एक घटना-उन्मुख प्रतिमान के साथ काम की शुरुआत रखी गई है। लेकिन अफसोस, अब तक भाषा पकड़ने की कोशिश कर रही है, और आंदोलन का प्रमुख नहीं बन गया। यदि आप रैचेट और टॉर्नेडो की तुलना करते हैं, तो क्षमताओं के संदर्भ में वे अभी तक समान नहीं हैं। हमें उम्मीद है कि सकारात्मक तेजी के साथ इस दिशा में विकास जारी रहेगा।

जिज्ञासु के लिए, परियोजना के लिए स्रोत कोड यहां देखा जा सकता है ।
रचनात्मक टिप्पणियों का स्वागत है।

पुनश्च
Node.js बनाम ReactPHP प्रदर्शन तुलना लेख ।
सॉकेट 2http प्रॉक्सी उदाहरण ।