Activation de la mise en mémoire tampon côté client et du traitement par lots des demandes avec Amazon SQS

Le kit AWS SDK for Java inclut AmazonSQSBufferedAsyncClient qui accède à Amazon SQS. Ce client facilite le traitement par lots des demandes à l'aide d'une mise en tampon côté client : les appels du client sont d'abord mis en tampon, puis transmis comme demande par lots à Amazon SQS.

La mise en tampon côté client autorise la mise en tampon et l'envoi en tant que demande par lots de 10 requêtes au maximum, ce qui réduit les coûts d'utilisation d'Amazon SQS et le nombre de requêtes envoyées. AmazonSQSBufferedAsyncClient met en tampon les appels synchrones et asynchrones. Les demandes par lots et la prise en charge de l'attente active de longue durée peuvent également permettre d'augmenter le débit. Pour plus d’informations, consultez Augmenter le débit grâce à la mise à l'échelle horizontale et au traitement par lots d'actions avec Amazon SQS.

Dans la mesure où AmazonSQSBufferedAsyncClient implémente la même interface qu'AmazonSQSAsyncClient, la migration d'AmazonSQSAsyncClient vers AmazonSQSBufferedAsyncClient requiert généralement très peu de changements du code existant.

Utilisation d'Amazon SQS BufferedAsyncClient

Avant de commencer, complétez les étapes détaillées dans Configuration d'Amazon SQS.

Vous pouvez créer un nouveau AmazonSQSBufferedAsyncClient basé sur AmazonSQSAsyncClient, par exemple :

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

Après avoir créé le nouveau AmazonSQSBufferedAsyncClient, utilisez-le pour envoyer plusieurs demandes à Amazon SQS (comme avec AmazonSQSAsyncClient), par exemple :

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

Configuration d'Amazon SQS BufferedAsyncClient

AmazonSQSBufferedAsyncClient est préconfiguré avec des paramètres qui fonctionnent dans la plupart des cas d'utilisation. Vous pouvez configurer davantage AmazonSQSBufferedAsyncClient, par exemple :

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