自定义 HTTP 客户端

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

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

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

在配置加载期间覆盖

调用 LoadDefaultConfig 时，可以提供自定义 HTTP 客户端，方法是使用 WithHTTPClient 包装客户端并将结果值传递给 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
})

设置

Dialer.KeepAlive

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

设置为负值可禁用“保持连接”。

如果协议和操作系统支持，则设置为 0 可启用“保持连接”。

不支持“保持连接”的网络协议或操作系统会忽略此字段。默认情况下，TCP 启用“保持连接”。

请参阅 https://golang.org/pkg/net/#Dialer.KeepAlive

将 KeepAlive 设置为 time.Duration。

Dialer.Timeout

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

默认为 30 秒。

请参阅 https://golang.org/pkg/net/#Dialer.Timeout

将 Timeout 设置为 time.Duration。

传输

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
})