访问 NettyNioAsyncHttpClient 使用和配置 NettyNioAsyncHttpClient 代理配置示例

配置基于 Netty 的客户端 HTTP

中异步操作的默认HTTP客户端 Amazon SDK for Java 2.x 是基于 Netty 的客户端。NettyNioAsyncHttpClient基于 Netty 的客户端以 Netty 项目的异步事件驱动网络框架为基础。

作为备用HTTP客户端，您可以使用Amazon CRT基于新的HTTP客户端。本主题演示如何配置 NettyNioAsyncHttpClient。

访问 `NettyNioAsyncHttpClient`

在大多数情况下，您无需在异步程序中进行任何显式配置即可使用 NettyNioAsyncHttpClient。您声明您的异步服务客户端，NettyNioAsyncHttpClient然后SDK将为您配置标准值。

如果要显式配置 NettyNioAsyncHttpClient 或将其用于多个服务客户端，则需要将其设置为可供配置。

无需配置

在 Maven 中声明对服务客户端的依赖关系时，SDK会添加对netty-nio-client工件的运行时依赖关系。这使得 NettyNioAsyncHttpClient 类在运行时可供您的代码使用，但在编译时不可用。如果您没有配置基于 Netty 的HTTP客户端，则无需为其指定依赖关系。

在以下 Maven pom.xml 文件XML片段中，使用<artifactId>dynamodb-enhanced</artifactId>传递声明的依赖关系引入了基于 Netty 的客户端。HTTP您无需专门为其声明依赖项。


<dependencyManagement>
   <dependencies>
        <dependency>
            <groupId>software.amazon.awssdk</groupId>
            <artifactId>bom</artifactId>
            <version>2.27.21</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
<dependencies>
    <dependency>
        <groupId>software.amazon.awssdk</groupId>
        <artifactId>dynamodb-enhanced</artifactId>
    </dependency>
</dependencies>

有了这些依赖关系，您就无法对HTTP配置进行任何更改，因为该NettyNioAsyncHttpClient库仅位于运行时类路径上。

需要配置

要配置 NettyNioAsyncHttpClient，您需要在编译时添加对 netty-nio-client 构件的依赖项。

请参阅以下 Maven pom.xml 文件示例来配置 NettyNioAsyncHttpClient。


    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>software.amazon.awssdk</groupId>
                <artifactId>bom</artifactId>
                <version>2.27.21</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>software.amazon.awssdk</groupId>
            <artifactId>dynamodb-enhanced</artifactId>
        </dependency>
        <!-- By adding the netty-nio-client dependency, NettyNioAsyncHttpClient will be 
             added to the compile classpath so you can configure it. -->
        <dependency>
            <groupId>software.amazon.awssdk</groupId>
            <artifactId>netty-nio-client</artifactId>
        </dependency>
    </dependencies>

使用和配置 `NettyNioAsyncHttpClient`

您可以在生成服务客户端的同时配置一个 NettyNioAsyncHttpClient 实例，也可以将单个实例配置为在多个服务客户端之间共享。

无论采用哪种方法，都可以使用 NettyNioAsyncHttpClient.Builder 来配置基于 Netty 的客户端实例的HTTP属性。

最佳实践：将一个 `NettyNioAsyncHttpClient` 实例专用于一个服务客户端

如果您需要配置 NettyNioAsyncHttpClient 实例，建议您生成专用 NettyNioAsyncHttpClient 实例。您可以通过使用服务客户端生成器的 httpClientBuilder 方法来执行此操作。这样，HTTP客户端的生命周期就由来管理SDK，这有助于避免在不再需要NettyNioAsyncHttpClient实例时不关闭实例时可能发生的内存泄漏。

以下示例创建了一个 DynamoDbAsyncClient 实例，该实例供 DynamoDbEnhancedAsyncClient 实例使用。该 DynamoDbAsyncClient 实例包含具有 connectionTimeout 和 maxConcurrency 值的 NettyNioAsyncHttpClient 实例。该HTTP实例是使用httpClientBuilder方法创建的DynamoDbAsyncClient.Builder。

导入


import software.amazon.awssdk.auth.credentials.EnvironmentVariableCredentialsProvider;
import software.amazon.awssdk.awscore.defaultsmode.DefaultsMode;
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedAsyncClient;
import software.amazon.awssdk.enhanced.dynamodb.extensions.AutoGeneratedTimestampRecordExtension;
import software.amazon.awssdk.http.nio.netty.NettyNioAsyncHttpClient;
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient;
import java.time.Duration;

代码


// DynamoDbAsyncClient is the lower-level client used by the enhanced client.
DynamoDbAsyncClient dynamoDbAsyncClient = 
    DynamoDbAsyncClient
        .builder()
            .httpClientBuilder(NettyNioAsyncHttpClient.builder()
            .connectionTimeout(Duration.ofMillis(5_000))
            .maxConcurrency(100)
            .tlsNegotiationTimeout(Duration.ofMillis(3_500)))
        .defaultsMode(DefaultsMode.IN_REGION)
        .credentialsProvider(EnvironmentVariableCredentialsProvider.create())
        .build();

