शुरुआती के लिए WebSphere MQ

परिचय

कार्यों में से एक के भाग के रूप में, एक बाहरी प्रणाली के साथ एकीकृत करना आवश्यक था। IBM WebSphere प्रोम में और सभी डेवलपर्स के लिए खड़ा है, इसलिए WebSphere MQ पूरी तरह से फिट बैठता है, यह देखते हुए कि उनके पास IBM WebSphere के साथ उत्कृष्ट आउट-ऑफ-बॉक्स एकीकरण है। सबसे पहले, हम WebSphere और WebSphere MQ को स्थापित और कॉन्फ़िगर करें, जब हम कतार से डेटा भेजने और प्राप्त करने के लिए एक सरल एप्लिकेशन लिखते हैं और HermesJMS की स्थापना और कॉन्फ़िगरेशन को पूरा करते हैं और देखते हैं कि इसे कैसे संदेश भेजें और देखें। सब कुछ विंडोज 7 में किया जाएगा। जारी रखने से पहले, उपरोक्त प्रोग्राम डाउनलोड करें।

सावधानी यातायात!

WebSphere और WebSphere MQ को स्थापित और कॉन्फ़िगर करें

मुझे आशा है कि आप पहले से ही सभी आवश्यक प्रोग्राम डाउनलोड कर चुके हैं और स्थापना के साथ आगे बढ़ने के लिए तैयार हैं। सबसे पहले, IBM इंस्टालेशन मैनेजर इंस्टॉलर को रन करें। लेख का आकार नहीं बढ़ाने के लिए, स्क्रीनशॉट जिसमें एक विशेष अर्थ लोड नहीं है, मैं खराबियों को हटा दूंगा, क्योंकि मुझे लगता है कि लेख से पूरी तरह से हटा देना गलत है क्योंकि वे यह स्पष्ट करते हैं कि आप सब कुछ ठीक कर रहे हैं।


इंस्टालमेंट मैनेजर को पुनः आरंभ करें और फ़ाइल -> विकल्प पर जाएं। पहली डिस्क से संग्रहण जोड़ें।



ओके पर क्लिक करें और इंस्टालेशन शुरू करें।


स्थापना के बाद, प्रोफ़ाइल प्रबंधक स्वचालित रूप से शुरू हो जाएगा।



“क्रिएट…” बटन पर क्लिक करें और फिर नीचे स्क्रीनशॉट की तरह करें।


अब WebSphere MQ स्थापित करें।


स्थापना पूर्ण होने के बाद, WebSphere MQ और WebSphere को कॉन्फ़िगर करें। आइए WebSphere MQ से शुरू करें क्योंकि हमें WebSphere की स्थापना करते समय कतार के नाम और कतार प्रबंधक की आवश्यकता है। सभी आदेशों को WebSphere MQ निर्देशिका की बिन निर्देशिका से निष्पादित किया जाता है। सबसे पहले, एक कतार प्रबंधक बनाएं और crtmqm.exe HABR_QUEUE_MANAGER कमांड का उपयोग करके इसे HABR_QUEUE_MANAGER कहें ।



Strmqm.exe HABR_QUEUE_MANAGER कमांड का उपयोग करके हमारे नए बनाए गए कतार प्रबंधक को लॉन्च करें।



हमारी इनबाउंड और आउटबाउंड कतारें बनाने के लिए, रनमक्स्क ..exe HABR_QUEUE_MANAGER पर कॉल करके MQ कमांड लाइन चलाएं और एक पंक्ति में 2 कमांड निष्पादित करें:

1. DEFINE QLOCAL (HOME.TO.ES) - हमारे एप्लिकेशन से बाहरी सिस्टम पर संदेश भेजने के लिए कतार
2. DEFINE QLOCAL (ES.TO.HOME) - बाहरी सिस्टम से संदेश प्राप्त करने के लिए कतार

यह एक श्रोता और एक चैनल बनाने और इसे चलाने के लिए बना हुआ है, और WebSphere MQ को कॉन्फ़िगर किया जा सकता है। ऐसा करने के लिए, निम्न आदेश चलाएँ:

1. DEFINE LISTENER (HABR_QUEUE_MANAGER.LISTENER) TRPTYPE (TCP) पोर्ट (1414)
2. START LISTENER (HABR_QUEUE_MANAGER.LISTENER)
3. DEFINE चैनल (SYSTEM.ADMIN.SVRCONN) CHLTYPE (SVRCONN)

पोर्ट 1414 याद रखें। WebSphere Application Server को कॉन्फ़िगर करने में उपयोगी।

चलिए WebSphere Application Server को सेट करते हैं।
एक कनेक्शन फैक्टरी बनाएँ। ऐसा करने के लिए, व्यवस्थापक कंसोल को चलाएं और संसाधन-> JMS प्रदाता-> WebSphere MQ संदेश प्रदाता-> कतार कनेक्शन कारखानों-> नया चुनें (जैसा कि नीचे स्क्रीनशॉट में दिखाया गया है)।

