अतुल्यकालिक PHP और एक बाइक की कहानी

PHP7 की रिहाई के बाद, अपेक्षाकृत कम लागत पर लंबे समय तक रहने वाले अनुप्रयोगों को लिखना संभव हो गया। प्रोग्रामर के लिए, prooph , broadway , prooph , prooph जैसी परियोजनाएं उपलब्ध हो गई हैं, जिनमें से लेखक सबसे आम समस्याओं का समाधान करते हैं। लेकिन क्या होगा अगर आप एक छोटे से कदम को आगे बढ़ाते हैं, सवाल में पड़ते हैं?

आइए एक और बाइक के भाग्य का पता लगाने की कोशिश करें, जो आपको प्रकाशित / सदस्यता एप्लिकेशन को लागू करने की अनुमति देता है।

शुरुआत करने के लिए, हम PHP की दुनिया में वर्तमान रुझानों की संक्षिप्त समीक्षा करने की कोशिश करेंगे, साथ ही अतुल्यकालिक ऑपरेशन पर एक संक्षिप्त नज़र डालेंगे।

PHP मरने के लिए बनाई गई

लंबे समय से, PHP मुख्य रूप से अनुरोध / प्रतिक्रिया वर्कफ़्लो में उपयोग की जाती थी। डेवलपर्स के दृष्टिकोण से, यह काफी सुविधाजनक है, क्योंकि मेमोरी लीक, मॉनिटर कनेक्शन के बारे में चिंता करने की कोई आवश्यकता नहीं है।

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

एक उदाहरण के रूप में, आप सिम्फनी ढांचे के आधार पर लिखा गया एक नियमित सीआरयूडी आवेदन ले सकते हैं। डेटाबेस से पढ़ने और JSON को वापस करने के लिए, कई चरणों को निष्पादित करना आवश्यक है (स्थान और समय बचाने के लिए, opcodes को उत्पन्न / निष्पादित करने के चरणों को बाहर करना):

• विन्यास का विश्लेषण;
• कंटेनर संकलन;
• रूटिंग का अनुरोध करें
• कार्यान्वयन;
• परिणाम का प्रतिपादन।

PHP के मामले में (त्वरक का उपयोग करके), फ्रेमवर्क सक्रिय रूप से कैशिंग का उपयोग करता है (कुछ कार्य अगले अनुरोध पर पूरा नहीं होगा), साथ ही साथ आरंभीकरण में देरी भी हुई। संस्करण load.४ के साथ शुरू, प्रीलोड उपलब्ध होगा, जो आवेदन के आरंभीकरण को आगे बढ़ाएगा।

हालांकि, प्रारंभ के लिए सभी ओवरहेड लागतों को पूरी तरह से निकालना संभव नहीं है।

आइए PHP को जीवित रहने में मदद करें

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

PHP इकोसिस्टम में php-pm और RoadRunner जैसे प्रोजेक्ट हैं। दोनों वैचारिक रूप से एक ही काम करते हैं:

• एक मूल प्रक्रिया बनाई जाती है जो पर्यवेक्षक के रूप में कार्य करती है;
• बच्चे की प्रक्रियाओं का एक पूल बनाया जाता है;
• जब एक अनुरोध प्राप्त होता है, तो मास्टर पूल से प्रक्रिया को पुनः प्राप्त करता है और अनुरोध को पास करता है। क्लाइंट को इस समय लंबित रखा गया है;
• एक बार कार्य पूरा हो जाने के बाद, मास्टर क्लाइंट को परिणाम देता है, और बच्चे की प्रक्रिया को पूल में वापस भेज दिया जाता है।

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

नोट:
श्रृंखला से कई उदाहरण "ReactPHP लेते हैं और लारवेल एन बार को तेज करते हैं" नेटवर्क पर चलते हैं। यह महत्वपूर्ण है कि डिमॉनेटाइजिंग (और, परिणामस्वरूप, बूटस्ट्रैपिंग एप्लिकेशन पर समय की बचत) और मल्टीटास्किंग के बीच अंतर को समझना महत्वपूर्ण है।
Php-pm या roadrunner का उपयोग करते समय आपका कोड नॉन-ब्लॉकिंग नहीं बनता है। आप सिर्फ आरंभीकरण पर समय बचाते हैं।
Php-pm, roadrunner और ReactPHP / Amp / Swoole की तुलना परिभाषा द्वारा गलत है।

