自定义 HTTP 客户端

适用于 Go 的 AWS SDK 使用带有默认配置值的默认 HTTP 客户端。尽管您可以更改其中的一些配置值，但是对于在高吞吐量和低延迟要求的环境适用于 Go 的 AWS SDK 中使用的客户，默认的 HTTP 客户端和传输配置不足。有关更多信息，请参阅，常见问题因为配置建议因特定工作负载而异。本节介绍如何配置自定义 HTTP 客户端，以及如何使用该客户端创建适用于 Go 的 AWS SDK 呼叫。

为了帮助您创建自定义 HTTP 客户端，本节介绍NewBuildableClient如何配置自定义设置以及如何将该客户端与适用于 Go 的 AWS SDK 服务客户端一起使用。

让我们来定义我们要自定义的内容。

在配置加载期间重写

调用 LoadDefaultConfig时可以通过使用 With 包装客户端HTTPClient并将结果值传递给，从而提供自定义 HTTP 客户端LoadDefaultConfig。例如，要以我们的客户customClient身份通过：


cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithHTTPClient(customClient))

超时

BuildableHTTPClient可以配置请求超时限制。此超时包括连接、处理任何重定向和读取完整响应正文的时间。例如，要修改客户端超时，请执行以下操作：


import "github.com/aws/aws-sdk-go-v2/aws/transport/http"

// ...

httpClient := http.NewBuildableClient().WithTimeout(time.Second*5)

拨号器

BuildableHTTPClient提供了一种生成器机制，用于使用修改后的拨号器选项来构造客户端。以下示例说明如何配置客户端Dialer设置。


import awshttp "github.com/aws/aws-sdk-go-v2/aws/transport/http"
import "net"

// ...

httpClient := awshttp.NewBuildableClient().WithDialerOptions(func(d *net.Dialer) {
    d.KeepAlive = -1
    d.Timeout = time.Millisecond*500
})

设置

拨号器。 KeepAlive

此设置表示活动网络连接的保持活动时间。

设置为负值可禁用 keep-alives。

如果协议和操作系统支持，则设置为 0 以启用 keep-alive。

不支持 keep-alive 的网络协议或操作系统会忽略此字段。默认情况下，TCP 启用保持活动状态。

见 https://golang。 org/pkg/net/#Dialer。 KeepAlive

设置KeepAlive为时间。持续时间。

拨号器. 超时

此设置表示拨号等待创建连接的最长时间。

默认值为 30 秒。

见 https://golang。 org/pkg/net/#Dialer .Timeout

设置Timeout为时间。持续时间。

传输

BuildableHTTPClient提供了构建器机制，用于使用修改后的传输选项来构造客户端。

配置代理

如果您无法直接连接到互联网，则可以使用 Go 支持的环境变量 (HTTP_PROXY/HTTPS_PROXY) 或创建自定义 HTTP 客户端来配置代理。以下示例将客户端配置为PROXY_URL用作代理端点：


import awshttp "github.com/aws/aws-sdk-go-v2/aws/transport/http"
import "net/http"

// ...

httpClient := awshttp.NewBuildableClient().WithTransportOptions(func(tr *http.Transport) {
    proxyURL, err := url.Parse("PROXY_URL")
    if err != nil {
        log.Fatal(err)
    }
    tr.Proxy = http.ProxyURL(proxyURL)
})

其他设置

以下是一些其他Transport设置，可以对其进行修改以调整 HTTP 客户端。此处未描述的任何其他设置都可以在传输类型文档中找到。可以应用这些设置，如以下示例所示：


import awshttp "github.com/aws/aws-sdk-go-v2/aws/transport/http"
import "net/http"

// ...

httpClient := awshttp.NewBuildableClient().WithTransportOptions(func(tr *http.Transport) {
    tr.ExpectContinueTimeout = 0
    tr.MaxIdleConns = 10
})