Habilitando o buffer do lado do cliente e o agrupamento de solicitações com o Amazon SQS

O AWS SDK for Java inclui o AmazonSQSBufferedAsyncClient, que acessa o Amazon SQS. Esse cliente permite o envio simples de solicitações em lotes usando armazenamento em buffer no lado do cliente. As chamadas feitas pelo cliente são primeiro armazenadas em buffer e, em seguida, enviadas como uma solicitação em lote para o Amazon SQS.

O armazenamento em buffer no lado do cliente permite que até 10 solicitações sejam armazenadas em buffer e enviadas como uma solicitação em lote, diminuindo o custo de uso do Amazon SQS e reduzindo o número de solicitações enviadas. O AmazonSQSBufferedAsyncClient armazena tanto as chamadas síncronas quanto as assíncronas em buffer. Solicitações em lote e suporte para sondagem longa também podem ajudar a aumentar a taxa de transferência. Para ter mais informações, consulte Aumento da produtividade usando escalabilidade horizontal e lotes de ações com o Amazon SQS.

como o AmazonSQSBufferedAsyncClient implementa a mesma interface que o AmazonSQSAsyncClient, migrar de AmazonSQSAsyncClient para AmazonSQSBufferedAsyncClient normalmente requer apenas pequenas mudanças no seu código existente.

Usando o Amazon SQS BufferedAsyncClient

Antes de começar, conclua as etapas em Configurando a Amazon SQS.

Você pode criar um novo AmazonSQSBufferedAsyncClient com base em AmazonSQSAsyncClient, por exemplo:

// Create the basic Amazon SQS async client
final AmazonSQSAsync sqsAsync = new AmazonSQSAsyncClient();
 
// Create the buffered client
final AmazonSQSAsync bufferedSqs = new AmazonSQSBufferedAsyncClient(sqsAsync);

Depois de criar o novo AmazonSQSBufferedAsyncClient, você pode usá-lo para enviar várias solicitações ao Amazon SQS (da mesma forma que faria com o AmazonSQSAsyncClient), por exemplo:

final CreateQueueRequest createRequest = new CreateQueueRequest().withQueueName("MyQueue");
 
final CreateQueueResult res = bufferedSqs.createQueue(createRequest);
 
final SendMessageRequest request = new SendMessageRequest();
final String body = "Your message text" + System.currentTimeMillis();
request.setMessageBody( body );
request.setQueueUrl(res.getQueueUrl());
 
final Future<SendMessageResult> sendResult = bufferedSqs.sendMessageAsync(request);
 
final ReceiveMessageRequest receiveRq = new ReceiveMessageRequest()
    .withMaxNumberOfMessages(1)
    .withQueueUrl(queueUrl);
final ReceiveMessageResult rx = bufferedSqs.receiveMessage(receiveRq);

Configurando o Amazon SQS BufferedAsyncClient

O AmazonSQSBufferedAsyncClient é pré-configurado com configurações que funcionarão para a maioria dos casos de uso. Você pode configurar ainda mais o AmazonSQSBufferedAsyncClient, por exemplo:

// Create the basic Amazon SQS async client
final AmazonSQSAsync sqsAsync = new AmazonSQSAsyncClient();
 
final QueueBufferConfig config = new QueueBufferConfig()
    .withMaxInflightReceiveBatches(5)
    .withMaxDoneReceiveBatches(15);
 
// Create the buffered client
final AmazonSQSAsync bufferedSqs = new AmazonSQSBufferedAsyncClient(sqsAsync, config);