PHP और I / O

PHP में I / O के साथ इंटरैक्शन डिफ़ॉल्ट रूप से ब्लॉकिंग मोड में निष्पादित होता है। इसका अर्थ है कि यदि हम तालिका में जानकारी को अपडेट करने के अनुरोध को निष्पादित करते हैं, तो निष्पादन का प्रवाह डेटाबेस से प्रतिक्रिया की प्रतीक्षा कर रहा है। अनुरोध को संसाधित करने की प्रक्रिया में जितनी अधिक कॉल होती हैं, सर्वर के संसाधन उतने लंबे होते हैं। दरअसल, अनुरोध को संसाधित करने की प्रक्रिया में, हमें कई बार डेटाबेस में जाने की जरूरत है, लॉग को कुछ लिखें, और क्लाइंट को परिणाम लौटाएं, अंत में - एक अवरुद्ध ऑपरेशन भी।

कल्पना करें कि आप एक कॉल सेंटर ऑपरेटर हैं और आपको एक घंटे में 50 ग्राहकों को कॉल करने की आवश्यकता है।
आप पहले नंबर को डायल करते हैं, और वहाँ व्यस्त है (ग्राहक फोन द्वारा गेम ऑफ़ थ्रोन्स की अंतिम श्रृंखला और श्रृंखला में लुढ़का हुआ है) पर चर्चा करता है।
और अब आप बैठे हैं और जीत से पहले उस तक पहुंचने की कोशिश कर रहे हैं। समय बीतता जा रहा है, पारी एक करीबी के लिए आकर्षित कर रही है। पहले ग्राहक तक पहुंचने की कोशिश में 40 मिनट गंवाने के बाद, आप दूसरों से संपर्क करने और स्वाभाविक रूप से बॉस से प्राप्त करने का अवसर चूक गए।
लेकिन आप अन्यथा कर सकते हैं: तब तक इंतजार न करें जब तक कि पहले ग्राहक मुक्त न हो जाए और जैसे ही आप बीप सुनें, लटक जाएं और अगला नंबर डायल करना शुरू करें। आप पहले थोड़ी देर बाद लौट सकते हैं।
इस दृष्टिकोण के साथ, अधिकतम लोगों को फ़ॉइन करने की संभावना बहुत बढ़ जाती है, और आपके काम की गति सबसे धीमी कार्य पर आराम नहीं करती है।

कोड जो निष्पादन के धागे को अवरुद्ध नहीं करता है (अवरुद्ध I / O कॉल का उपयोग नहीं करता है, साथ ही साथ sleep() ) जैसे कार्यों को अतुल्यकालिक कहा जाता है।

आइए हमारे सिम्फनी CRUD एप्लिकेशन पर वापस जाएं। ब्लॉकिंग फ़ंक्शन के उपयोग की प्रचुरता के कारण इसे अतुल्यकालिक मोड में काम करना लगभग असंभव है: सभी कॉन्फ़िगर, कैश, लॉगिंग, प्रतिक्रिया प्रतिपादन, डेटाबेस के साथ बातचीत के साथ काम करते हैं।

लेकिन ये सभी कन्वेंशन हैं, आइए हम सिम्फनी को फेंकने की कोशिश करते हैं और एएमपी का उपयोग करते हैं, जो हमारी समस्या को हल करने के लिए केक पर चेरी के रूप में ईवेंट लूप (बाइंडर्स की एक संख्या सहित), प्रॉमिस और कोराटाइन का कार्यान्वयन प्रदान करता है।

वादा एसिंक्रोनस कोड को व्यवस्थित करने का एक तरीका है। उदाहरण के लिए, हमें कुछ http संसाधन तक पहुँचने की आवश्यकता है।

हम एक अनुरोध वस्तु बनाते हैं और इसे परिवहन के पास भेजते हैं, जो वादा वर्तमान स्थिति वाले हमें देता है। तीन संभावित राज्य हैं:

• सफलता: हमारा अनुरोध सफलतापूर्वक पूरा हुआ;
• त्रुटि: अनुरोध के निष्पादन के दौरान, कुछ गलत हो गया (उदाहरण के लिए, सर्वर ने 500 प्रतिसाद लौटाया);
• प्रतीक्षा: अनुरोध प्रक्रिया अभी तक शुरू नहीं हुई है।

