http 客户端超时怎么做(是每个请求的超时都独立)

maolele · 2018-12-17 14:16:08 · 1190 次点击 · 大约8小时之前 开始浏览    置顶
这是一个创建于 2018-12-17 14:16:08 的主题,其中的信息可能已经有所发展或是发生改变。

本人开了100个协程,每个协程调用这个httpPost方法,在这个方法里面初始化http客户端,本来以为是每个协程初始化一个http客户端,然后每一个请求都有一个超时的时间,后来发现并没有,这个超时时间竟然是累计的。

想问一下,如果每个http请求都设置一个超时时间该怎么做, httpPost函数代码如下

var v1 = make([]byte, 1)
c := http.Client{
    Transport: &http.Transport{
        Dial: func(netw, addr string) (net.Conn, error) {
            c, err := net.DialTimeout(netw, addr, time.Millisecond*200 ) //设置建立连接超时
            if err != nil {
                return nil, err
            }
            deadline := time.Now().Add(2 * time.Second) //设置超时时间
            c.SetDeadline(deadline)  
            return c, nil
        },
    },
}

form := url.Values{}

for k, v := range post_param{
    form.Set(k, v)
}

b := strings.NewReader(form.Encode())
req, err := http.NewRequest("POST", post_url, b)
req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
res, err := c.Do(req)
if err != nil {

    fmt.Println("httpPostForm 机器人请求失败: ",robot_num)
    fmt.Println("httpPostForm 请求错误是:", err.Error())

    //加锁
    mutex.Lock()
    defer mutex.Unlock()
    fail++

    return v1,false
}
defer res.Body.Close()

body,err:=ioutil.ReadAll(res.Body)
if err != nil{
    fmt.Println("httpPostForm 机器人请求失败: ",robot_num)
    fmt.Println("httpPostForm 请求错误是:", err.Error())

    //加锁
    mutex.Lock()
    defer mutex.Unlock()
    fail++
}
return body,true

有疑问加站长微信联系(非本文作者)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1190 次点击  
加入收藏 微博
5 回复  |  直到 2018-12-18 17:39:05
dingzewe
dingzewe · #1 · 6年之前

可以用context的超时自己做

heyHui2018
heyHui2018 · #2 · 6年之前

试试在Transport里面设置ResponseHeaderTimeout

BlackBerryX
BlackBerryX · #3 · 6年之前

1楼是对的,使用contect包,自己包装超时。

maolele
maolele · #4 · 6年之前

难道go的http包,自己没有提供这个方法吗

maolele
maolele · #5 · 6年之前

ResponseHeaderTimeout这个我试了还是一样的,算的是总的时间

添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传