👊🏻 👩🏼‍💼 👎 कतार और जेमीटर: प्रकाशक और सब्सक्राइबर के साथ एक्सचेंज 🔊 〽️ 🧖🏻

नमस्कार, हेब्र!

यह मेरे पिछले प्रकाशन की अगली कड़ी है, जिसमें मैं JMeter का उपयोग करके संदेशों को कतारों में रखने के विकल्पों के बारे में बात करूंगा।

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

परिचय

हालाँकि मुझे पहले इस दर्द से जूझना पड़ा। यह सब RFHUtil से शुरू हुआ। शक्तिशाली, लेकिन असहज और डरावना: ~~ठीक है, आप रस जानते हैं।~~

कुछ मामलों में अपरिहार्य, लेकिन सक्रिय रूप से उपयोग करने के मामले में स्थिर रूप से गिर रहा है।
उसके साथ सुविधाजनक परीक्षण असंभव है।

JMeter के साथ, चीजें आसान हो गईं। पहले चरण में महारत हासिल करने और इसकी अभ्यस्त होने के बाद, एक खुशहाल परीक्षण की आशा आई।

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

नमूना तैयार करना

जेएमएस प्रकाशक

सेटअप - प्रत्येक नमूना। यदि चर / विषय चर के माध्यम से निर्दिष्ट किए जाते हैं तो अपाचे इस विकल्प का उपयोग करने की सलाह देता है ।
समाप्ति (एमएस) = 120000. विफलता के मामले में, परीक्षण अनुरोध 2 मिनट के बाद कतार से गायब हो जाएंगे।
गैर-स्थायी वितरण मोड का उपयोग करें? - सच। आईबीएम का दावा है कि लगातार मोड अचानक विफलता की स्थिति में संदेशों की विश्वसनीय दृढ़ता प्रदान करता है। और गैर-निरंतर मोड में तेजी से साझा करना। परीक्षण के उद्देश्यों के लिए, गति अधिक महत्वपूर्ण है।

प्रत्येक प्रकाशक में, मैं jms गुण सेट करता हूँ जो सब्सक्राइबर JMS चयनकर्ता में उपयोग करेगा। प्रत्येक शिपमेंट के लिए, उपयोगकर्ता पैरामीटर परीक्षण योजना तत्व में एक यादृच्छिक मूल्य उत्पन्न होता है:

इसलिए आप सुनिश्चित हो सकते हैं कि सही संदेश पढ़ा गया है।

पूर्व-कॉन्फ़िगर जेएमएस प्रकाशक का अंतिम "रिक्त":

Jms ग्राहक

सेटअप - प्रत्येक नमूना। खैर, आप बात करते हैं।
टाइमआउट (एमएस) = 100000। यदि अनुरोध 100 सेकंड प्रतीक्षा के बाद कतार में नहीं आता है, तो कुछ गलत हुआ।
नमूना के बीच बंद करो? - सच।

JMS चयनकर्ता एक बहुत ही काम की चीज है । सारांश जेएमएस सब्सक्राइबर:

प्रेषित संदेशों में सिरिलिक वर्णमाला से कैसे निपटें। JMeter में, डिफ़ॉल्ट रूप से, घटाव के बाद, यह कुटिल रूप से प्रदर्शित होता है। इससे बचने के लिए और हमेशा और हर जगह महान और शक्तिशाली का आनंद लें, आपको इसकी आवश्यकता है:

JMM "लॉन्चर" में JVM तर्क जोड़ें:
```
-Dfile.encoding=UTF-8 
```
Groovy पर एक लाइन के साथ सब्सक्राइबर JSR223 पोस्टप्रोसेसर जोड़ें:
```
 prev.setDataEncoding("UTF-8") 
```

पाठ स्थानांतरण

सबसे हल्का विकल्प। हौसले से लिखे गए परीक्षणों को डिबग करने के लिए उपयुक्त है। या ऐसे मामलों के लिए जब आपको कम से कम कुछ छोटा भेजने की आवश्यकता होती है। विकल्प का चयन करें संदेश स्रोत - टेक्सटेरिया और संदेश बॉडी को टेक्स्ट ब्लॉक में रखें:

