😗 🍕 👩‍🏭 जेईई में जेएमएस संदेशों और एमडीबी के साथ काम करें 🐣 🏼 ☝🏽

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

एमडीबी का उपयोग करके जेएमएस संदेश को संसाधित करने का एक सरल उदाहरण निम्नलिखित है।

सिद्धांत की बिट

संदेशों के साथ काम करने के लिए, सहायक सॉफ्टवेयर का उपयोग किया जाता है, जिसे आमतौर पर एप्लिकेशन सर्वर के साथ शामिल किया जाता है।
सिस्टम घटक संदेश भेज सकते हैं (निर्माता) और उन्हें (उपभोक्ता) प्राप्त कर सकते हैं। संदेश
निर्माता को गंतव्य पर भेजता है, जो सर्वर पर एक कतार या विषय है, जिसके बाद उपभोक्ता वहां से एक संदेश ले सकता है
गंतव्य किस प्रकार का है, इसके आधार पर दो मैसेजिंग मॉडल साझा किए जाते हैं।

पहला मॉडल - प्वाइंट-टू-प्वाइंट

यदि गंतव्य सर्वर में कतार प्रकार है, तो निर्माता द्वारा भेजा गया संदेश एकमात्र उपभोक्ता द्वारा प्राप्त किया जाता है। यदि कई प्राप्तकर्ताओं को इस संदेश कतार में सदस्यता दी जाती है, तो उनमें से केवल एक संदेश प्राप्त करेगा।

दूसरा मॉडल - प्रकाशित-सदस्यता

यदि गंतव्य सर्वर विषय प्रकार का है, तो एक संदेश को असीमित संख्या में उपभोक्ताओं द्वारा पढ़ा जा सकता है, जिन्हें इस गंतव्य के लिए सदस्यता दी गई है।

जेएमएस संदेश संरचना

एक संदेश में एक हेडर, एक संपत्ति क्षेत्र और एक निकाय होता है।
शीर्ष लेख मेटा संदेश की जानकारी संग्रहीत करता है जो स्वचालित रूप से आबादी है।
प्रॉपर्टी फ़ील्ड हेडर के समान है, लेकिन यह प्रोग्रामेटिक रूप से पॉपुलेटेड है, और बाद में प्राप्तकर्ता इस जानकारी को पढ़ने में सक्षम होगा।
शरीर में संदेश पेलोड होता है। संदेश बनाते समय लोड का प्रकार निर्धारित किया जाता है। विशिष्ट प्रकार javax.jms.Message इंटरफ़ेस से विरासत में मिले हैं ।

सर्वर पर एक कतार बनाना।

एक उदाहरण के लिए हम सर्वर पर विषय बनाएंगे। मैं ग्लासफिश 3.1 का उपयोग करूंगा।
सबसे पहले, एक कनेक्शन फैक्टरी बनाएं। किस प्रकार की संदेश कतार का उपयोग किया जाएगा, इसके आधार पर कई प्रकार संभव हैं।

फिर हम प्रकार के संकेत के साथ गंतव्य बनाते हैं।

संदेश भेजने वाला बनाएँ

इस मामले में, निर्माता एप्लिकेशन सर्वर पर स्थित होगा। यदि आपको किसी व्यक्तिगत क्लाइंट से संदेश भेजने की आवश्यकता है, तो आपको संदर्भ से उनके मानक JNDI नाम की वस्तुओं तक पहुंचने की आवश्यकता होगी।

//      @Resource(name="jms/TutorialPool") private ConnectionFactory connectionFactory; @Resource(name="jms/TutorialTopic") private Destination destination; public String getEnterString() { return enterString; } public void sendString(String enterString) { try { //  Connection connection = connectionFactory.createConnection(); Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); MessageProducer producer = session.createProducer(destination); TextMessage message = session.createTextMessage(); //  JMS         message.setStringProperty("clientType", "web clien"); // payload   message.setText(enterString); //  producer.send(message); System.out.println("message sent"); //  session.close(); connection.close(); } catch (JMSException ex) { System.err.println("Sending message error"); ex.printStackTrace(); } }

संदेश-प्रेरित बीन

सर्वर पर आने वाले संदेशों को संसाधित करने के लिए, हम एमडीबी का उपयोग करेंगे।

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

MBD को लागू करने के लिए, यह ऑनमैसेज () पद्धति को लागू करके javax.jms.MessageListener इंटरफ़ेस से सेम को इनहेरिट करने के लिए पर्याप्त है और तदनुसार वर्ग को एनोटेट करें।

आइए एमडीबी का एक उदाहरण बनाते हैं, जो सर्वर कंसोल में प्राप्त संदेश के बारे में जानकारी प्रदर्शित करता है।

 @MessageDriven( // topic,     mappedName="jms/TutorialTopic", name = "ExampleMDB") public class MDBExample implements MessageListener{ //,      @Override public void onMessage(Message msg) { try { TextMessage message = (TextMessage)msg; //    ,    consumer System.out.println("FROM MDB - client type IS " + message.getStringProperty("clientType")); //   System.out.println("FROM MDB - payload IS" + message.getText()); } catch (JMSException ex) { ex.printStackTrace(); } } }

संदेश के प्रकार, उसकी सामग्री, आदि के आधार पर आवश्यक व्यावसायिक तर्क को ऑनमैसेज विधि में जोड़ा जाता है।
यदि आवश्यक हो, संदेशों के मैनुअल प्रसंस्करण के लिए, आप स्वतंत्र रूप से एक हैंडलर बना सकते हैं।
उदाहरण के लिए, इस तरह:

  @Resource(name="jms/TutorialPool") private ConnectionFactory connectionFactory; @Resource(name="jms/TutorialTopic") private Destination destination; void onMessage(){ try { Connection connection = connectionFactory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageConsumer consumer = session.createConsumer(destination); connection.start(); while(true){ Message msg = consumer.receive(); //  } // connection } catch (JMSException ex) { ex.printStackTrace(); } }

सामान्य रूप से जेएमएस और ईजेबी के अधिक विस्तृत अध्ययन के लिए, मैं पुस्तकों की सिफारिश कर सकता हूं:
ईजेबी 3 एक्शन - देबू पांडा, रेजा रहमान, डेरेक लेन
एडम बायन की कुछ किताबें

जेईई में जेएमएस संदेशों और एमडीबी के साथ काम करें