本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
# 将 Amazon SQS 的自动请求批处理与 AWS SDK for Java 2.x
Amazon SQS 的自动请求批处理 API 是一个高级库，提供了一种高效的方法来批处理和缓冲 SQS 操作的请求。通过使用批处理 API，您可以减少 SQS 的请求数量，从而提高吞吐量并更大限度地降低成本。
由于批处理 API 方法与 `[SqsAsyncClient](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/SqsAsyncClient.html)` 方法（`sendMessage`、`changeMessageVisibility`、`deleteMessage`、`receiveMessage`）相匹配，因此您可以将批处理 API 作为直接替代方案使用，只需做极少的代码修改。
本主题概述了如何配置和使用 Amazon SQS 的自动请求批处理 API。
## 检查先决条件
您需要使用适用于 Java 的 SDK 2.x 的版本 *2.28.0* 或更高版本才能访问批处理 API。您的 Maven `pom.xml` 应至少包含以下元素。
```
software.amazon.awssdk
bom
2.28.231
pom
import
software.amazon.awssdk
sqs
```
1 [最新版本](https://central.sonatype.com/artifact/software.amazon.awssdk/bom)
## 创建批量管理器
自动请求批处理 API 由[SqsAsyncBatchManager](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html)接口实现。您可以通过几种方式创建管理器的实例。
### 使用 `SqsAsyncClient` 的默认配置
创建批处理管理器的最简单方法是在现有[SqsAsyncClient](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/SqsAsyncClient.html)实例上调用`batchManager`工厂方法。以下代码段演示了这种简单方法。
```
SqsAsyncClient asyncClient = SqsAsyncClient.create();
SqsAsyncBatchManager sqsAsyncBatchManager = asyncClient.batchManager();
```
当您使用这种方法时，`SqsAsyncBatchManager` 实例会使用 [覆盖 `SqsAsyncBatchManager` 的配置设置](#sqs-auto-batch-config-settings) 部分表格中显示的默认值。此外，`SqsAsyncBatchManager` 实例会使用其创建来源的 `SqsAsyncClient` 实例的 `ExecutorService`。
### 使用 `SqsAsyncBatchManager.Builder` 的自定义配置
对于更高级的使用案例，您可以使用 [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) 自定义批处理管理器。通过使用这种方法来创建 `SqsAsyncBatchManager` 实例，您可以微调批处理行为。以下代码段举例说明了如何使用生成器来自定义批处理行为。
```
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();
```
使用这种方法时，您可以调整 [覆盖 `SqsAsyncBatchManager` 的配置设置](#sqs-auto-batch-config-settings) 部分表格中显示的 `BatchOverrideConfiguration` 对象的设置。您也可以使用这种方法为批处理管理器提供自定义 [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)。
## 发送消息
要使用批处理管理器发送消息，请使用 `[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))` 方法。SDK 会缓冲请求，并在达到 `maxBatchSize` 或 `sendRequestFrequency` 值时批量发送请求。
以下示例展示了一个 `sendMessage` 请求后立即紧跟着另一个请求。在这种情况下，SDK 在单个批次中发送这两条消息。
```
// 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();
```
## 更改消息的可见性超时
您可以使用 [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)) 方法批量更改消息的可见性超时。SDK 会缓冲请求，并在达到 `maxBatchSize` 或 `sendRequestFrequency` 值时批量发送请求。
以下示例显示了如何调用 `changeMessageVisibility` 方法。
```
CompletableFuture futureOne =
sqsAsyncBatchManager.changeMessageVisibility(r ->
r.receiptHandle("receiptHandle")
.queueUrl("queue"));
ChangeMessageVisibilityResponse response = futureOne.join();
```
## 删除消息
您可以使用 [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)) 方法批量删除消息。SDK 会缓冲请求，并在达到 `maxBatchSize` 或 `sendRequestFrequency` 值时批量发送请求。
以下示例说明了如何调用 `deleteMessage` 方法。
```
CompletableFuture futureOne =
sqsAsyncBatchManager.deleteMessage(r ->
r.receiptHandle("receiptHandle")
.queueUrl("queue"));
DeleteMessageResponse response = futureOne.join();
```
## 接收消息
### 使用默认设置
当您在应用程序中轮询 `[SqsAsyncBatchManager\$1receiveMessage](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html#receiveMessage(java.util.function.Consumer))` 方法时，批处理管理器会从其内部缓冲区获取消息，SDK 会在后台自动更新缓冲区。
以下示例显示了如何调用 `receiveMessage` 方法。
```
CompletableFuture responseFuture =
sqsAsyncBatchManager.receiveMessage(r -> r.queueUrl("queueUrl"));
```
### 使用自定义设置
如果您想进一步自定义请求（例如设置自定义等待时间和指定要检索的消息数量），则可以按以下示例所示自定义请求。
```
CompletableFuture response =
sqsAsyncBatchManager.receiveMessage(r ->
r.queueUrl("queueUrl")
.waitTimeSeconds(5)
.visibilityTimeout(20));
```
**注意**
如果您使用包括以下任何参数的 `[ReceiveMessageRequest](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/model/ReceiveMessageRequest.html)` 来调用 `receiveMessage`，则 SDK 会绕过批处理管理器并发送常规异步 `receiveMessage` 请求：
`messageAttributeNames`
`messageSystemAttributeNames`
`messageSystemAttributeNamesWithStrings`
`overrideConfiguration`
## 覆盖 `SqsAsyncBatchManager` 的配置设置
创建 `SqsAsyncBatchManager` 实例时，可以调整以下设置。[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) 提供了以下设置列表。
| 设置 | 说明 | 默认 值 |
| --- | --- | --- |
| maxBatchSize | 每个 SendMessageBatchRequest、ChangeMessageVisibilityBatchRequest 或 DeleteMessageBatchRequest 每批次的最大请求数。最大值为 10。 | 10 |
| sendRequestFrequency | 发送批次之前的时间，除非提前达到 `maxBatchSize`。较高的值可能会减少请求，但会增加延迟。 | 200 毫秒 |
| receiveMessageVisibilityTimeout | 消息的可见性超时。如果未设置，则使用队列的默认值。 | 队列的默认值 |
| receiveMessageMinWaitDuration | receiveMessage 请求的最短等待时间。避免设置为 0，以防浪费 CPU。 | 50 毫秒 |
| receiveMessageSystemAttributeNames | receiveMessage 调用请求的[系统属性名称](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/model/MessageSystemAttributeName.html)列表。 | 无 |
| receiveMessageAttributeNames | receiveMessage 调用请求的[属性名称](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-metadata.html#sqs-message-attributes)列表。 | 无 |