फ़ाइल स्थानांतरण

सबसे आम विकल्प। अधिकांश परिदृश्यों के लिए उपयुक्त है। विकल्प का चयन करें संदेश स्रोत - फ़ाइल से और फ़ाइल में संदेश के लिए पथ निर्दिष्ट करें - फ़ाइल नाम फ़ील्ड :

फाइल को टेक्स्ट फील्ड में ट्रांसफर करें

सबसे बहुमुखी विकल्प। अधिकांश परिदृश्यों के लिए उपयुक्त + का उपयोग जेएमएस पॉइंट-टू-पॉइंट में किया जा सकता है, जिसमें कोई दूसरा भेजने का विकल्प नहीं है:

बाइट सरणी हस्तांतरण

सबसे कठिन विकल्प। विरूपण, एसएमएस और गड़बड़ी के बिना, बाइट के अनुरोधों के असीम रूप से सटीक हस्तांतरण की जांच करने के लिए उपयुक्त है। मैं डिफ़ॉल्ट JMeter में ऐसा नहीं कर सकता, यहाँ उन्होंने मुझे इसके बारे में निश्चित रूप से बताया।

इसलिए, मुझे स्रोतों को डाउनलोड करना पड़ा और जेएमएस सब्सक्राइबर कोड को संशोधित करना पड़ा।

निकाले गए लाइन को extractContent(..) विधि में बदला गया:

 buffer.append(bytesMessage.getBodyLength() + " bytes received in BytesMessage");

पर:

 byte[] bytes = new byte[(int) bytesMessage.getBodyLength()]; bytesMessage.readBytes(bytes); try { buffer.append(new String(bytes, "UTF-8")); } catch (UnsupportedEncodingException e) { throw new RuntimeException(e); }

और JMeter का पुनर्निर्माण किया।

यह JSR223 के एक जोड़े को जोड़ने के लिए बनी हुई है। रैंडम / सब्सक्राइबर जोड़ी से पहले पहला है एक बेतरतीब बाइट युक्त .dat फ़ाइल बनाने के लिए:

 import org.apache.commons.lang3.RandomUtils; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; vars.put("PATH_TO_BYTES", "C:\\temp\\randomBytes.dat"); File RESULT_FILE = new File(vars.get("PATH_TO_BYTES")); byte[] arr = RandomUtils.nextBytes((int)(Math.random()*10000)); try { FileOutputStream fos = new FileOutputStream(RESULT_FILE); fos.write(arr); fos.close(); } catch (IOException e) { System.out.println("file not found"); }

स्क्रिप्ट के अंत में दूसरा वाला, फ़ाइल को हटा देता है:

 import java.io.File; File RESULT_FILE = new File(vars.get("PATH_TO_BYTES")); RESULT_FILE.delete();

और प्रकाशक से फ़ाइल में पथ जोड़ने के लिए मत भूलना:

और सब्सक्राइबर के लिए JSR223 अभिकथन में एक चेक - स्रोत बाइट्स की तुलना उन लोगों के साथ करें जो रिसीवर की कतार में आते हैं:

 import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.util.Arrays; Path path = Paths.get(vars.get("PATH_TO_BYTES"), new String[0]); byte[] originalArray = Files.readAllBytes(path); byte[] changedArray = ctx.getPreviousResult().getResponseData(); System.out.println(changedArray.length); if (Arrays.equals(originalArray, changedArray)) { SampleResult.setResponseMessage("OK"); } else { SampleResult.setSuccessful(false); SampleResult.setResponseMessage("Comparison failed"); SampleResult.setResponseData("Bytes have changed","UTF-8"); IsSuccess=false; }

निष्कर्ष

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

अपने समय का ख्याल रखें। और देखने के लिए धन्यवाद।

कतार और जेमीटर: प्रकाशक और सब्सक्राइबर के साथ एक्सचेंज