🥇큐와 JMeter: Publisher 및 Subscriber와 공유

안녕, 하브르! 이건 내 후속편이야 이전 간행물, JMeter를 사용하여 대기열에 메시지를 배치하는 옵션에 대해 설명하겠습니다.

우리는 대규모 연방 회사를 위한 데이터 버스를 만들고 있습니다. 다양한 요청 형식, 변환, 복잡한 라우팅. 테스트하려면 대기열에 많은 메시지를 보내야 합니다. 수동적으로는 모든 척추지압사가 감당할 수 없는 고통입니다.

소개

처음에는 이 고통을 참아야 했지만. 모든 것은 RFHUtil에서 시작되었습니다. 강력하지만 어색하고 무섭습니다. 글쎄, 당신은 Rus를 알고 있습니다.

어떤 경우에는 필수 불가결하지만 적극적으로 사용하는 경우 꾸준히 감소합니다.
편리한 테스트는 불가능합니다.

JMeter를 사용하면 모든 것이 더 쉬워졌습니다. 첫 번째 마스터링 단계와 익숙해진 후에 행복한 테스트에 대한 희망이 생기기 시작했습니다.

나는 JMS 게시자 및 JMS 구독자 샘플러를 적극적으로 사용합니다. JMS Point-to-Point와 달리 이 쌍은 사용하기 더 편리해 보였습니다. 예를 들어, JMS Selector의 Subscriber를 사용하면 변수를 지정할 수 있지만 Point-to-Point에서는 그렇게 할 수 없습니다(또는 이 방법은 그다지 명확하지 않습니다).

샘플러 준비

JMS 게시자

설정 - 각 샘플. 아파치 추천하다 변수를 통해 대기열/주제를 지정한 경우 이 옵션을 사용하세요.
만료(ms) = 120000. 실패할 경우 테스트 요청은 2분 후에 대기열에서 사라집니다.
비지속적 전달 모드를 사용하시겠습니까? - 진실. IBM 승인하다해당 지속 모드는 갑작스러운 오류가 발생하는 경우 전송된 메시지를 안정적으로 보존합니다. 비지속 모드에서는 더 빠른 교환이 가능합니다. 테스트 목적에서는 속도가 더 중요합니다.

각 게시자에서 구독자가 JMS 선택기에서 사용할 jms 속성을 설정했습니다. 제출할 때마다 사용자 매개변수 테스트 계획 요소에 임의의 값이 생성됩니다.

이렇게 하면 올바른 메시지를 읽었는지 확인할 수 있습니다.

사전 구성된 JMS 게시자의 마지막 "공백":

JMS 구독자

설정 - 각 샘플. 글쎄, 당신은 이해합니다.
제한 시간(ms) = 100000. 100초 동안 대기한 후에도 요청이 대기열에 도착하지 않으면 문제가 발생한 것입니다.
샘플 사이에 중지하시겠습니까? - 진실.

JMS 선택기 - 매우 편리함 조각. 최종 JMS 가입자:

전송된 메시지에서 키릴 문자를 처리하는 방법. JMeter에서는 기본적으로 교정 후 삐뚤게 표시됩니다. 이를 피하고 언제 어디서나 위대하고 강력한 것을 즐기려면 다음을 수행해야 합니다.

JMeter "실행기"에 JVM 인수를 추가합니다.
```
-Dfile.encoding=UTF-8
```
그루비 라인을 사용하여 구독자에 JSR223 PostProcessor를 추가합니다.
```
prev.setDataEncoding("UTF-8")
```

문자를 보내다

가장 게으른 옵션. 새로 작성된 테스트를 디버깅하는 데 적합합니다. 또는 최소한 작은 것을 보내야 하는 경우. 옵션을 선택하세요 메시지 소스 - 텍스트 영역 메시지 본문을 텍스트 블록에 배치합니다.

파일 전송

가장 일반적인 옵션입니다. 대부분의 시나리오에 적합합니다. 옵션을 선택하세요 메시지 소스 - 파일에서 필드에 메시지 경로를 표시합니다. 파일 - 파일 이름:

파일을 텍스트 필드로 전송하기

가장 다양한 옵션. 대부분의 시나리오에 적합 + 두 번째 전송 옵션이 없는 JMS 지점 간에서 사용할 수 있습니다.

바이트 배열 전달

가장 어려운 옵션. 왜곡, SMS 및 교란 없이 요청의 바이트까지 정확하고 정확한 전송을 확인하는 데 적합합니다. 기본 JMeter에서는 이 작업을 수행할 수 없습니다. 여기에 나는 이것에 대해 확실히 들었습니다.

그래서 다운로드를 해야 했어요 출처 수정하고 암호 JMS 가입자.

메서드에서 대체됨 extractContent(..) 선:

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

on :

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();

그리고 Publisher에서 파일 경로를 추가하는 것을 잊지 마세요.

또한 JSR223 Assertion for Subscriber에 대한 확인도 있습니다. 소스 바이트를 수신자의 대기열에 도착하는 바이트와 비교합니다.

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;
	}

결론

실제로 매일 사용하는 큐에 메시지를 보내는 네 가지 방법을 설명했습니다. 이 정보가 귀하의 삶을 더 쉽게 만들어주기를 바랍니다. 계속해서 한쪽 끝에는 큐가 있고 다른 쪽 끝에는 데이터베이스나 파일 시스템이 있는 교환을 테스트한 경험에 대해 이야기할 계획입니다.

시간을 절약하세요. 관심을 가져주셔서 감사합니다.

출처 : habr.com

대기열 및 JMeter: 게시자 및 구독자와 공유

소개