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

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

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

परिचय

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

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

JMeter से सब कुछ आसान हो गया है। महारत हासिल करने और इसकी आदत डालने के पहले चरण के बाद, सुखद परीक्षण की आशा जगने लगी।

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

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

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

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

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

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

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

जेएमएस सब्सक्राइबर

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

जेएमएस चयनकर्ता - काफी सुविधाजनक चीज़. अंतिम जेएमएस सब्सक्राइबर:

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

1. JMeter "लॉन्चर" में एक JVM तर्क जोड़ें:

   -Dfile.encoding=UTF-8

2. ग्रूवी लाइन के साथ सब्सक्राइबर में 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:temprandomBytes.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;
	}

निष्कर्ष

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

अपना समय बचाएं. और आपके ध्यान के लिए धन्यवाद.

स्रोत: www.habr.com