RabbitMQ सी # API ईवेंट आधारित संदेश खपत

Question

while (true) 
{ 
    BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue(); 
    IBasicProperties properties = e.BasicProperties; 
    byte[] body = e.Body; 
    Console.WriteLine("Recieved Message : " + Encoding.UTF8.GetString(body)); 
    ch.BasicAck(e.DeliveryTag, false); 
} 

यह है कि हम क्या करते हैं जब हम एक ओर जहां लूप subscription..We उपयोग के द्वारा संदेश पुन: प्राप्त करें क्योंकि हम उपभोक्ता Continously..what सुनने के लिए अगर मैं यह और भी आधारित बनाना चाहते चाहते है .. कि जब एक नया संदेश उस समय कतार में आता है केवल उपभोक्ता किसी भी तरह के समान घटना पर message..or ..

Answer 1

आप वर्तमान में Consumer.Queue.Dequeue पर अवरुद्ध कर रहे हैं() सेवन करना चाहिए। अगर मैं आपके प्रश्न को सही ढंग से समझता हूं, तो आप असीमित रूप से संदेशों का उपभोग करना चाहते हैं।

ऐसा करने का मानक तरीका चैनल के लिए IBasicConsumer (शायद DefaultBasicConsumer उपखंडित करके set it as the consumer लिखना होगा)।

इसके साथ समस्या यह है कि आपको बहुत होना चाहिए जो आप IBASicConsumer.HandleBasicDelivery में करते हैं। यदि आप किसी भी सिंक्रोनस AMQP विधियों का उपयोग करते हैं, जैसे कि मूल.publish, आपको एक मृत-लॉक मिलेगा। यदि आप ऐसा कुछ भी करते हैं जो लंबे समय तक लेता है, तो आप कुछ अन्य समस्याओं में भाग लेंगे।

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

यदि आपको और मदद की ज़रूरत है, तो पूछने के लिए एक शानदार जगह rabbitmq-चर्चा मेलिंग सूची है।

Answer 2

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

मैं मनोरंजक अपने प्रोजेक्ट RabbitEar फोन के रूप में यह शक्तिशाली RabbitMQ से संदेश मैं RabbitMQ साइट के साथ इस साझा करने के लिए इसलिए अगर उन्हें लगता अपने मूल्य के वे वहाँ उदाहरण में एक लिंक/कोड शामिल कर सकते हैं करना चाहते हैं के लिए बाहर सुनता है।

पर http://rabbitears.codeplex.com/

धन्यवाद साइमन

इसे देखें

Answer 3

एक इवेंट उपभोक्ता के बजाय एक अवरुद्ध एक के लिए RabbitMQ.Client.Events.EventingBasicConsumer का उपयोग करें।