// Singleton: Use dynamoDbAsyncClient and enhancedClient for all requests.
DynamoDbEnhancedAsyncClient enhancedClient = 
    DynamoDbEnhancedAsyncClient
        .builder()
        .dynamoDbClient(dynamoDbAsyncClient)
        .extensions(AutoGeneratedTimestampRecordExtension.create())
        .build();

// Perform work with the dynamoDbAsyncClient and enhancedClient.

// Requests completed: Close dynamoDbAsyncClient.
dynamoDbAsyncClient.close();

替代方法：共享 `NettyNioAsyncHttpClient` 实例

为了帮助降低应用程序的资源和内存使用量，您可以配置 NettyNioAsyncHttpClient 并在多个服务客户端之间共享该客户端。HTTP连接池将被共享，从而降低资源使用量。

注意

共享 NettyNioAsyncHttpClient 实例时，必须在准备好弃置实例时将其关闭。关闭服务客户端后，SDK不会关闭实例。

以下示例配置了由两个服务客户机使用的基于 Netty 的HTTP客户端。配置的 NettyNioAsyncHttpClient 实例将传递给每个生成器的 httpClient 方法。当不再需要服务客户端和HTTP客户端时，代码会显式关闭它们。该代码最后关闭HTTP客户端。

导入


import software.amazon.awssdk.http.SdkHttpClient;
import software.amazon.awssdk.http.apache.ApacheHttpClient;
import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
import software.amazon.awssdk.services.s3.S3Client;

代码


// Create a NettyNioAsyncHttpClient shared instance.
SdkAsyncHttpClient nettyHttpClient = NettyNioAsyncHttpClient.builder().maxConcurrency(100).build();

// Singletons: Use the s3AsyncClient, dbAsyncClient, and enhancedAsyncClient for all requests.
S3AsyncClient s3AsyncClient = 
    S3AsyncClient.builder()
                 .httpClient(nettyHttpClient)
                 .build();

DynamoDbAsyncClient dbAsyncClient = 
    DynamoDbAsyncClient.builder()
                       .httpClient(nettyHttpClient)
                       .defaultsMode(DefaultsMode.IN_REGION)
                       .credentialsProvider(EnvironmentVariableCredentialsProvider.create())
                       .build();

DynamoDbEnhancedAsyncClient enhancedAsyncClient = 
    DynamoDbEnhancedAsyncClient.builder()
                               .dynamoDbClient(dbAsyncClient)
                               .extensions(AutoGeneratedTimestampRecordExtension.create())
                               .build();

// Perform work with s3AsyncClient, dbAsyncClient, and enhancedAsyncClient.

// Requests completed: Close all service clients.
s3AsyncClient.close();
dbAsyncClient.close()
nettyHttpClient.close();  // Explicitly close nettyHttpClient.

代理配置示例

以下代码片段使用了 Netty HTTP 客户端的代理配置生成器。


SdkAsyncHttpClient nettyHttpClient = NettyNioAsyncHttpClient.builder()
    .proxyConfiguration(ProxyConfiguration.builder()
        .scheme("https")
        .host("myproxy")
        .port(1234)
        .username("username")
        .password("password")
        .nonProxyHosts(Set.of("localhost", "host.example.com"))
        .build())
    .build();

以下命令行片段显示了代理配置的等效 Java 系统属性。


$ java -Dhttps.proxyHost=myproxy -Dhttps.proxyPort=1234 -Dhttps.proxyUser=username \
-Dhttps.proxyPassword=password -Dhttp.nonProxyHosts=localhost|host.example.com -cp ... App

重要

要使用任何HTTPS代理系统属性，必须在代码中将该scheme属性设置为https。如果未在代码中设置 scheme 属性，则方案默认为，HTTP并且仅SDK查找http.*系统属性。

使用环境变量的等效设置为：


// Set the following environment variables.
// $ export HTTPS_PROXY="https://username:password@myproxy:1234"
// $ export NO_PROXY="localhost|host.example.com"

// Set the 'useSystemPropertyValues' to false on the proxy configuration.
SdkAsyncHttpClient nettyHttpClient = NettyNioAsyncHttpClient.builder()
    .proxyConfiguration(ProxyConfiguration.builder()
        .useSystemPropertyValues(Boolean.FALSE)
        .build())
    .build();

// Run the application.
// $ java -cp ... App

Javascript 在您的浏览器中被禁用或不可用。

要使用 Amazon Web Services 文档，必须启用 Javascript。请参阅浏览器的帮助页面以了解相关说明。

配置URLConnection基于的HTTP客户端

Amazon CRT基于配置的HTTP客户端

配置基于 Netty 的客户端 HTTP

访问 NettyNioAsyncHttpClient