ईगलमक्यू का परिचय

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





मुख्य समस्याओं को हल करने के लिए, 3 मुख्य आदिम हैं: कतार, मार्ग और चैनल।

कतारों
कतारें सबसे बुनियादी आदिम हैं। कतार आपको संदेशों को संग्रहीत करने और उन्हें क्लाइंट को उसी क्रम में जारी करने की अनुमति देती है जिसमें वे आए थे (एफआईएफओ सिद्धांत)।

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

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

संदेश सीमित समय समाप्ति के साथ भी हो सकते हैं और समाप्ति के मामले में स्वचालित रूप से हटा दिए जाएंगे। अवधारण अवधि कतार में भेजे गए संदेश का एक गुण है।

ग्राहकों को आने वाले संदेशों की अतुल्यकालिक डिलीवरी के लिए कतारों का समर्थन है। अतुल्यकालिक वितरण का उपयोग करने के लिए, आपको झंडे में सदस्यता मोड का संकेत करते हुए .queue_subscribe कमांड के साथ कतार की सदस्यता लेनी होगी। कतार में 2 सदस्यता मोड हैं: संदेश और सूचना।
संदेश मोड में, एक घटना ग्राहकों को भेजी जाती है जिसमें कतार का नाम होता है जिसमें संदेश और संदेश आता है। संदेश इस मामले में कतार में नहीं आता है, क्योंकि यह पहले ही ग्राहकों को भेजा जा चुका है। यदि पंक्ति ROUND_ROBIN ध्वज के साथ बनाई गई है तो संदेश प्रत्येक बार केवल एक ग्राहक को भेजा जाएगा, और सभी को नहीं। राउंड-रॉबिन एल्गोरिथ्म का उपयोग ग्राहकों को संदेश वितरित करने के लिए किया जाता है।
अधिसूचना मोड में, इस मोड का उपयोग करके कतार में सदस्यता लिए गए सभी ग्राहक एक संदेश भेजते हैं जिसमें केवल कतार नाम होता है। यह ईवेंट कतार के सभी ग्राहकों को इस मोड के साथ भेजा जाएगा, भले ही संदेश किसी को भेजा गया हो और कतार में न आया हो।
आप .queue_unsubscribe कमांड के साथ अतुल्यकालिक संदेश वितरण से सदस्यता समाप्त कर सकते हैं।

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

AUTODELETE, FORCE_PUSH, ROUND_ROBIN, DURABLE: कतार 4 झंडों का समर्थन करती है।

AUTODELETE ध्वज का उपयोग स्वचालित रूप से एक कतार को हटाने के लिए किया जाता है यदि यह किसी के द्वारा घोषित नहीं किया गया है और इसके कोई सदस्य नहीं हैं।

FORCE_PUSH ध्वज आपको अधिकतम संदेश पहुंचने पर कतार में संदेश भेजने की अनुमति देता है। यह एक नया संदेश सहेजने के लिए एक पुराने संदेश को हटाने के द्वारा प्राप्त किया जाता है।

ROUND_ROBIN ध्वज आपको प्रत्येक बार केवल एक ग्राहक को संदेश भेजने की अनुमति देता है (ऊपर विवरण देखें)।

DURABLE ध्वज इंगित करता है कि कतार लगातार है और भंडार में सभी संदेशों के साथ संग्रहीत किया जा सकता है।

कतारों के साथ काम करने के लिए कमांड की सूची:

• .queue_create (नाम, max_msg, max_msg_size, झंडे)
• .queue_declare (नाम)
• .queue_exist (नाम)
• .queue_list
• .queue_rename (से, के लिए)
• .queue_size (नाम)
• .queue_push (नाम, संदेश)
• .queue_get (नाम)
• .queue_pop (नाम, समय समाप्त)
• .queue_confirm (नाम, टैग)
• .queue_subscribe (नाम, झंडे)
• .queue_unsubscribe (नाम)
• .queue_purge (नाम)
• .queue_delete (नाम)

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

किसी कुंजी के साथ एक कतार संबद्ध करने के लिए .route_bind कमांड का उपयोग करें। मार्ग पर एक संदेश भेजने के लिए कमांड .route_push जिम्मेदार है।

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

