Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Arbeiten mit Amazon Simple Queue Service Nachrichtenwarteschlangen

Eine Nachrichtenwarteschlange ist der logische Container, der zum zuverlässigen Senden von Nachrichten in Amazon Simple Queue Service genutzt wird. Es gibt zwei Arten von Warteschlangen: Standard und First-in-First-out-Verfahren (FIFO). Weitere Informationen zu Warteschlangen und den Unterschieden zwischen diesen Typen finden Sie im Amazon Simple Queue Service -Entwicklerhandbuch.

In diesem Thema wird beschrieben, wie Sie Amazon Simple Queue Service-Warteschlangen erstellen, auflisten, löschen und die URL einer Warteschlange mit AWS SDK for Java abrufen können.

Die sqsClient Variable, die in den folgenden Beispielen verwendet wird, kann aus dem folgenden Codeausschnitt erstellt werden.

SqsClient sqsClient = SqsClient.create();

Wenn Sie ein SqsClient mit der statischen create() Methode erstellen, konfiguriert das SDK die Region mithilfe der standardmäßigen Regionsanbieterkette und die Anmeldeinformationen mithilfe der standardmäßigen Anbieterkette für Anmeldeinformationen.

Erstellen einer Warteschlange

Verwenden Sie die -SqsClient’screateQueueMethode und stellen Sie ein CreateQueueRequest Objekt bereit, das die Warteschlangenparameter beschreibt, wie im folgenden Codeausschnitt gezeigt.

Importe

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.*;
import java.util.List;

Code

            CreateQueueRequest createQueueRequest = CreateQueueRequest.builder()
                .queueName(queueName)
                .build();

            sqsClient.createQueue(createQueueRequest);

Sehen Sie sich das vollständige Beispiel auf an GitHub.

Auflisten von Warteschlangen

Um die Amazon Simple Queue ServiceWarteschlangen für Ihr Konto aufzulisten, rufen Sie die -SqsClient’slistQueuesMethode mit einem -ListQueuesRequestObjekt auf.

Wenn Sie das Format der listQueues Methode verwenden, die keine Parameter verwendet, gibt der Service alle Warteschlangen zurück – bis zu 1 000 Warteschlangen.

Sie können dem ListQueuesRequest Objekt ein Präfix für den Warteschlangennamen bereitstellen, um die Ergebnisse auf Warteschlangen zu beschränken, die diesem Präfix entsprechen, wie im folgenden Code gezeigt.

Importe

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.*;
import java.util.List;

Code

        String prefix = "que";

        try {
            ListQueuesRequest listQueuesRequest = ListQueuesRequest.builder().queueNamePrefix(prefix).build();
            ListQueuesResponse listQueuesResponse = sqsClient.listQueues(listQueuesRequest);

            for (String url : listQueuesResponse.queueUrls()) {
                System.out.println(url);
            }

        } catch (SqsException e) {
            System.err.println(e.awsErrorDetails().errorMessage());
            System.exit(1);
        }

Sehen Sie sich das vollständige Beispiel auf an GitHub.

Abrufen der URL für eine Warteschlange

Der folgende Code zeigt, wie Sie die URL für eine Warteschlange abrufen, indem Sie die -SqsClient’sgetQueueUrlMethode mit einem -GetQueueUrlRequestObjekt aufrufen.

Importe

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.*;
import java.util.List;

Code

            GetQueueUrlResponse getQueueUrlResponse =
                sqsClient.getQueueUrl(GetQueueUrlRequest.builder().queueName(queueName).build());
            String queueUrl = getQueueUrlResponse.queueUrl();
            return queueUrl;

Sehen Sie sich das vollständige Beispiel auf an GitHub.

Löschen einer Warteschlange

Geben Sie die URL der Warteschlange für das DeleteQueueRequest Objekt an. Rufen Sie dann die -SqsClient’sdeleteQueueMethode auf, um eine Warteschlange zu löschen, wie im folgenden Code gezeigt.

Importe

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.*;
import java.util.List;

Code

    public static void deleteSQSQueue(SqsClient sqsClient, String queueName) {

        try {

            GetQueueUrlRequest getQueueRequest = GetQueueUrlRequest.builder()
                    .queueName(queueName)
                    .build();

            String queueUrl = sqsClient.getQueueUrl(getQueueRequest).queueUrl();

            DeleteQueueRequest deleteQueueRequest = DeleteQueueRequest.builder()
                    .queueUrl(queueUrl)
                    .build();

            sqsClient.deleteQueue(deleteQueueRequest);

        } catch (SqsException e) {
            System.err.println(e.awsErrorDetails().errorMessage());
            System.exit(1);
        }
    }

Sehen Sie sich das vollständige Beispiel auf an GitHub.

Weitere Informationen