मैं कई प्रकाशकों के संदेशों की धाराओं को प्रबंधित करने का एक तरीका ढूंढ रहा हूं।
एक आकस्मिक उदाहरण यह है।
मेरे प्रत्येक प्रकाशक नौकरियों को प्रस्तुत कर रहे हैं जिन्हें छोटे घटकों में तोड़ा जा सकता है जिन्हें किसी भी क्रम में संसाधित किया जा सकता है। प्रत्येक घटक को संसाधित होने में कई सेकंड लगते हैं।
प्रकाशक A एक ऐसी कतार में नौकरी करता है जिसमें 1000 छोटे घटक होते हैं। उपभोक्ता X कतार में सदस्यता लेता है और कतार संदेशों को संसाधित करना शुरू कर देता है और परिणाम कतार में भेज देता है।
नौकरी के माध्यम से आधा रास्ता, प्रकाशक बी 1000 घटकों के साथ एक नौकरी प्रस्तुत करता है।
मैं चाहूंगा कि कंज्यूमर X को अब इसके बीच वैकल्पिक कर दिया जाएप्रकाशक A और प्रकाशक B के संदेश ताकि प्रकाशक B को परिणाम प्राप्त करने से पहले पूरी नौकरी के लिए प्रतीक्षा करने की आवश्यकता न हो और / प्रकाशक A को अभी और धीरे-धीरे परिणाम प्राप्त हो, अब प्रकाशक B के पास नौकरी है। (नेटवर्किंग में उचित कतार के समान)
यह प्रकाशकों के किसी भी संख्या के लिए पूरा करना चाहिए।
यदि मैं फिर उपभोक्ताओं को मापता हूं, तो प्रत्येक उपभोक्ता को उसी तरह से व्यवहार करना चाहिए। वे निष्पक्ष कतार की गारंटी के लिए अपने कार्यों को समन्वित करने की आवश्यकता नहीं करते हैं, बस एक मोटा अनुमान ठीक है।
क्या सर्विस बस में इसे संभालने का कोई पैटर्न है? वहाँ एक और azure तकनीक है जो मुझे इसके बजाय उपयोग करना चाहिए?
उत्तर:
उत्तर № 1 के लिए 1आप छोटे घटक संदेश भेजने के लिए एक विषय बना सकते हैं।
उस विषय पर कई सदस्यताएँ बनाएँ। उदाहरण 2 के लिए, और प्रत्येक को 50% संदेशों को फ़िल्टर करने के लिए कॉन्फ़िगर करें। सदस्यता 1 में प्रकाशक A के संदेश होंगे और सदस्यता 2 में प्रकाशक B के संदेश होंगे। (ऐसे)
फिर प्रत्येक सब्सक्रिप्शन के लिए एक रीडर बनाएं, जिसके परिणामस्वरूप एक ही समय में कई प्रकाशकों से कई प्रकाशकों के संदेशों को संसाधित करने की क्षमता होती है।