Habilitación del almacenamiento en búfer del lado del cliente y del agrupamiento en lotes de solicitudes - Amazon Simple Queue Service

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 del almacenamiento en búfer del lado del cliente y del agrupamiento en lotes de solicitudes

LaAWS SDK for JavaincludesAmazonSQSBufferedAsyncClientque accede a Amazon SQS. Este cliente permite agrupar fácilmente en lotes las solicitudes mediante el almacenamiento en búfer del lado del cliente; las llamadas realizadas desde el cliente primero se almacenan en búfer y después se envían como una solicitud por lotes a Amazon SQS.

El almacenamiento en búfer del lado del cliente permite almacenar en búfer hasta 10 solicitudes y enviarlas como una solicitud por lotes, lo que disminuye el costo de uso de Amazon SQS y el número de solicitudes enviadas.AmazonSQSBufferedAsyncClientalmacena en búfer tanto las llamadas síncronas como las asíncronas. Las solicitudes por lotes y la compatibilidad con los sondeos largos también pueden contribuir a mejorar el rendimiento. Para obtener más información, consulte Aumento del rendimiento mediante el escalado horizontal y agrupación en lotes de acciones de la.

Dado que AmazonSQSBufferedAsyncClient implementa la misma interfaz que AmazonSQSAsyncClient, la migración de AmazonSQSAsyncClient a AmazonSQSBufferedAsyncClient solo suele requerir cambios mínimos en el código.

nota

El cliente asíncrono en búfer de Amazon SQS no admite actualmente colas FIFO.

Uso de AmazonSQSBufferedAsyncClient

Antes de comenzar, complete los pasos de Configuración de Amazon SQS.

importante

AWS SDK for Java 2.x no es compatible actualmente con AmazonSQSBufferedAsyncClient.

Puede crear un nuevo cliente AmazonSQSBufferedAsyncClient basado en AmazonSQSAsyncClient; por ejemplo:

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

Después de crear el nuevoAmazonSQSBufferedAsyncClient, puede utilizarlo para enviar varias solicitudes a Amazon SQS (del mismo modo que conAmazonSQSAsyncClient), por ejemplo:

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 SendMessageResult sendResult = bufferedSqs.sendMessageAsync(request); final ReceiveMessageRequest receiveRq = new ReceiveMessageRequest() .withMaxNumberOfMessages(1) .withQueueUrl(queueUrl); final ReceiveMessageResult rx = bufferedSqs.receiveMessage(receiveRq);

Configuración de AmazonSQSBufferedAsyncClient

AmazonSQSBufferedAsyncClient está preconfigurado con ajustes válidos para la mayoría de los casos de uso. Se pueden configurar ajustes adicionales de AmazonSQSBufferedAsyncClient; por ejemplo:

  1. Crear una instancia de la clase QueueBufferConfig con los parámetros de configuración necesarios.

  2. Proporcionar la instancia al constructor AmazonSQSBufferedAsyncClient.

// 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);
Parámetros de configuración de QueueBufferConfig
Parámetro Valor predeterminado Descripción
longPoll true

Cuando longPoll se establece en true, AmazonSQSBufferedAsyncClient intenta utilizar el sondeo largo a la hora de consumir mensajes.

longPollWaitTimeoutSeconds 20 s

El tiempo máximo, en segundos, que una llamada a ReceiveMessage se bloquea en el servidor a la espera de que aparezcan mensajes en la cola antes de devolver un resultado de recepción vacío.

nota

Este parámetro no tiene ningún efecto cuando el sondeo largo está deshabilitado.

maxBatchOpenMs 200ms

El tiempo máximo, en milisegundos, que una llamada saliente espera otras llamadas para procesar por lotes mensajes del mismo tipo.

Cuanto mayor sea el valor, menos lotes son necesarios para realizar la misma cantidad de trabajo (no obstante, la primera llamada de un lote tiene que esperar más tiempo).

Cuando se establece este parámetro en 0, las solicitudes enviadas no esperan a otras solicitudes, lo que en la práctica deshabilita el procesamiento por lotes.

maxBatchSize 10 solicitudes por lote

El número máximo de mensajes que se procesan juntos por lotes en una sola solicitud. Cuanto mayor sea la configuración, menos lotes serán necesarios para llevar a cabo el mismo número de solicitudes.

nota

El valor máximo permitido para Amazon SQS es de 10 solicitudes por lote.

maxBatchSizeBytes 256 KB

El tamaño máximo de un lote de mensajes, en bytes, que el cliente intenta enviar a Amazon SQS.

nota

El valor máximo permitido para Amazon SQS es de 256 KB.

maxDoneReceiveBatches 10 lotes

El número máximo de lotes de recepción que AmazonSQSBufferedAsyncClient captura previamente y almacena en el lado del cliente.

Cuanto mayor sea el valor, más solicitudes de recepción podrán satisfacerse sin tener que realizar una llamada a Amazon SQS (sin embargo, cuantos más mensajes se capturen previamente, más tiempo permanecerán en el búfer, lo que hará que caduque su propio tiempo de espera de visibilidad).

nota

0 indica que se ha deshabilitado la captura previa de mensajes y que estos solo se consumen bajo demanda.

maxInflightOutboundBatches 5 lotes

El número máximo de lotes salientes activos que se pueden procesar al mismo tiempo.

Cuanto mayor sea el valor, más rápido se podrán enviar los lotes salientes (sujeto a cuotas como la CPU o el ancho de banda) y más subprocesos podrá consumir AmazonSQSBufferedAsyncClient.

maxInflightReceiveBatches 10 lotes

El número máximo de lotes de recepción activos que se pueden procesar al mismo tiempo.

Cuanto mayor sea el valor, más mensajes de podrán recibir (sujeto a cuotas como la CPU o el ancho de banda) y más subprocesos podrá consumir AmazonSQSBufferedAsyncClient.

nota

0 indica que se ha deshabilitado la captura previa de mensajes y que estos solo se consumen bajo demanda.

visibilityTimeoutSeconds -1

Cuando este parámetro se establece en un valor positivo distinto de cero, el tiempo de espera de visibilidad que se establece aquí anula el tiempo de espera de visibilidad definido en la cola desde la que se consumen los mensajes.

nota

-1 indica que está seleccionada la configuración predeterminada de la cola.

No se puede establecer el tiempo de espera de visibilidad en 0.