Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
# Verwenden Sie die automatische Batchverarbeitung von Anfragen für Amazon SQS mit dem AWS SDK for Java 2.x
Die Automatic Request Batching API für Amazon SQS ist eine Bibliothek auf hoher Ebene, die eine effiziente Möglichkeit bietet, Anfragen für SQS-Operationen zu stapeln und zu puffern. Durch die Verwendung der Batching-API reduzieren Sie die Anzahl der Anfragen an SQS, was den Durchsatz verbessert und die Kosten minimiert.
Da die Batch-API-Methoden mit den `[SqsAsyncClient](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/SqsAsyncClient.html)` Methoden—`sendMessage`,,`changeMessageVisibility`, `receiveMessage` —übereinstimmen`deleteMessage`, können Sie die Batch-API als direkten Ersatz mit minimalen Änderungen verwenden.
Dieses Thema gibt Ihnen einen Überblick über die Konfiguration und die Arbeit mit der Automatic Request Batching API für Amazon SQS.
## Überprüfen Sie die Voraussetzungen
Sie müssen Version *2.28.0* oder höher des SDK for Java 2.x verwenden, um auf die Batching-API zugreifen zu können. Ihr Maven `pom.xml` sollte mindestens die folgenden Elemente enthalten.
```
software.amazon.awssdk
bom
2.28.231
pom
import
software.amazon.awssdk
sqs
```
1 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom)
## Erstellen Sie einen Batch-Manager
Die automatische Batching-API für Anfragen wird von der [SqsAsyncBatchManager](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html)Schnittstelle implementiert. Sie können eine Instanz des Managers auf verschiedene Arten erstellen.
### Standardkonfiguration mithilfe von `SqsAsyncClient`
Die einfachste Methode zum Erstellen eines Batch-Managers besteht darin, die `batchManager` Factory-Methode für eine vorhandene [SqsAsyncClient](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/SqsAsyncClient.html)Instanz aufzurufen. Der einfache Ansatz wird im folgenden Snippet gezeigt.
```
SqsAsyncClient asyncClient = SqsAsyncClient.create();
SqsAsyncBatchManager sqsAsyncBatchManager = asyncClient.batchManager();
```
Wenn Sie diesen Ansatz verwenden, verwendet die `SqsAsyncBatchManager` Instanz die Standardwerte, die in der Tabelle im [Überschreiben Sie die Konfigurationseinstellungen für `SqsAsyncBatchManager`](#sqs-auto-batch-config-settings) Abschnitt aufgeführt sind. Darüber hinaus verwendet die `SqsAsyncBatchManager` Instanz die `ExecutorService` der `SqsAsyncClient` Instanz, aus der sie erstellt wurde.
### Benutzerdefinierte Konfiguration mithilfe von `SqsAsyncBatchManager.Builder`
Für fortgeschrittenere Anwendungsfälle können Sie den Batch-Manager mithilfe von anpassen [https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.Builder.html](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.Builder.html). Wenn Sie diesen Ansatz verwenden, um eine `SqsAsyncBatchManager` Instanz zu erstellen, können Sie das Batching-Verhalten fein abstimmen. Der folgende Ausschnitt zeigt ein Beispiel dafür, wie Sie den Builder verwenden können, um das Batching-Verhalten anzupassen.
```
SqsAsyncBatchManager batchManager = SqsAsyncBatchManager.builder()
.client(SqsAsyncClient.create())
.scheduledExecutor(Executors.newScheduledThreadPool(5))
.overrideConfiguration(b -> b
.receiveMessageMinWaitDuration(Duration.ofSeconds(10))
.receiveMessageVisibilityTimeout(Duration.ofSeconds(1))
.receiveMessageAttributeNames(Collections.singletonList("*"))
.receiveMessageSystemAttributeNames(Collections.singletonList(MessageSystemAttributeName.ALL)))
.build();
```
Wenn Sie diesen Ansatz verwenden, können Sie die Einstellungen für das `BatchOverrideConfiguration` Objekt anpassen, die in der Tabelle im Abschnitt aufgeführt sind. [Überschreiben Sie die Konfigurationseinstellungen für `SqsAsyncBatchManager`](#sqs-auto-batch-config-settings) Mit diesem Ansatz können Sie auch einen benutzerdefinierten Wert [https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/ScheduledExecutorService.html](https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/ScheduledExecutorService.html)für den Batch-Manager angeben.
## Senden Sie Nachrichten
Verwenden Sie die `[SqsAsyncBatchManager\$1sendMessage](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html#sendMessage(software.amazon.awssdk.services.sqs.model.SendMessageRequest))` Methode, um Nachrichten mit dem Batch-Manager zu senden. Das SDK puffert Anfragen und sendet sie als Batch, wenn die `sendRequestFrequency` Werte `maxBatchSize` oder erreicht sind.
Das folgende Beispiel zeigt eine `sendMessage` Anfrage, auf die unmittelbar eine weitere Anfrage folgt. In diesem Fall sendet das SDK beide Nachrichten in einem einzigen Batch.
```
// Sending the first message
CompletableFuture futureOne =
sqsAsyncBatchManager.sendMessage(r -> r.messageBody("One").queueUrl("queue"));
// Sending the second message
CompletableFuture futureTwo =
sqsAsyncBatchManager.sendMessage(r -> r.messageBody("Two").queueUrl("queue"));
// Waiting for both futures to complete and retrieving the responses
SendMessageResponse messageOne = futureOne.join();
SendMessageResponse messageTwo = futureTwo.join();
```
## Ändern Sie das Timeout für die Sichtbarkeit von Nachrichten
Sie können das Sichtbarkeits-Timeout von Nachrichten in einem Batch mithilfe der [https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html#changeMessageVisibility(java.util.function.Consumer)](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html#changeMessageVisibility(java.util.function.Consumer))Methode ändern. Das SDK puffert Anfragen und sendet sie als Batch, wenn die `sendRequestFrequency` Werte `maxBatchSize` oder erreicht sind.
Das folgende Beispiel zeigt, wie die `changeMessageVisibility` Methode aufgerufen wird.
```
CompletableFuture futureOne =
sqsAsyncBatchManager.changeMessageVisibility(r ->
r.receiptHandle("receiptHandle")
.queueUrl("queue"));
ChangeMessageVisibilityResponse response = futureOne.join();
```
## Nachrichten löschen
Mit [https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html#deleteMessage(java.util.function.Consumer)](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html#deleteMessage(java.util.function.Consumer))dieser Methode können Sie Nachrichten stapelweise löschen. Das SDK puffert Anfragen und sendet sie als Batch, wenn die `sendRequestFrequency` Werte `maxBatchSize` oder erreicht sind.
Das folgende Beispiel zeigt, wie Sie die `deleteMessage` Methode aufrufen können.
```
CompletableFuture futureOne =
sqsAsyncBatchManager.deleteMessage(r ->
r.receiptHandle("receiptHandle")
.queueUrl("queue"));
DeleteMessageResponse response = futureOne.join();
```
## Empfangen Sie Nachrichten
### Verwenden Sie die Standardeinstellungen
Wenn Sie die `[SqsAsyncBatchManager\$1receiveMessage](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html#receiveMessage(java.util.function.Consumer))` Methode in Ihrer Anwendung abfragen, ruft der Batch-Manager Nachrichten aus seinem internen Puffer ab, den das SDK automatisch im Hintergrund aktualisiert.
Das folgende Beispiel zeigt, wie die `receiveMessage` Methode aufgerufen wird.
```
CompletableFuture responseFuture =
sqsAsyncBatchManager.receiveMessage(r -> r.queueUrl("queueUrl"));
```
### Verwenden Sie benutzerdefinierte Einstellungen
Wenn Sie die Anfrage weiter anpassen möchten, indem Sie beispielsweise benutzerdefinierte Wartezeiten festlegen und die Anzahl der abzurufenden Nachrichten angeben, können Sie die Anforderung wie im folgenden Beispiel dargestellt anpassen.
```
CompletableFuture response =
sqsAsyncBatchManager.receiveMessage(r ->
r.queueUrl("queueUrl")
.waitTimeSeconds(5)
.visibilityTimeout(20));
```
**Anmerkung**
Wenn Sie `receiveMessage` mit einer aufrufen`[ReceiveMessageRequest](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/model/ReceiveMessageRequest.html)`, die einen der folgenden Parameter enthält, umgeht das SDK den Batch-Manager und sendet eine reguläre asynchrone Anfrage`receiveMessage`:
`messageAttributeNames`
`messageSystemAttributeNames`
`messageSystemAttributeNamesWithStrings`
`overrideConfiguration`
## Überschreiben Sie die Konfigurationseinstellungen für `SqsAsyncBatchManager`
Sie können die folgenden Einstellungen anpassen, wenn Sie eine `SqsAsyncBatchManager` Instanz erstellen. Die folgende Liste von Einstellungen ist auf der verfügbar [https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/BatchOverrideConfiguration.Builder.html](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/BatchOverrideConfiguration.Builder.html).
| Einstellung | Description | Standardwert |
| --- | --- | --- |
| maxBatchSize | Maximale Anzahl von Anfragen pro Stapel für jedesSendMessageBatchRequest,ChangeMessageVisibilityBatchRequest, oderDeleteMessageBatchRequest. Der Höchstwert ist 10. | 10 |
| sendRequestFrequency | Zeit bis zum Senden eines Batches, sofern sie nicht `maxBatchSize` früher erreicht wurde. Höhere Werte können die Anzahl der Anfragen reduzieren, aber die Latenz erhöhen. | 200 ms |
| receiveMessageVisibilityTimeout | Timeout für die Sichtbarkeit von Nachrichten. Wenn diese Option nicht gesetzt ist, wird die Standardeinstellung der Warteschlange verwendet. | Die Standardeinstellung der Warteschlange |
| receiveMessageMinWaitDuration | Minimale Wartezeit für receiveMessage Anfragen. Vermeiden Sie es, auf 0 zu setzen, um CPU-Verschwendung zu vermeiden. | 50 ms |
| receiveMessageSystemAttributeNames | Liste der [Systemattributnamen](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/model/MessageSystemAttributeName.html), die für receiveMessage Anrufe angefordert werden sollen. | Keine |
| receiveMessageAttributeNames | Liste der [Attributnamen](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes), die für receiveMessage Anrufe angefordert werden sollen. | Keine |