प्रत्येक वादा की एक विधि होती है (उदाहरण में, वादा Amp द्वारा पार्स किया जाता है ) - onResolve() , जिसमें दो तर्कों के साथ कॉलबैक फ़ंक्शन पास होता है।

 $promise->onResolve( static function(?/Throwable $throwable, $result): void { if(null !== $throwable) { /**   */ return; } /**  */ } ); 

प्रॉमिस प्राप्त करने के बाद, सवाल उठता है: कौन अपनी स्थिति की निगरानी करेगा और हमें स्थिति परिवर्तन की सूचना देगा?

इसके लिए, इवेंट लूप का उपयोग किया जाता है।

संक्षेप में, एक इवेंट लूप एक अनुसूचक है जो निष्पादन की निगरानी करता है। जैसे ही कार्य पूरा हो जाता है (कोई फर्क नहीं पड़ता) कैसे, कॉल करने योग्य जिसे हमने वादा किया था उसे कॉल किया जाएगा।

बारीकियों के लिए, मैं निकिता पोपोव के एक लेख को पढ़ने की सलाह दूंगा: कोरटाइन का उपयोग करके सहकारी मल्टीटास्किंग । यह क्या हो रहा है और कहां जनरेटर हैं के बारे में कुछ स्पष्टता लाने में मदद करेगा।

नए ज्ञान से लैस, आइए अपने JSON प्रतिपादन कार्य पर लौटने का प्रयास करें।
Amphp / http-server का उपयोग करके आने वाले http अनुरोध को संसाधित करने का एक उदाहरण ।
जैसे ही हम अनुरोध प्राप्त करते हैं, डेटाबेस से एक अतुल्यकालिक पाठ किया जाता है (हमें वादा मिलता है) और इसके पूरा होने पर उपयोगकर्ता प्राप्त डेटा के आधार पर गठित प्रतिष्ठित JSON प्राप्त करेगा।

यदि हमें कई प्रक्रियाओं में से एक पोर्ट को सुनने की आवश्यकता है, तो हम एम्फ़पी / क्लस्टर की ओर देख सकते हैं

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

अतुल्यकालिक PHP की अद्भुत दुनिया

त्याग
एसिंक्रोनस PHP को एक्सोटिक्स के संदर्भ में माना जाता है और इसे कुछ स्वस्थ / सामान्य नहीं माना जाता है। असल में, वे "गो / कोटलिन, एक मूर्ख", आदि की शैली में हंसी की प्रतीक्षा करेंगे। मैं यह नहीं कहूंगा कि ये लोग गलत हैं, लेकिन ...

ऐसी कई परियोजनाएँ हैं जो गैर-अवरोधक PHP कोड लिखने में मदद करती हैं। लेख के ढांचे में, मैं पूरी तरह से सभी पेशेवरों और विपक्षों का विश्लेषण नहीं करूंगा, लेकिन मैं उनमें से प्रत्येक को सतही रूप से जांचने की कोशिश करूंगा।

Swoole

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

चैनल, कॉरटिन और अन्य स्वादिष्ट चीजों का कार्यान्वयन है, लेकिन उनके पास 1 बड़ा ऋण है - प्रलेखन। यद्यपि यह आंशिक रूप से अंग्रेजी में है, मेरी राय में यह बहुत विस्तृत नहीं है, और एपीआई स्वयं बहुत स्पष्ट नहीं है।

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

Minuses के लिए, आप यह भी जोड़ सकते हैं कि परियोजना में योगदान करने के लिए (पुल अनुरोध का उपयोग करके) किसी भी बदलाव के साथ भी मुश्किल है अगर आप उचित स्तर पर सी को नहीं जानते हैं।

Workerman

यदि यह अपने प्रतिद्वंद्वी (स्वोल के बारे में बात करना) की गति में खो जाता है, तो यह बहुत ही ध्यान देने योग्य नहीं है और कई परिदृश्यों में अंतर की उपेक्षा की जा सकती है।

इसका ReactPHP के साथ एकीकरण है, जो बुनियादी ढांचे के मुद्दों के कार्यान्वयन की संख्या का विस्तार करता है। अंतरिक्ष को बचाने के लिए, मैं ReactPHP के साथ विपक्ष का वर्णन करूंगा।

ReactPHP

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

एक फ़ाइल (आदर्श माना जाता है) के साथ कुछ परिशोधन के साथ, आप कॉरटिन का एक कार्यान्वयन प्राप्त कर सकते हैं जो प्रोमिस नरक से छुटकारा पाने में मदद करेगा।