मार्ग 3 झंडे का समर्थन करता है: AUTODELETE, ROUND_ROBIN, DURABLE।

AUTODELETE ध्वज का उपयोग स्वचालित रूप से एक मार्ग को हटाने के लिए किया जाता है यदि इसमें कुंजी द्वारा कतारों का कोई लिंक नहीं है।

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

DURABLE ध्वज इंगित करता है कि मार्ग लगातार है और भंडार में सभी कुंजियों के साथ संग्रहीत किया जा सकता है।

मार्गों के साथ काम करने के लिए आदेशों की सूची:

• .route_create (नाम, झंडे)
• .route_exist (नाम)
• .route_list
• .route_keys (नाम)
• .route_rename (से, के लिए)
• .route_bind (नाम, कतार, कुंजी)
• .route_unbind (नाम, कतार, कुंजी)
• .route_push (नाम, कुंजी, संदेश)
• .route_delete (नाम)

चैनलों
चैनल वास्तविक समय में ग्राहकों को संदेशों की सुविधाजनक डिलीवरी के लिए एक आदिम है।

काम का सिद्धांत यह है कि ग्राहक एक विशिष्ट विषय के साथ सदस्यता ले सकता है .channel_subscribe कमांड। किसी अन्य क्लाइंट द्वारा चैनल को एक संदेश भेजते समय .channel_publish टीम उस ग्राहक को संदेश के साथ एक घटना भेजेगी जिसने इस विषय की सदस्यता ली है।

आप .channel_psubscribe कमांड के साथ टेम्प्लेट द्वारा विषयों के एक समूह की सदस्यता भी ले सकते हैं। टेम्प्लेट का प्रारूप ग्लोब-शैली पैटर्न है।

चैनल 3 झंडे का समर्थन करता है: AUTODELETE, ROUND_ROBIN, DURABLE।

AUTODELETE ध्वज का उपयोग किसी चैनल को स्वचालित रूप से हटाने के लिए किया जाता है यदि इसके कोई ग्राहक नहीं हैं।

ROUND_ROBIN ध्वज आपको कई ग्राहकों में से केवल एक को संदेश भेजने की अनुमति देता है। राउंड-रॉबिन एल्गोरिथ्म का उपयोग ग्राहकों के बीच संदेश वितरित करने के लिए किया जाता है।

DURABLE ध्वज इंगित करता है कि चैनल लगातार है और भंडारण में संग्रहीत किया जा सकता है।

चैनलों के साथ काम करने के लिए आदेशों की सूची:

• .channel_create (नाम, झंडे)
• .channel_exist (नाम)
• .channel_list
• .channel_rename (से, के लिए)
• .channel_publish (नाम, विषय, संदेश)
• .channel_subscribe (नाम, विषय)
• .channel_psubscribe (नाम, पैटर्न)
• .channel_unsubscribe (नाम, विषय)
• .channel_punsubscribe (नाम, पैटर्न)
• .channel_delete (नाम)

उपयोगकर्ताओं
आदेशों को निष्पादित करने के लिए अधिकृत करने के लिए प्रत्येक ईगलम क्लाइंट को प्रमाणित किया जाना चाहिए। प्रमाणीकरण के बिना, केवल एक आदेश उपलब्ध है - .disconnect।

ईगलएमक्यू में कई उपयोगकर्ता हो सकते हैं और प्रत्येक उपयोगकर्ता के पास अधिकारों का अपना सेट हो सकता है।

अनुकूलन में उपयोगकर्ता अधिकारों में बहुत लचीलापन है। आप किसी भी कमांड (.disconnect को छोड़कर) और किसी भी आदिम को निष्क्रिय कर सकते हैं।

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

उपयोगकर्ताओं के साथ काम करने के लिए आदेशों की सूची:

• .user_create (नाम, पासवर्ड, पर्म)
• .user_list
• .user_rename (से, के लिए)
• .user_set_perm (नाम, पर्म)
• .user_delete (नाम)

कुल मिलाकर, ईगलमक्यू में वर्तमान में 44 टीमें हैं। सभी आदेशों की एक सूची प्रलेखन में है।

