🥇Warteschlangen und JMeter: Austausch mit Publisher und Subscriber

Hallo, Habr! Dies ist die Fortsetzung meines vorherige Veröffentlichung, in der ich über die Möglichkeiten der Nachrichtenplatzierung in Warteschlangen mit JMeter berichten werde.

Wir erstellen eine Datenpipeline für ein großes nationales Unternehmen. Verschiedene Anfrageformate, Transformationen, komplexe Routenführungen. Für Tests müssen viele Nachrichten in die Warteschlangen gesendet werden. Manuell – ein Schmerz, mit dem nicht jeder Tester umgehen kann.

Einführung

Obwohl wir uns in den Anfangszeiten mit diesem Schmerz arrangieren mussten. Alles begann mit RFHUtil. Leistungsstark, aber unbequem und gruselig: Ihr wisst schon, wie es zu Russisch ist.

Unverzichtbar in bestimmten Fällen, aber stabil abstürzend bei aktiver Nutzung.
Bequemes Testen ist damit unmöglich.

Mit JMeter wurde alles einfacher. Nach der ersten Phase des Lernens und Eingewöhnens dämmerte die Hoffnung auf glückliches Testen.

Ich nutze aktiv die JMS Publisher- und JMS Subscriber-Sampler. Im Gegensatz zu JMS Point-to-Point scheint dieses Duo angenehmer in der Anwendung zu sein. Zum Beispiel kann man beim Subscriber im JMS Selector eine Variable angeben, beim Point-to-Point - nicht (oder dieser Weg ist nicht besonders offensichtlich).

Vorbereitung der Sampler

JMS Publisher

Setup - Jede Probe. Apache empfiehlt verwenden Sie diese Option, wenn Warteschlangen/Themen über Variablen festgelegt sind.
Ablauf (ms) = 120000. Im Falle eines Fehlers verschwinden die Testanfragen nach 2 Minuten aus der Warteschlange.
Nicht-beständige Lieferart verwenden? - wahr. IBM stellt fest, dass der beständige Modus eine zuverlässige Speicherung der übertragenden Nachrichten im Falle eines plötzlichen Ausfalls gewährleistet. Und schnelleren Austausch im nicht-beständigen Modus. Für Testzwecke ist die Geschwindigkeit wichtiger.

In jedem Publisher lege ich eine JMS-Eigenschaft fest, die der Subscriber im JMS Selector verwenden wird. Für jede Sendung wird ein zufälliger Wert im Element des Testplans Benutzerparameter generiert:

So kann man sicher sein, dass die richtige Nachricht gelesen wird.

Die endgültige "Dummie" des vorkonfigurierten JMS Publishers:

JMS Subscriber

Setup - Jede Probe. Ihr habt es verstanden.
Timeout (ms) = 100000. Wenn die Anfrage nach 100 Sekunden Wartezeit nicht in der Warteschlange ankommt, ist etwas schief gelaufen.
Zwischen den Proben stoppen? - wahr.

JMS Selector - eine recht praktische Sache. Der endgültige JMS Subscriber:

Wie man mit der Kyrillik in übertragenden Nachrichten umgeht. In JMeter wird sie standardmäßig nach dem Auslesen schief angezeigt. Um dies zu vermeiden und die große und mächtige Sprache jederzeit und überall zu genießen, muss man:

Einen JVM-Parameter zum "Launcher" JMeter hinzufügen:
```
-Dfile.encoding=UTF-8
```
Einen JSR223 PostProcessor im Subscriber mit der Zeile in Groovy hinzufügen:
```
prev.setDataEncoding("UTF-8")
```

Textübertragung

Die faulste Option. Geeignet für das Debuggen frisch geschriebener Tests. Oder in Fällen, in denen man wenigstens etwas Kleines senden muss. Option auswählen Nachrichtenquelle — Textbereich und den Nachrichtentext im Textblock platzieren:

Dateiübertragung

Die häufigste Option. Geeignet für die meisten Szenarien. Option auswählen Nachrichtenquelle — Von Datei und den Pfad zur Nachricht im Feld angeben Datei — Dateiname:

Dateiübertragung im Textfeld

Die universellste Option. Geeignet für die meisten Szenarien + kann in JMS Point-to-Point verwendet werden, bei dem es keine zweite Versandoption gibt:

Übertragung von Bytearrays

Die komplexeste Option. Geeignet für die präzise Überprüfung der Anfrageübertragung bis zum Byte, ohne Verzerrungen, SMS oder Störungen. Dies ist nicht mit dem Standard-JMeter möglich, hier wurde mir deutlich gesagt.

Deshalb musste ich herunterladen Quellcode und modifizieren Code JMS Subscriber.

Ich habe in der Methode extractContent(..) die Zeile ersetzt:

buffer.append(bytesMessage.getBodyLength() + " Bytes erhalten in BytesMessage");

auf:

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

und JMeter neu kompiliert.

Es bleibt, ein paar JSR223 Sampler hinzuzufügen. Der erste — vor dem Paar Publisher/Subscriber zur Erstellung einer DAT-Datei, die zufällige Bytes enthält:

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("Datei nicht gefunden");
        }

Der zweite — am Ende des Szenarios, löscht die Datei:

import java.io.File;

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

Und nicht vergessen, den Datei-Pfad beim Publisher hinzuzufügen:

Und auch die Überprüfung in der JSR223 Assertion für Subscriber — um die ursprünglichen Bytes mit denen zu vergleichen, die in der Warteschlange des Empfängers ankommen:

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("Vergleich fehlgeschlagen");
	   SampleResult.setResponseData("Bytes haben sich geändert","UTF-8");
     	   IsSuccess=false;
	}

Fazit

Ich habe vier Methoden zur Übermittlung von Nachrichten in Warteschlangen beschrieben, die ich täglich in der Praxis anwende. Ich hoffe, diese Informationen erleichtern Ihnen das Leben. Ich plane, in der Fortsetzung über meine Erfahrungen beim Testen des Austauschs zu berichten, bei dem auf der einen Seite die Warteschlange und auf der anderen Seite die Datenbank oder das Dateisystem steht.

Schützen Sie Ihre Zeit. Vielen Dank für Ihre Aufmerksamkeit.

Quelle: habr.com