मेरी राय में, ReactPHP का उपयोग करते हुए , recoilphp / recoil परियोजना के बिना, एक समझदार अनुप्रयोग में संभव नहीं है।

इसके अलावा, हर चीज के अलावा, किसी को यह महसूस होता है कि उसका विकास बहुत धीमा हो गया है। पर्याप्त नहीं है, उदाहरण के लिए, PostgreSQL के साथ सामान्य काम।

एम्प

मेरी राय में, मौजूदा समय में मौजूद सबसे अच्छे विकल्प।
सामान्य वादे के अलावा, कोरटाइन का कार्यान्वयन है, जो विकास प्रक्रिया को बहुत सुविधाजनक बनाता है और कोड PHP प्रोग्रामर के लिए सबसे अधिक परिचित दिखता है।

डेवलपर्स लगातार परियोजना के पूरक और सुधार करते हैं, प्रतिक्रिया के साथ भी कोई समस्या नहीं है।

दुर्भाग्य से, फ्रेमवर्क के सभी लाभों के साथ, समुदाय अपेक्षाकृत छोटा है, लेकिन एक ही समय में कार्यान्वयन भी हैं, उदाहरण के लिए, पोस्टग्रेसीक्यूएल के साथ-साथ सभी बुनियादी चीजों (फाइल सिस्टम, http क्लाइंट, डीएनएस, आदि) के साथ काम करना।

मैं अभी भी एक्स्ट-असंक प्रोजेक्ट के भाग्य को नहीं समझता हूं, लेकिन लोग इसे जारी रखते हैं। 3 वें संस्करण में इसका क्या होगा, यह समय बताएगा।

शुरुआत हो रही है

इसलिए, हमने सैद्धांतिक भाग को थोड़ा हल कर दिया, यह अभ्यास के लिए आगे बढ़ने और धक्कों को भरने का समय है।

सबसे पहले, हम आवश्यकताओं को थोड़ा औपचारिक करते हैं:

• अतुल्यकालिक संदेश (संदेश की अवधारणा को 2 प्रकारों में विभाजित किया जा सकता है)
  
  • command : कार्य को पूरा करने की आवश्यकता को इंगित करता है। एक परिणाम नहीं लौटाता (कम से कम अतुल्यकालिक संचार के मामले में);
  • event : किसी भी राज्य परिवर्तन की रिपोर्ट करता है (उदाहरण के लिए, एक आदेश के परिणामस्वरूप)।
• I / O के साथ काम करने के लिए गैर-अवरुद्ध प्रारूप;
• प्रोसेसर की संख्या को आसानी से बढ़ाने की क्षमता;
• संदेश संचालकों को किसी भी भाषा में लिखने की क्षमता।

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

आवश्यकताओं की सूची के लिए, प्रकाशित / सदस्यता पैटर्न का एक सरल कार्यान्वयन सबसे उपयुक्त है।
वितरित निष्पादन को सुनिश्चित करने के लिए, हम RabbitMQ का उपयोग एक संदेश दलाल के रूप में करेंगे।

प्रोटोटाइप को ReactPHP , Bunny और DoctrineDBAL का उपयोग करके लिखा गया था।
एक चौकस पाठक यह नोटिस कर सकता है कि डबल आंतरिक रूप से कॉलिंग के लिए pdo / mysqli का उपयोग करता है, लेकिन वर्तमान स्तर पर यह विशेष रूप से महत्वपूर्ण नहीं था, क्योंकि आपको यह समझना था कि अंत में क्या होना चाहिए।

समस्याओं में से एक PostgreSQL के साथ काम करने के लिए पुस्तकालयों की कमी थी। कुछ ड्राफ्ट हैं, लेकिन यह पूर्ण कार्य के लिए पर्याप्त नहीं है (नीचे इस पर अधिक)।

एक छोटे से शोध के बाद, ReactPHP को Amp के पक्ष में हटा दिया गया, क्योंकि यह अपेक्षाकृत सरल और बहुत सक्रिय रूप से विकसित हो रहा है।

खरगोश परिवहन

लेकिन Amp के सभी फायदों के साथ, 1 समस्या थी: Amp में RabbitMQ के लिए ड्राइवर नहीं है ( बनी केवल ReactPHP का समर्थन करती है)।

