Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Lavora con Amazon Simple Queue Service code di messaggi

Una coda di messaggi è il contenitore logico utilizzato per inviare messaggi in modo affidabile. Amazon Simple Queue Service Sono disponibili due tipi di code: standard e first-in, first-out (FIFO). Per saperne di più sulle code e sulle differenze tra questi tipi, consulta la Guida per gli sviluppatori. Amazon Simple Queue Service

Questo argomento descrive come creare, elencare, eliminare e ottenere l'URL di una Amazon Simple Queue Service coda utilizzando il. AWS SDK per Java

La sqsClient variabile utilizzata nei seguenti esempi può essere creata dal seguente frammento.

SqsClient sqsClient = SqsClient.create();

Quando si crea un SqsClient utilizzando il create() metodo statico, l'SDK configura la regione utilizzando la catena di provider della regione predefinita e le credenziali utilizzando la catena di provider di credenziali predefinita. Catena di fornitori di credenziali predefinita in AWS SDK for Java 2.x

Crea una coda

Utilizzate il SqsClient’s createQueue metodo e fornite un CreateQueueRequest oggetto che descriva i parametri della coda come mostrato nel seguente frammento di codice.

Importazioni

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

Codice

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

            sqsClient.createQueue(createQueueRequest);

Guarda l'esempio completo su. https://github.com/awsdocs/aws-doc-sdk-examples/blob/cf25559da654a7b74bec039c0ab9397dc5951dd4/javav2/example_code/sqs/src/main/java/com/example/sqs/SQSExample.java#L52 GitHub

Elencare code

Per elencare le Amazon Simple Queue Service code relative al tuo account, chiama il SqsClient’s listQueues metodo con un ListQueuesRequest oggetto.

Quando utilizzate il modulo del listQueues metodo che non accetta parametri, il servizio restituisce tutte le code, fino a 1.000 code.

È possibile fornire un prefisso per il nome della coda all'ListQueuesRequestoggetto per limitare i risultati alle code che corrispondono a tale prefisso, come mostrato nel codice seguente.

Importazioni

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

Codice

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

Guarda l'esempio completo su. https://github.com/awsdocs/aws-doc-sdk-examples/blob/cf25559da654a7b74bec039c0ab9397dc5951dd4/javav2/example_code/sqs/src/main/java/com/example/sqs/SQSExample.java#L79 GitHub

Ottenere l'URL di una coda

Il codice seguente mostra come ottenere l'URL di una coda chiamando il SqsClient’s getQueueUrl metodo con un GetQueueUrlRequest oggetto.

Importazioni

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

Codice

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

Guarda l'esempio https://github.com/awsdocs/aws-doc-sdk-examples/blob/7486a1a092aa8e16a21698ef26f9d524fef62e55/javav2/example_code/sqs/src/main/java/com/example/sqs/SQSExample.java#L70 completo su. GitHub

Elimina una coda

Fornisci l'URL della coda all'DeleteQueueRequestoggetto. Quindi chiamate il SqsClient’s deleteQueue metodo per eliminare una coda come mostrato nel codice seguente.

Importazioni

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

Codice

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

Guarda l'esempio https://github.com/awsdocs/aws-doc-sdk-examples/blob/6240df86c5f17eae1e23d1139d1435c7dc4b2a11/javav2/example_code/sqs/src/main/java/com/example/sqs/DeleteQueue.java#L48 completo su. GitHub

Ulteriori informazioni