go包：fasthttp

1. 介绍

fasthttp是由valyala编写,并宣称比Go官方标准库net/http快十倍。fasthttp采用了许多性能优化上的最佳实践，尤其是在内存对象的重用上，大量使用[sync.Pool以降低对Go GC的压力。

推荐文章: Go标准库http与fasthttp服务端性能比较:https://tonybai.com/2021/04/25/server-side-performance-nethttp-vs-fasthttp/

2.工作原理

2.1 net/http工作原理示意图

a. 流程说明

http包作为server端的原理很简单，那就是accept到一个连接(conn)之后，将这个conn甩给一个worker goroutine去处理，后者一直存在，直到该conn的生命周期结束：即连接关闭。

2.2 fasthttp工作原理示意图

fasthttp高性能主要源自于复用，fasthttp设计了一套机制，目的是尽量复用goroutine，而不是每次都创建新的goroutine。

a. 流程说明

当fasthttp的Server接到一个conn之后，会尝试从workerpool中的ready切片中取出一个channel，该channel与某个worker goroutine一一对应。

一旦取出channel，就会将accept到的conn写到该channel里，而channel另一端的worker goroutine就会处理该conn上的数据读写。

当处理完该conn后，该worker goroutine不会退出，而是会将自己对应的那个channel重新放回workerpool中的ready切片中，等待这下一次被取出。

3. 安装

go get -u github.com/valyala/fasthttp

4. 使用

4.1 自定义客户端配置

/**
 * @Description: 获取http客户端
 * @Author: LiuQHui
 * @Date 2022-04-13 18:53:22
**/
func getFastReqClient() *fasthttp.Client {
    reqClient := &fasthttp.Client{
        // 读超时时间,不设置read超时,可能会造成连接复用失效
        ReadTimeout: time.Second * 5,
        // 写超时时间
        WriteTimeout: time.Second * 5,
        // 5秒后，关闭空闲的活动连接
        MaxIdleConnDuration: time.Second * 5,
        // 当true时,从请求中去掉User-Agent标头
        NoDefaultUserAgentHeader: true,
        // 当true时，header中的key按照原样传输，默认会根据标准化转化
        DisableHeaderNamesNormalizing: true,
        //当true时,路径按原样传输，默认会根据标准化转化
        DisablePathNormalizing: true,
        Dial: (&fasthttp.TCPDialer{
            // 最大并发数，0表示无限制
            Concurrency: 4096,
            // 将 DNS 缓存时间从默认分钟增加到一小时
            DNSCacheDuration: time.Hour,
        }).Dial,
    }
    return reqClient
}

4.2 发起GET请求

/**
 * @Description: 发起Get请求
**/
func FastGetWithDo() string {
    // 获取客户端
    client := getFastReqClient()
    // 从请求池中分别获取一个request、response实例
    req, resp := fasthttp.AcquireRequest(), fasthttp.AcquireResponse()
    // 回收实例到请求池
    defer func() {
        fasthttp.ReleaseRequest(req)
        fasthttp.ReleaseResponse(resp)
    }()
    // 设置请求方式
    req.Header.SetMethod(fasthttp.MethodGet)
    // 设置请求地址
    req.SetRequestURI("http://httpbin.org/get")
    // 设置参数
    var arg fasthttp.Args
    arg.Add("name", "张三")
    arg.Add("id", "10001")
    req.URI().SetQueryString(arg.String())
    // 设置header信息
    req.Header.Add("content-type", "application/json")
    // 设置Cookie信息
    req.Header.SetCookie("key", "val")
    // 发起请求
    if err := client.Do(req, resp); err != nil {
        fmt.Println("req err ", err)
        return err.Error()
    }
    // 读取结果
    return string(resp.Body())
}

4.3 发起POST请求

// post请求参数
type postParamExample struct {
    Request string `json:"request"`
}

/**
 * @Description: post请求
 * @Return string
**/
func FastPostRawWithDo() string {
    // 获取客户端
    client := getFastReqClient()
    // 从请求池中分别获取一个request、response实例
    req, resp := fasthttp.AcquireRequest(), fasthttp.AcquireResponse()
    // 回收到请求池
    defer func() {
        fasthttp.ReleaseRequest(req)
        fasthttp.ReleaseResponse(resp)
    }()
    // 设置请求方式
    req.Header.SetMethod(fasthttp.MethodPost)
    // 设置请求地址
    req.SetRequestURI("http://httpbin.org/post")
    // 设置请求ContentType
    req.Header.SetContentType("application/json")
    // 设置参数
    param := postParamExample{
        Request: "test",
    }
    marshal, _ := json.Marshal(param)
    req.SetBodyRaw(marshal)
    // 发起请求
    if err := client.Do(req, resp); err != nil {
        fmt.Println("req err ", err)
        return err.Error()
    }
    // 读取结果
    return string(resp.Body())
}