सिद्धांत रूप में, Amp आपको एक प्रतियोगी से प्रॉमिस का उपयोग करने की अनुमति देता है। ऐसा लगता है कि सब कुछ सरल होना चाहिए, लेकिन ReactPHP लाइब्रेरी में सॉकेट्स के साथ काम करने के लिए इवेंट लूप का उपयोग करता है।
एक समय में, जाहिर है, दो अलग-अलग ईवेंट लूप शुरू नहीं किए जा सकते थे, इसलिए मैं अनुकूलन () फ़ंक्शन का उपयोग नहीं कर सका।

दुर्भाग्य से, बनी में कोड की गुणवत्ता वांछित होने के लिए बहुत कुछ छोड़ गई और एक कार्यान्वयन को दूसरे के साथ पर्याप्त रूप से प्रतिस्थापित करना संभव नहीं था। काम को नहीं रोकने के लिए, पुस्तकालय को थोड़ा फिर से लिखने का निर्णय लिया गया ताकि यह एएमपी के साथ काम करे और निष्पादन के प्रवाह को अवरुद्ध न करे।

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

और ऐसा आदमी मिला। PHPinnacle परियोजना, अन्य बातों के अलावा, Amp के लिए अनुकूलित एक एडाप्टर के कार्यान्वयन प्रदान करता है।

लेखक का नाम एंटोन शबोवा है, जो PHP रूस के भीतर अतुल्यकालिक php के बारे में और PHP के लिए ड्राइवर विकसित करने के बारे में बात करेंगे ।

PostgreSQL

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

अतुल्यकालिक निष्पादन के मामले में, हमें एक साथ कई अनुरोधों को निष्पादित करने में सक्षम होना चाहिए (उदाहरण के लिए, 3 लेनदेन)। ऐसा करने में सक्षम होने के लिए, एक कनेक्शन पूल कार्यान्वयन की आवश्यकता है।

काम का तंत्र काफी सरल है:

• हम स्टार्टअप पर एन कनेक्शन खोलते हैं (या प्रारंभ में देरी, बिंदु नहीं);
• यदि आवश्यक हो, तो हम पूल से कनेक्शन लेते हैं, यह सुनिश्चित करते हुए कि कोई और इसका उपयोग नहीं कर सकता है;
• हम अनुरोध को निष्पादित करते हैं और या तो कनेक्शन को नष्ट कर देते हैं या इसे पूल (पसंदीदा) पर वापस कर देते हैं।

सबसे पहले, यह हमें एक समय में कई लेनदेन शुरू करने की अनुमति देता है, और दूसरी बात, यह पहले से ही खुले कनेक्शन की उपस्थिति के कारण काम को गति देता है। Amp में एक amphp / postgres घटक होता है। वह कनेक्शन का ख्याल रखता है: निष्पादन की प्रवाह को अवरुद्ध किए बिना उनकी संख्या, जीवनकाल और यह सब पर नज़र रखता है।

वैसे, उपयोग करते समय, उदाहरण के लिए, ReactPHP, यदि आप डेटाबेस के साथ काम करना चाहते हैं, तो आपको इसे स्वयं लागू करना होगा।

म्युटेक्स

प्रभावी और, सबसे महत्वपूर्ण बात, आवेदन के उचित संचालन के लिए, म्यूटेक्स के समान कुछ को लागू करना आवश्यक है। हम उनके उपयोग के लिए 3 परिदृश्यों को अलग कर सकते हैं:

• एक प्रक्रिया के ढांचे के भीतर, स्मृति तंत्र में एक सरल बिना किसी अधिशेष के उपयुक्त है;
• यदि हम कई प्रक्रियाओं में लॉकिंग प्रदान करना चाहते हैं, तो हम फाइल सिस्टम का उपयोग कर सकते हैं (बेशक, गैर-अवरुद्ध मोड में);
• यदि कई सर्वरों के संदर्भ में, तो आपको पहले से ही ज़ुकाइपर जैसे कुछ के बारे में सोचने की आवश्यकता है।

रेस हालत की समस्याओं को हल करने के लिए म्यूटेक्स की आवश्यकता होती है। आखिरकार, हमें पता नहीं है (और हम नहीं जान सकते) कि हमारे कार्य किस क्रम में किए जाएंगे, लेकिन फिर भी हमें डेटा की अखंडता सुनिश्चित करनी चाहिए।

