गैर स्पष्ट RabbitMQ Yii2 में या क्यों RabbitMQ एक बार में सभी कतारों को लिखता है

मैं Yii2 में RabbitMQ कतार ब्रोकर को कॉन्फ़िगर करने की व्यावहारिक समस्या को साझा करना चाहता हूं। मैं पाठक को चेतावनी देता हूं कि इस कतार के दलाल के साथ काम करने के बारे में मेरे पास विशेषज्ञ राय नहीं है, हालांकि मैं वास्तव में Yii2 प्रलेखन में अंतराल को भरना चाहता हूं और अपने स्वयं के पीड़ा का परिणाम ठीक करना चाहता हूं। इसलिए, यदि आपको कभी भी एक समस्या का सामना करना पड़ा है कि कतार सर्वर पर मौजूद सभी कतारों को संदेश भेजे जाते हैं, तो आप सहमत हैं कि यह एक समस्या है और यह नहीं समझती कि ऐसा क्यों होता है, तो मैं एक बिल्ली के लिए पूछता हूं।

आप इस व्यवहार का सामना क्यों कर सकते हैं? उदाहरण के लिए, यदि आप, मेरी तरह, ने पहले RabbitMQ के साथ काम नहीं किया है, लेकिन गियरमैन के साथ उदाहरण के लिए काम किया है। खुद गियरमैन, एक रेलवे के रूप में सरल ( एक प्रसिद्ध और सम्मानित इंटरनेट चरित्र से उधार )। आप एक निश्चित नाम के साथ एक कतार बनाते हैं, वहां डेटा डालते हैं। कार्यकर्ता उसी नाम से कतार से पढ़ता है। सब कुछ सरल है। अब फैशन तकनीक का उपयोग करने का समय है, बिना यह समझे कि आप RabbitMQ को क्यों चुनते हैं। फिर आपको खुशी है कि Yii2 में कई लोकप्रिय कतार के दलालों के लिए तैयार अमूर्त है। Scanty प्रलेखन सब कुछ शुरू करने के लिए डिफ़ॉल्ट कॉन्फ़िगरेशन बताता है:

