RabbitMQ: प्रकाशित करने के लिए कतार निर्दिष्ट कैसे करें?

Question

RabbitMQ के Channel#basicConsume विधि हमें निम्नलिखित तर्क देता है:

channel.basicConsume(queueName, autoAck, consumerTag, noLocal, 
    exclusive, arguments, callback); 

हमें वास्तव में कौन-क़तार हम से उपभोग करने के लिए चाहते हैं RabbitMQ बता की क्षमता देना।

channel.basicPublish(exchangeName, routingKey, mandatory, immediateFlag, 
    basicProperties, messageAsBytes); 

मैं कतार क्यों निर्दिष्ट नहीं कर सकते यहां के लिए प्रकाशित करने के लिए:

लेकिन Channel#basicPublish ऐसी कोई समानक है?!? मुझे Channellogging नामक कतार कहने के लिए कैसे प्रकाशित किया जा सकता है? अग्रिम धन्यवाद!

Answer 1

मूल रूप से कतारों को रूटिंग के आधार पर एक्सचेंज में जोड़ा जा सकता है।

मान लें कि आपके पास 3 अलग-अलग प्रकाशक हैं।
Publisher1 संदेश भेजने "घटनाओं"
Publisher2 भेजने संदेश routingKey साथ आदान-प्रदान करने के लिए "कार्य"
Publisher3 भेजने संदेश routingKey साथ आदान-प्रदान करने routingKey "नौकरियों"

आप एक उपभोक्ता है कि केवल संदेशों की खपत हो सकता है के साथ आदान-प्रदान करने विशिष्ट routhing के साथ।
क्रम में "घटनाओं" संदेश आप इस

channel.queueBind(queueName, exchangeName, "events"); 

तरह की घोषणा आप सभी संदेशों को विनिमय के रूप में '#' आप मार्ग देने के लिए आ रहा उपभोग करने के लिए चाहते हैं के लिए एक उपभोक्ता के लिए उदाहरण के लिए

तो संक्षेप में मैं क्या कह सकता हूं,
1. संदेश एक एक्सचेंज में प्रकाशित किए जाएंगे।
2. पंक्तियों को रूटिंग के आधार पर विनिमय करने के लिए बाध्य किया जाएगा।
3. RabbitMQ संबंधित पंक्तियों से मिलान करने वाली रूटिंग कुंजियों के साथ संदेश अग्रेषित करेगा।

कृपया ट्यूटोरियल देखते हैं - http://www.rabbitmq.com/tutorials/tutorial-three-java.html

RabbitMQ में संदेश भेजने के मॉडल में मुख्य विचार यह है कि निर्माता एक कतार में सीधे किसी भी संदेश भेजता है कभी नहीं है। दरअसल, अक्सर निर्माता यह भी नहीं जानता कि किसी भी कतार में कोई संदेश वितरित किया जाएगा या नहीं। इसके बजाए, निर्माता केवल

Answer 2

इस प्रयास करें:

channel.basicPublish("", yourQueueName, null, 
     message.getBytes((Charset.forName("UTF-8")))); 

यह मेरा परियोजना के लिए काम किया।

Answer 3

@Tien Nguyen के उत्तर पर विस्तार करने के लिए संदेश भेज सकता है, RabbitMQ में "धोखा" है जो प्रभावी रूप से आपको सीधे कतार में प्रकाशित करने देता है। कतार के नाम के साथ रूटिंग कुंजी के रूप में प्रत्येक कतार स्वचालित रूप से AMQP डिफ़ॉल्ट विनिमय से जुड़ी होती है। डिफ़ॉल्ट विनिमय को "नामहीन विनिमय" के रूप में भी जाना जाता है - यानी इसका नाम खाली स्ट्रिंग है। इसलिए यदि आप अपने कतार के नाम के बराबर रूटिंग कुंजी के साथ "" नामक एक्सचेंज पर प्रकाशित करते हैं, तो संदेश केवल उस कतार पर जाएगा। यह एक एक्सचेंज के माध्यम से जा रहा है क्योंकि जॉन ने कहा, यह सिर्फ इतना नहीं है कि आपको खुद को घोषित करने या बांधने की आवश्यकता है।

मेरे पास जावा क्लाइंट इस कोड को आजमाने के लिए आसान नहीं है, लेकिन इसे काम करना चाहिए।

channel.basicPublish("", myQueueName, false, false, null, myMessageAsBytes); 

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