इसके बाद नाम और jndi नाम डालें।




कतार प्रबंधक का नाम दर्ज करें।




यदि कनेक्शन सत्यापन के दौरान एक संदेश दिखाई देता है (जो नीचे स्क्रीनशॉट में दिखाया गया है), निम्न चरणों का पालन करें।

1. MQ कमांड प्रॉम्प्ट को फिर से चलाएँ और runmqsc.exe HABR_QUEUE_MANAGER चलाएं
2. अल्टर QMGR CHLUT (डायल करें)
3. Windows सेवा अनुभाग पर जाएं और अपने खाते से IBM MQSeries सेवा को "लॉगऑन" अनुभाग में बदलें। WebSphere Application Server 8.5 के लिए भी ऐसा ही करें
4. सिस्टम रिबूट करें और HABR_QUEUE_MANAGER चलाएं और LISTENER (HABR_QUEUE_MANAGER.LISTENER) शुरू करें
5. अब सब कुछ काम करना चाहिए

अब कतारों का निर्माण करें। हमें 2 कतारें बनाने की आवश्यकता है। उनके पास वेबस्फेयर एमक्यू में बनाई गई कतारों की तरह नाम होंगे। यदि कोई भूल गया, तो उन्हें ES.TO.HOME और HOME.TO.ES कहा जाता है। संसाधनों पर जाएं-> जेएमएस-> कतार-> नया





हम सादृश्य द्वारा दूसरा बनाते हैं।



यह श्रोता बंदरगाह को कॉन्फ़िगर करने के लिए बना हुआ है। एप्लिकेशन सर्वर पर जाएं -> सर्वर 1 -> संदेश श्रोता सेवा -> श्रोता बंदरगाहों और एक नया जोड़ें।



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

अब हमने WebSphere Application Server और WebSphere MQ को अनुकूलित किया है। आप एक साधारण परीक्षण एप्लिकेशन बनाना शुरू कर सकते हैं।

कतार से संदेश भेजने और प्राप्त करने के लिए एक सरल अनुप्रयोग बनाना

मैं जानबूझकर विभिन्न उपकरणों का उपयोग नहीं कर सकता हूं ताकि एक प्रोजेक्ट विकसित करते समय मावेन, ग्रैडल या चींटी जैसी परियोजनाओं का निर्माण किया जा सके ताकि आप समझ सकें कि पर्दे के पीछे क्या चल रहा है। लेकिन फिर भी, सुविधा के लिए, मैं कुछ स्क्रिप्ट लिखूंगा जो आपको कान में प्रोजेक्ट बनाने में मदद करेंगे। मैंने पूरा प्रोजेक्ट गिथब पर पोस्ट किया। नीचे मैं केवल मुख्य बिंदुओं का वर्णन करूंगा।

कतार में एक संदेश भेज रहा है

एक संदेश भेजने के लिए हम एक सर्वलेट, एक बिन और एक संदेश दर्ज करने के लिए एक फॉर्म बनाएंगे।

आइए JMSMessageBean क्लास से शुरू करें ejb-core मॉड्यूल। EjbCreate पद्धति में, हम कनेक्शन कारखाने और उस कतार को लिंक प्राप्त करते हैं, जिस पर हम संदेश भेजेंगे। प्रक्रिया संदेश विधि एक पाठ संदेश बनाने और उसे कतार में भेजने के लिए डिज़ाइन की गई है।

public class JMSMessageBean implements SessionBean { private SessionContext sessionContext; private QueueConnectionFactory connectionFactory; private Queue destination; public boolean processMessage(String message) { QueueConnection jmsConnection = null; QueueSession jmsSession = null; try { jmsConnection = connectionFactory.createQueueConnection(); jmsSession = jmsConnection.createQueueSession(true, Session.AUTO_ACKNOWLEDGE); TextMessage jmsMessage = jmsSession.createTextMessage(); jmsMessage.setText(message); jmsSession.createSender(destination).send(jmsMessage); } catch (JMSException e) { return false; } finally { try { if (jmsSession != null) { jmsSession.close(); } if (jmsConnection != null) { jmsConnection.close(); } } catch (JMSException e) { e.printStackTrace(); } } return true; } public void ejbCreate() throws EJBException { try { Context ctx = new InitialContext(); connectionFactory = (QueueConnectionFactory) ctx.lookup("java:comp/env/QMHabr"); destination = (Queue) ctx.lookup("java:comp/env/jms/HOME.TO.ES"); } catch (NamingException e) { throw new EJBException(e); } } @Override public void ejbActivate() throws EJBException { } @Override public void ejbPassivate() throws EJBException { } @Override public void ejbRemove() throws EJBException { } @Override public void setSessionContext(SessionContext sessionContext) throws EJBException { this.sessionContext = sessionContext; } } 