return [ 'bootstrap' => [ 'queue', // The component registers its own console commands ], 'components' => [ 'queue' => [ 'class' => \yii\queue\amqp_interop\Queue::class, 'port' => 5672, 'user' => 'guest', 'password' => 'guest', 'queueName' => 'queue', 'driver' => yii\queue\amqp_interop\Queue::ENQUEUE_AMQP_LIB, // or 'dsn' => 'amqp://guest:guest@localhost:5672/%2F', // or, same as above 'dsn' => 'amqp:', ], ], ]; 

ऐसा लगता है कि सब कुछ बहुत सरल है, यहाँ कतार , कॉपी और पेस्ट के साथ परिचित लाइन है, इसे ठीक करें, इसे चलाएं - यह काम करता है! हम सिस्टम के अन्य घटकों के लिए कतार बनाते हैं। हम अपने php के साथ समानांतर कर सकते हैं। प्रतिबद्ध, पुश संतुष्ट हमने कार्य को क्यूए में डाल दिया और हम एक लंच ( लंच ब्रेक पर ) पढ़ने के लिए जाते हैं।

यहां, सबसे दिलचस्प पर, चैट में क्यूए हमें बाधित करता है, और कहता है कि कुछ अजीब हो रहा है। किसी कारण के लिए, श्रमिकों (कॉसमर्स) द्वारा लिखे गए डेटा को डुप्लिकेट किया जाता है। क्या क्या? यह ऐसा नहीं हो सकता। हम लॉग की जांच करने के लिए जाते हैं। हम देखते हैं कि संदेश कतार में लिखा जा रहा है, जिसके साथ कतार सही ढंग से चुनी गई है, हैश जॉब प्राप्त हुई है। नहीं, नहीं, हमारी कोई गलती नहीं है। हम संतुष्ट क्यूए लिख रहे हैं, फिर से जांच करें, यह नहीं हो सकता है, हम अच्छा कर रहे हैं।

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



हम कतार में कुछ और संदेश फेंकते हैं, हम वेबमॉर्ड में देखते हैं कि हमारे संदेश आते हैं और कार्यकर्ता द्वारा संसाधित किए जाते हैं। एक आकस्मिक नज़र नोटिस करती है कि जब हम किसी संदेश को कतार में फेंकते हैं, तो "संदेश दरें" चार्ट सभी कतारों में कूद जाता है।



हम एक सौ बार कॉन्फ़िगरेशन की जांच करते हैं, वाई के डरावने प्रलेखन को फिर से पढ़ते हैं। हमने सब कुछ ठीक किया। हम खरगोश की साइट पर प्रलेखन पढ़ने के लिए जाते हैं। अंधेरे में भटकने के कुछ मिनटों के बाद, हम एक ट्यूटोरियल पर ठोकर खाते हैं। पहले पैराग्राफ के तुरंत बाद, हम अपनी गलतफहमी के कारण से परिचित हो जाते हैं - एक्सचेंज। मैं बहुत संक्षेप में प्रलेखन को नहीं दोहराऊंगा।

RabbitMQ में हम कतार में एक संदेश नहीं लिखते हैं, हम इसे विनिमय करने के लिए लिखते हैं, एक प्रकार का प्रॉक्सी जो एक छोर पर हमारे संदेश प्राप्त करता है और दूसरे छोर पर सर्वर पर कतारों के साथ संचार करता है। यह तय करना उसकी शक्ति है कि हमारे डेटा को किस कतार में रखा जाए। दिलचस्प है, वाईआई प्रलेखन में इस बारे में एक भी लाइन नहीं है। पहली नज़र में, यह स्पष्ट नहीं है कि विनिमय को कैसे कॉन्फ़िगर किया जाए, हम हिम्मत करते हैं और फ़ाइल विक्रेता / yiisoft / yii2-queue / src / driver / amqp_interop / Queue.php: 176 में हमें एक पोषित संपत्ति मिलती है जिसे देखा जा सकता है। यहाँ मुझे यह कहना होगा कि RabbitMQ के लिए कई ड्राइवर हैं, मेरे मामले में enqueue / amqp-lib का उपयोग किया जाता है । हम एक्सचेंजनाम सेट करते हैं, परीक्षण करते हैं, कुछ भी नहीं बदलता है। ठीक है, हम एक वास्तविक रूसी इंजीनियर की तरह हैं, पहले हम कोशिश करते हैं, और फिर हम प्रलेखन को फिर से पढ़ने के लिए सोच-समझकर जाते हैं। हम इसे फिर से ध्यान से पढ़ते हैं, फिर खरगोश के वेब चेहरे पर जाते हैं और निम्नलिखित देखते हैं:



हमारी कई कतारें एक ही एक्सचेंज से जुड़ी हैं। बिंगो! यहाँ यह कारण है, एक "लेकिन", मैंने उन्हें बाँधा नहीं। हम फिर से चालक की आंत में जाते हैं, हम सेटअपब्रोकर विधि लाइन 392 पाते हैं

 $this->context->bind(new AmqpBind($queue, $topic)); 

यह मानव रहित बंधन है।

और इसलिए, लंबे समय तक सोचने के बिना, हम इस निष्कर्ष पर आते हैं कि प्रत्येक कतार के लिए एक एक्सचेंज घोषित किया जाना चाहिए, फिर कनेक्शन सही होगा और एक एक्सचेंज में केवल एक कनेक्टेड कतार होगी। इस तरह से हमें एक समान गियरमैन व्यवहार मिलता है। वैसे, दस्तावेज़ीकरण में विस्तार से वर्णन किया गया है कि विनिमय क्यों किया गया था, और जैसा कि मैं इसे समझता हूं, कारणों में से एक एक्सचेंज के साथ कई कतारों को जोड़ने की क्षमता है। लेकिन मुझे इस तरह का मामला नहीं आया जब इसकी आवश्यकता हो सकती है, लोग टिप्पणियों में लिखते हैं। और लिखो, क्या आपने ऊपर वर्णित स्थिति का सामना किया है या क्या मैं सब कुछ गलत कर रहा हूं?