उत्पादकता
ईगलमक्यू में काफी उच्च प्रदर्शन है। सख्त व्यापक माप और तुलनात्मक परीक्षण अभी तक नहीं किए गए हैं। यह काफी हद तक इस तथ्य के कारण है कि कुछ समान प्रणालियों में कार्य को ठीक करने की क्षमता है (उदाहरण के लिए, RabbitMQ) और इन प्रणालियों में मेरा अनुभव उद्देश्यपूर्ण मूल्यांकन करने की अनुमति नहीं देता है।

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

परीक्षण के लिए, मानदंड से बेंचमार्क बेंचमार्क उपयोगिता का उपयोग किया गया था।

परीक्षण का सार .queue_push कमांड के साथ कतार में संदेश भेजना है। आवेदन 50 धागे का उपयोग करता है। सर्वर से कनेक्ट करने के लिए, स्थानीय टीसीपी सॉकेट का उपयोग किया गया था।

Intel Core (TM) i5-2450M CPU @ 2.50GHz

ग्राहकों	कुल संदेश	संदेश का आकार	समय सेकंड	रक / सेक
50	1000000	1000	9.20	108,283.71
50	1000000	100	8.07	123,931.09
50	1000000	10	8.05	124,300.80
50	100000	1000	0.95	105,596.62
50	100000	100	0.85	117,096.02
50	100000	10	0.81	123,304.56

इंटेल कोर (TM) i5-3470 CPU @ 3.20GHz

ग्राहकों	कुल संदेश	संदेश का आकार	समय सेकंड	रक / सेक
50	1000000	1000	5.19	192,566.92
50	1000000	100	4.47	223,613.59
50	1000000	10	4.40	227,169.47
50	100000	1000	0.53	189,393.94
50	100000	100	0.46	219,298.25
50	100000	10	0.45	220,750.55

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

सभी डेटा लगातार रैम में संग्रहीत होते हैं।

भंडारण तंत्र के संचालन के सिद्धांत में दिए गए अंतराल पर प्रक्रिया (कांटा) को क्लोन करना और एक फ़ाइल के लिए सभी आवश्यक डेटा लिखना शामिल है। क्लाइंट के अनुरोध पर डेटा को बचाने के लिए एक कमांड है .save।

जब भी संभव हो, सभी संग्रहीत डेटा को लिबर्ज़फ़ लाइब्रेरी द्वारा संपीड़ित किया जाता है।

प्रोटोकॉल
ईगलमक्यू का अपना बाइनरी प्रोटोकॉल है।

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

बेशक, इसके नुकसान भी हैं:

1. बाइनरी प्रोटोकॉल मानव-पठनीय नहीं है।
2. प्रोग्रामिंग भाषाओं को स्क्रिप्ट करने में क्लाइंट लाइब्रेरी को लागू करने में कठिनाइयाँ हो सकती हैं।
3. एक संगत ग्राहक का उपयोग करने की आवश्यकता है बाइनरी प्रोटोकॉल बदल सकते हैं।

ईगलमक्यू प्रोटोकॉल को केवल प्रमुख रिलीज में बदला जा सकता है।

रोडमैप

1. एक बार में कई कमांड भेजने के लिए उन्नत पैकेट एकत्रीकरण समर्थन। अब ऐसा समर्थन पहले से ही उपलब्ध है, लेकिन पैकेट नुकसान के साथ।
2. एक बाइनरी प्रोटोकॉल का प्रलेखन।
3. कमांड लाइन का उपयोग करके ईगलएमक्यू को नियंत्रित करने के लिए एक सीएलआई लिखना।
4. साइट का शोधन और रखरखाव www.eaglemq.com ।
5. छोटे और बड़े engian आर्किटेक्चर के लिए समर्थन।
6. परीक्षणों के साथ सभी कार्यक्षमता को कवर करना।

हर कोई मुझसे आपका सवाल कमेंट में या मेल से पूछ सकता है। मुझे जवाब देने में खुशी होगी।

प्रोजेक्ट रिपोजिटरी: गिटहब