1. HTTP Transport简介
在Go语言中，http.Transport是用于控制HTTP客户端行为的结构体，其包括与HTTP客户端相关的各种配置选项，例如连接、重定向、跟踪和代理等。使用它可以非常灵活地控制HTTP请求的相关参数，包括请求的超时时间、最大并发连接数、TLS配置等。
// http.Transport结构体定义
type Transport struct {
Proxy func(*Request) (*url.URL, error)
DialContext func(ctx context.Context, network, addr string) (net.Conn, error)
Dial func(network, addr string) (net.Conn, error)
DialTLS func(network, addr string) (net.Conn, error)
TLSClientConfig *tls.Config
TLSHandshakeTimeout time.Duration
...
}
2. 请求错误处理方法
2.1 Timeout错误
当HTTP请求在预定义的时间内没有完成时，会触发Timeout错误。这个错误通常是由网络延迟、服务器过载或者客户端代码中的缺陷引起的。在Go语言中，可以通过设置http.Transport的Timeout属性来控制请求的超时时间。
// 设置超时时间为5秒钟
client := http.Client{
Timeout: time.Second * 5,
Transport: &http.Transport{
...
},
}
req, err := http.NewRequestWithContext(context.Background(), http.MethodGet, "http://example.com", nil)
if err != nil {
log.Fatalf("Failed to create new request: %v", err)
}
res, err := client.Do(req)
if err != nil {
if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
log.Fatalf("Request timed out: %v", err)
}
log.Fatalf("Failed to send request: %v", err)
}
defer res.Body.Close()
2.2 Connection Refused错误
当客户端尝试连接的端口未打开或不可用时，会触发Connection Refused错误。这个错误通常是由服务端没有正确启动、网络设置不正确或者防火墙拦截引起的。在Go语言中，可以通过设置http.Transport的DialContext属性来控制连接的超时时间。
// 设置连接超时时间为2秒钟
var transport = &http.Transport{
DialContext: (&net.Dialer{
Timeout: 2 * time.Second,
KeepAlive: 30 * time.Second,
DualStack: true,
}).DialContext,
MaxIdleConns: 100,
IdleConnTimeout: 90 * time.Second,
...
}
client := &http.Client{Transport: transport}
// 发送HTTP请求
res, err := client.Get("http://example.com")
if err != nil {
if _, ok := err.(*net.OpError); ok {
log.Fatalf("Failed to connect: %v", err)
}
log.Fatalf("Failed to send request: %v", err)
}
defer res.Body.Close()
3. 日志记录方法
对于处理HTTP请求中的错误，记录日志可以帮助开发人员快速发现问题，追踪日志信息并且及时排查故障。在Go语言中，可以通过log包来实现日志记录功能，这个包提供了三个主要方法：Print、Printf和Fprint。其中，Printf方法使用格式化字符串来输出日志记录。
// 日志记录示例代码
func HandleRequest(req *http.Request) (*http.Response, error) {
// 构建HTTP客户端
client := http.Client{Transport: &http.Transport{}}
// 发送HTTP请求
res, err := client.Do(req)
if err != nil {
log.Printf("Failed to send request: %v", err)
return nil, err
}
defer res.Body.Close()
// 处理响应
if res.StatusCode != http.StatusOK {
log.Printf("Server returned bad status code: %d", res.StatusCode)
return nil, errors.New("received bad status code")
}
return res, nil
}
3.1 日志信息分类
对于日志信息，需要根据其重要程度进行分类。因为HTTP请求的处理可能会产生很多不同级别的日志记录，而开发人员并不需要处理所有这些日志记录。可以将日志信息分为以下几类：
调试信息：对于开发人员而言，这些日志信息是非常有价值的，可以帮助开发人员对HTTP请求的处理过程进行跟踪和调试。
警告信息：对于HTTP请求的处理过程中发生的一些预期的或者可处理的错误，可以记录为警告信息。
错误信息：对于HTTP请求的处理过程中发生的无法处理或者非预期的错误，需要记录为错误信息，以便开发人员及时排查和修复错误。
3.2 日志信息格式化
在记录日志信息时，需要规定一个统一的日志格式，以便开发人员能够快速地找到日志信息，采集和分析日志。通常，日志格式由若干个字段组成，每个字段用一个特定的符号进行分隔，例如在Apache服务器中，日志格式通常为："%h %l %u %t \"%r\" %>s %b"，表示分别记录了客户端IP地址、远程登录名、远程用户名、时间戳、HTTP方法、HTTP状态码和响应内容长度。
// 自定义日志格式实现示例
var logFormat = log.New(os.Stdout, "", log.LstdFlags|log.LUTC|log.Lshortfile)
func HandleRequest(req *http.Request) (*http.Response, error) {
// 构建HTTP客户端
client := http.Client{Transport: &http.Transport{}}
// 发送HTTP请求
start := time.Now()
res, err := client.Do(req)
if err != nil {
logFormat.Printf("Error occurred: %v", err)
return nil, err
}
defer res.Body.Close()
// 处理响应
duration := time.Since(start)
logFormat.Printf("%s %s %d %d %d %dms", req.Method, req.URL.String(), res.StatusCode, res.ContentLength, req.ContentLength, duration.Milliseconds())
if res.StatusCode != http.StatusOK {
logFormat.Printf("Server returned bad status code: %d", res.StatusCode)
return nil, errors.New("received bad status code")
}
return res, nil
}
3.3 日志信息输出
在记录日志信息时，需要考虑日志输出的方式。通常，日志信息可以输出到控制台、日志文件、数据库或者其他的日志收集系统中。在Go语言中，可以通过设置log.SetOutput()方法来设置日志输出的目标。
package main
import (
"log"
"os"
)
func main() {
output, err := os.Create("log.txt")
if err != nil {
log.Fatalf("Failed to create log file: %v", err)
}
defer output.Close()
log.SetOutput(output)
// 记录日志信息
log.Print("This is a log message")
}
4. 总结
使用http.Transport结构体和log包可以很好地控制HTTP请求的行为和记录请求处理过程中的日志信息。在日常开发中，我们应该始终关注HTTP请求处理过程中是否存在错误，以及如何及时有效地记录和跟踪相关的日志信息，以便及时发现问题并对其进行修复。