लॉगिंग / कॉन्टेक्ट्स

लॉगिंग के लिए, मोनोलॉग पहले से ही मानक बन गया है, लेकिन कुछ कैविट्स के साथ: हम बिल्ट-इन हैंडलर का उपयोग नहीं कर सकते, क्योंकि वे ताले को जन्म देंगे।
StdOut को लिखने के लिए, आप amphp / log ले सकते हैं, या कुछ ग्रेलॉग पर एक सरल संदेश लिख सकते हैं।

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

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

समाप्त

अतुल्यकालिक विकास की बारीकियों में से एक हमारे डेमॉन के बंद को नियंत्रित कर रहा है। यदि आप सिर्फ प्रक्रिया को मारते हैं, तो सभी कार्य जो प्रगति पर हैं, वे पूरे नहीं होंगे और डेटा खो जाएगा। सामान्य दृष्टिकोण में, ऐसी समस्या भी है, लेकिन यह इतना महान नहीं है, क्योंकि एक समय में केवल एक कार्य किया जाता है।

निष्पादन को सही ढंग से पूरा करने के लिए, हमें आवश्यकता है:

• कतार से सदस्यता समाप्त करें। दूसरे शब्दों में, नए संदेश प्राप्त करना असंभव बना देता है;
• शेष सभी कार्यों को पूरा करें (वादों को हल करने के लिए प्रतीक्षा करें);
• और इसके बाद ही स्क्रिप्ट को पूरा करें।

लीक, डिबगिंग

आम धारणा के विपरीत, आधुनिक PHP में उन स्थितियों का सामना करना इतना आसान नहीं है जिनमें एक स्मृति रिसाव होता है। कुछ गलत करना आवश्यक है।

हालांकि, एक बार इसका सामना किया गया था, लेकिन प्रतिबंधात्मक लापरवाही के कारण। दिल की धड़कन के कार्यान्वयन के दौरान, कनेक्शन को क्वेरी करने के लिए हर 40 सेकंड में एक नया टाइमर जोड़ा गया था। यह अनुमान लगाना मुश्किल नहीं है कि कुछ समय बाद स्मृति का उपयोग बहुत जल्दी और काफी जल्दी समाप्त हो गया।

इसके अलावा, अन्य बातों के अलावा, उन्होंने एक साधारण चौकीदार लिखा है जो वैकल्पिक रूप से हर 10 मिनट में शुरू करेगा और gc_collect_cycles () और gc_mem_caches () को कॉल करेगा ।
लेकिन कचरा कलेक्टर की जबरन शुरुआत कुछ आवश्यक और मौलिक नहीं है।

मेमोरी उपयोग को लगातार देखने के लिए, लॉगिंग में एक मानक मेमोरीयूजेजप्रोसेसर जोड़ा गया।

यदि आपको यह विचार आता है कि ईवेंट लूप किसी चीज़ के साथ अवरुद्ध हो रहा है, तो इसे आसानी से चेक भी किया जा सकता है: बस लूपब्लॉकवॉच कनेक्ट करें ।

लेकिन आपको यह सुनिश्चित करने की आवश्यकता है कि यह पर्यवेक्षक उत्पादन वातावरण में शुरू नहीं करता है। यह सुविधा विशेष रूप से विकास के दौरान उपयोग की जाती है।

परिणाम

: php-service-bus , Message Based .

, :

 composer create-project php-service-bus/skeleton pub-sub-example cd pub-sub-example docker-compose up --build -d 

, , .

/bin/consumer , .
/src 3 : Ping ; Pong : ; PingService : , .
PingService , 2 :

  /** @CommandHandler() */ public function handle(Ping $command, KernelContext $context): Promise { return $context->delivery(new Pong()); } /** @EventListener() */ public function whenPong(Pong $event, KernelContext $context): void { $context->logContextMessage('Pong message received'); } 

• handle ( 1 ). @CommandHandler ;
  
  • Promise , RabbitMQ ( delivery() ). , RabbitMQ .
• whenPong — Pong . . @EventListener ;
  

  , — . , , , . php-service-bus , , .
  

2 : , ( ) . , , (, ).

Ping , Pong . .

, RabbitMQ:

 tools/ping 

, php-service-bus , Message based .

Ping\Pong, — , , Hello, world .

, .

- , , , Saga pattern (Process manager) .

, symfony/messenger .

, , .