La AWS SDK para Java versión 1.x entró en modo de mantenimiento el 31 de julio de 2024 y estará disponible el 31 de end-of-supportdiciembre de 2025. Le recomendamos que migre al para AWS SDK for Java 2.xseguir recibiendo nuevas funciones, mejoras de disponibilidad y actualizaciones de seguridad.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Habilitación de sondeos prolongados para colas de Amazon SQS mensajes

Amazon SQS utiliza un sondeo breve de forma predeterminada y consulta solo un subconjunto de los servidores (según una distribución aleatoria ponderada) para determinar si hay algún mensaje disponible para su inclusión en la respuesta.

Los sondeos Amazon SQS prolongados ayudan a reducir el coste de uso, ya que reducen el número de respuestas vacías cuando no hay mensajes disponibles para responder a una ReceiveMessage solicitud enviada a una cola y eliminan las respuestas falsas y vacías. Amazon SQS

Habilitar el sondeo largo al crear una cola

Para habilitar un sondeo prolongado al crear una Amazon SQS cola, defina el ReceiveMessageWaitTimeSeconds atributo en el CreateQueueRequestobjeto antes de llamar al método de la clase AmazonSQS. createQueue

Importaciones

import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
import com.amazonaws.services.sqs.model.AmazonSQSException;
import com.amazonaws.services.sqs.model.CreateQueueRequest;

Código

final AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();

// Enable long polling when creating a queue
CreateQueueRequest create_request = new CreateQueueRequest()
        .withQueueName(queue_name)
        .addAttributesEntry("ReceiveMessageWaitTimeSeconds", "20");

try {
    sqs.createQueue(create_request);
} catch (AmazonSQSException e) {
    if (!e.getErrorCode().equals("QueueAlreadyExists")) {
        throw e;
    }
}

Consulte el ejemplo completo en. GitHub

Habilitar el sondeo largo en una cola existente

Además de habilitar el sondeo prolongado al crear una cola, también puede habilitarlo en una cola existente configurando el método «SetQueueAttributesRequestantes de llamar a ReceiveMessageWaitTimeSeconds la clase AmazonSQS». setQueueAttributes

Importaciones

import com.amazonaws.services.sqs.model.SetQueueAttributesRequest;

Código

SetQueueAttributesRequest set_attrs_request = new SetQueueAttributesRequest()
        .withQueueUrl(queue_url)
        .addAttributesEntry("ReceiveMessageWaitTimeSeconds", "20");
sqs.setQueueAttributes(set_attrs_request);

Consulte el ejemplo completo en. GitHub

Habilitar el sondeo largo al recibir un mensaje

Puede habilitar un sondeo prolongado al recibir un mensaje configurando el tiempo de espera en segundos según el ReceiveMessageRequestmétodo de la clase receiveMessage AmazonSQS.

Importaciones

import com.amazonaws.services.sqs.model.ReceiveMessageRequest;

Código

ReceiveMessageRequest receive_request = new ReceiveMessageRequest()
        .withQueueUrl(queue_url)
        .withWaitTimeSeconds(20);
sqs.receiveMessage(receive_request);

Consulta el ejemplo completo en. GitHub

Más información