Abilitazione del buffering lato client e del batching delle richieste con Amazon SQS

AWS SDK for Java include AmazonSQSBufferedAsyncClient che accede ad Amazon SQS. Questo client facilita il batching semplice delle richieste abilitando il buffering lato client, dove le chiamate effettuate dal client vengono prima memorizzate, quindi inviate come una richiesta di batch ad Amazon SQS.

Il buffering lato client consente di memorizzare e inviare fino a 10 richieste in batch, riducendo il costo di utilizzo di Amazon SQS e il numero di richieste inviate. AmazonSQSBufferedAsyncClient effettua il buffering delle chiamate sincrone e asincrone. Le richieste in batch e il supporto per il polling lungo possono inoltre contribuire ad aumentare il throughput. Per ulteriori informazioni, consulta Aumento del throughput utilizzando la scalabilità orizzontale e l'action batching con Amazon SQS.

Poiché AmazonSQSBufferedAsyncClient implementa la stessa interfaccia di AmazonSQSAsyncClient, la migrazione da AmazonSQSAsyncClient a AmazonSQSBufferedAsyncClient di solito richiede solo modifiche minime al codice esistente.

Usare AmazonSQS BufferedAsyncClient

Prima di iniziare, completa i passaggi descritti in Configurazione di Amazon SQS.

Puoi creare un nuovo AmazonSQSBufferedAsyncClient basato su AmazonSQSAsyncClient, ad esempio:

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

Una volta creato il nuovo AmazonSQSBufferedAsyncClient, è possibile utilizzarlo per l'invio di più richieste ad Amazon SQS; (proprio come con AmazonSQSAsyncClient), ad esempio:

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

Configurazione di AmazonSQS BufferedAsyncClient

AmazonSQSBufferedAsyncClient è preconfigurato con impostazioni che funzionano per la maggior parte dei casi d'uso. È possibile configurare ulteriormente AmazonSQSBufferedAsyncClient, ad esempio:

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