नीचे हमारा SendJMSMessageServlet सर्वलेट है। Init विधि में, हमें बीन का संदर्भ मिलता है, जो ऊपर वर्णित है। आगे, doPost पद्धति में, यह प्रपत्र से एक संदेश प्राप्त करता है और सेम को प्रोसेसमेसेज विधि में भेजता है। बाक़ी का काम बिन ने किया है।

 public class SendJMSMessageServlet extends HttpServlet { private static final String MESSAGE_PARAMETER_NAME = "message"; private static final String MESSAGE_SENDING_SUCCESS = "  "; private static final String MESSAGE_SENDING_ERROR = "   "; private JMSMessage jmsMessage = null; @Override public void init() throws ServletException { super.init(); try { Context ctx = new InitialContext(); Object objHome = ctx.lookup("java:comp/env/ejb/JMSMessageLocal"); JMSMessageHome jmsMessageHome = (JMSMessageHome) PortableRemoteObject.narrow(objHome, JMSMessageHome.class); jmsMessage = jmsMessageHome.create(); } catch (Exception e) { throw new ServletException(e); } } @Override protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { request.getRequestDispatcher("/sendMessage.jsp").forward(request, response); } @Override protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { request.setCharacterEncoding("UTF-8"); String message = request.getParameter(MESSAGE_PARAMETER_NAME); request.setAttribute(MESSAGE_PARAMETER_NAME, (jmsMessage.processMessage(message)) ? MESSAGE_SENDING_SUCCESS : MESSAGE_SENDING_ERROR); request.getRequestDispatcher("/viewMessage.jsp").forward(request, response); } } 

Html सबमिशन फॉर्म सबसे प्राथमिक है। यह सबसे महत्वपूर्ण हिस्सा नहीं है। संदेश को हार्डकोड किया जा सकता है या गुण फ़ाइल से प्राप्त किया जा सकता है। लेकिन मैं कोड वैसे भी दूंगा।

 <%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8" %> <html> <head> <meta http-equip="Content-Type" content="text/html; charset=UTF-8"/> <title>   </title> </head> <body> <form action="sendMessage" method="POST"> <table> <tr> <td> :</td> <td><input type="text" name="message" size="70"/></td> </tr> <tr> <td colspan="2"><input type="submit" name="submitMessage" value=""/></td> </tr> </table> </form> </body> </html> 

हर्म्सजेएमएस को स्थापित करना और कॉन्फ़िगर करना

यदि WebSphere MQ किसी अन्य मशीन पर स्थापित है और आप कतार में संदेशों की जांच करने के लिए दौड़ रहे हैं या केवल कतार में परीक्षण संदेश भेजने के लिए एक सुविधाजनक उपकरण चाहते हैं, तो आप HermesJMS का उपयोग कर सकते हैं। शायद एनालॉग्स हैं, लेकिन जो मुझे मिला वह भुगतान किया गया था। यदि आप जानते हैं तो टिप्पणियों को अच्छे मुक्त एनालॉग्स में सलाह दें। मैं अन्य समान प्रणालियों पर सहर्ष विचार करूंगा। विशेष रूप से, हर्मीजजेएमएस में कुछ यूआई बग पूरी तरह से संतुष्ट नहीं होते हैं और यदि आप किसी फ़ाइल (कसकर लॉक) से एक संदेश भेजते हैं, तो संसाधनों को मुक्त नहीं किया जाता है, लेकिन आप उनके साथ रह सकते हैं।

और इसलिए, चलो स्थापना और कॉन्फ़िगरेशन के साथ आगे बढ़ें।


HermesJMS लॉन्च करें और एक नया सत्र जोड़ें। आरंभ करने के लिए, प्रदाता टैब पर जाएं और एक नया समूह जोड़ें। इसे स्क्रीनशॉट में नाम दें (हालाँकि यह महत्वपूर्ण नहीं है) और नीचे सूचीबद्ध सभी जार फ़ाइलों को जोड़ें।



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



अब हमारी बारी के लिए एक संदेश भेजने की कोशिश करें। ऐसा करने के लिए, पता http: // localhost: 9080 / habr / sendMessage पर जाएं और इनपुट क्षेत्र में कोई भी संदेश दर्ज करें और "भेजें" बटन पर क्लिक करें।



अब HermesJMS खोलें और देखने के लिए HOME.TO.ES कतार खोलें। यदि आपने नीचे दिए गए स्क्रीनशॉट में दिखाए गए संदेश को देखा, तो आपने उपरोक्त सभी चरणों को सही ढंग से निष्पादित किया।



इस पर मैंने लेख पूरा किया। आपके ध्यान के लिए आप सभी का धन्यवाद! मुझे उम्मीद है कि वह किसी के लिए उपयोगी होगी।