पेश है JMS 2.0

बहुत समय पहले नहीं, 12 जून 2013 को, जावा ईई 7 की रिलीज को दुनिया के सामने लाया गया था । इस रिलीज़ में एक प्रमुख बिंदु जेएमएस संस्करण 2.0 की उपस्थिति थी, जिसे 2002 के बाद से अपडेट नहीं किया गया है।

यह पाठ निगेल डिकिन के लेख की शुरुआत का एक मुफ्त अनुवाद है। पाठ को नए एपीआई के साथ इच्छुक पाठक को परिचित करना है।

जेएमएस 1.1 एपीआई को काम करने के लिए बहुत सारे कोड की आवश्यकता होती है, लेकिन खुद को अच्छी तरह से साबित करने में कामयाब रहे, इसलिए, 2002 के बाद से यह नहीं बदला है। JMS 2.0 में, नया API JMS संदेशों को भेजने और प्राप्त करने को आसान बनाने के लिए डिज़ाइन किया गया है। पिछले API को समाप्त नहीं किया गया है और नए के साथ काम करना जारी रखता है।

JMS 2.0 एपीआई: JMSContext, JMSProducer और JMSConsumer में नए इंटरफेस दिखाई दिए हैं।

• JMSContext क्लासिक JMS API में कनेक्शन और सत्र को प्रतिस्थापित करता है
• JMSProducer एक लाइटवेट MessageProducer प्रतिस्थापन है जो आपको तरीकों की एक श्रृंखला ( बिल्डर पैटर्न ) को कॉल करके संदेश वितरण सेटिंग्स, हेडर, गुण सेट करने की अनुमति देता है।
• JMSConsumer MessageConsumer को प्रतिस्थापित करता है और उसी सिद्धांत पर उपयोग किया जाता है।

जेएमएस प्रस्तुत करना

तुलना के लिए। JMS 1.1:

public void sendMessageJMS11(ConnectionFactory connectionFactory, Queue queue, String text) { try { Connection connection = connectionFactory.createConnection(); try { Session session =connection.createSession(false,Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(queue); TextMessage textMessage = session.createTextMessage(text); messageProducer.send(textMessage); } finally { connection.close(); } } catch (JMSException ex) { // handle exception (details omitted) } } 

JMS 2.0:

 public void sendMessageJMS20(ConnectionFactory connectionFactory, Queue queue, String text) { try (JMSContext context = connectionFactory.createContext();){ context.createProducer().send(queue, text); } catch (JMSRuntimeException ex) { // handle exception (details omitted) } } 

• संस्करण 2.0 में हम JavaSE 7 से कोशिश-के-संसाधनों का उपयोग करते हैं
• SMS.AUTO_ACKNOWLEDGE पैरामीटर डिफ़ॉल्ट रूप से JMSContext में सेट है। यदि आप एक और मान (CLIENT_ACKNOWLEDGE या DUPS_OK_ACKNOWLEDGE) सेट करना चाहते हैं, तो इसे एक अलग पैरामीटर के रूप में पारित किया जाता है
• कनेक्शन और सत्र वस्तुओं के बजाय JMSContext द्वारा उपयोग किया जाता है
• एक TextMessage बनाने के लिए, बस भेजने की विधि को लाइन पास करें

नए API की एक विशिष्ट विशेषता यह है कि इसके तरीके एक जाँच किए गए JMSException के बजाय RuntimeException - JMSRuntimeException को फेंकते हैं। यह आपको वैकल्पिक रूप से जेएमएस अपवादों को संभालने की अनुमति नहीं देता है।

तुल्यकालिक जेएमएस पुनर्प्राप्ति

संदेश प्राप्त करते समय अंतर की तुलना करें।
JMS 1.1:

 public String receiveMessageJMS11(ConnectionFactory connectionFactory,Queue queue){ String body=null; try { Connection connection = connectionFactory.createConnection(); try { Session session =connection.createSession(false,Session.AUTO_ACKNOWLEDGE); MessageConsumer messageConsumer = session.createConsumer(queue); connection.start(); TextMessage textMessage = (TextMessage)messageConsumer.receive(); body = textMessage.getText(); } finally { connection.close(); } } catch (JMSException ex) { // handle exception (details omitted) } return body; } 

JMS 2.0:

 public String receiveMessageJMS20(ConnectionFactory connectionFactory,Queue queue){ String body=null; try (JMSContext context = connectionFactory.createContext();){ JMSConsumer consumer = context.createConsumer(queue); body = consumer.receiveBody(String.class); } catch (JMSRuntimeException ex) { // handle exception (details omitted) } return body; } 

• स्वचालित रूप से एक कनेक्शन को बंद करने के लिए कोशिश-के साथ संसाधनों द्वारा प्रयुक्त
• कनेक्शन और सत्र वस्तुओं के बजाय JMSContext द्वारा उपयोग किया जाता है
• AUTO_ACKNOWLEDGE डिफ़ॉल्ट रूप से सेट किया गया है
• एक JMSRuntimeException द्वारा संभाला गया, जिसे JMS 1.1 में JMSException के बजाय हैंडल नहीं किया जा सकता है
• कनेक्शन.स्टार्ट () स्वचालित रूप से चलता है
• स्ट्रिंग को उपभोक्ता के माध्यम से स्वचालित रूप से प्राप्त किया जाता है ।receiveBody (String.class) विधि, संदेश ऑब्जेक्ट प्राप्त करने के बजाय, इसे TextMessage को कास्टिंग करें और गेटटेक्स्ट विधि को कॉल करें।

अतुल्यकालिक जेएमएस पुनर्प्राप्ति

जावा में, संदेशों को अतुल्यकालिक रूप से प्राप्त करने के लिए, JMS 1.1 में निम्नलिखित कोड का उपयोग किया जाता है:

 MessageConsumer messageConsumer = session.createConsumer(queue); messageConsumer.setMessageListener(messageListener); connection.start(); 

JMS 2.0 में, यह इस तरह दिखता है:

 JMSConsumer consumer = context.createConsumer(queue); consumer.setMessageListener(messageListener); 

MessageConsumer के बजाय - JMSConsumer। कनेक्शन स्वचालित रूप से शुरू होता है।

जावा ईई वेब या ईजेबी अनुप्रयोगों में, पहले की तरह, आपको सेटमैसेज लाइजनर विधि के बजाय एक संदेश-चालित बीन का उपयोग करना चाहिए

Java EE एप्लिकेशन में JMSContext ऑब्जेक्ट डालें

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

निम्नलिखित कोड स्निपेट आपको एक सत्र बीन या सर्वलेट में JMSContext एम्बेड करने की अनुमति देता है।

 @Inject @JMSConnectionFactory( "jms/connectionFactory") private JMSContext context; @Resource(lookup = "jms/dataQueue") private Queue dataQueue; public void sendMessageJavaEE7(String body) { context.send(dataQueue, body); } 

JMSContext को बंद करना एप्लिकेशन सर्वर द्वारा स्वचालित रूप से किया जाता है। यदि किसी अनुरोध के दौरान JTA लेनदेन किया जाता है, तो JMSContext एक कमिट के बाद अपने आप बंद हो जाएगा; यदि कोई लेन-देन किए बिना, यह अनुरोध के अंत में बंद हो जाएगा।

इस पर मैंने रुकने का फैसला किया। अपने आप को परिचित करने और आरंभ करने के लिए, यह जानकारी पर्याप्त होनी चाहिए। बहुत सारी जानकारी और अतिरिक्त जानकारी यहाँ:
जेएमएस 2.0 में नया क्या है, भाग एक: उपयोग में आसानी
जेएमएस 2.0 में नया क्या है, भाग दो - नई संदेश सुविधाएँ