登录
首页 >  Golang >  Go问答

是否可以在 Gin 服务器中处理客户端套接字事件关闭(基于 net/http 包)?

来源:stackoverflow

时间:2024-04-08 22:54:34 458浏览 收藏

怎么入门Golang编程?需要学习哪些知识点?这是新手们刚接触编程时常见的问题;下面golang学习网就来给大家整理分享一些知识点,希望能够给初学者一些帮助。本篇文章就来介绍《是否可以在 Gin 服务器中处理客户端套接字事件关闭(基于 net/http 包)?》,涉及到,有需要的可以收藏一下

问题内容

https://github.com/gin-gonic/gin 使用 http 服务器。是否可以处理客户端套接字关闭?在处理程序中

router.GET("/v1/get/*uri", func (c *gin.Context) {
     var url = c.Param("uri")
     if url[0:1] == "/" {
        url = url[1:]
     }
     req, err := http.NewRequest("GET", url, nil)

我向 url 发出 http 客户端请求。如果我从 wget/curl 客户端关闭与 gin 服务器的连接,gin http 客户端请求仍会被处理。我想中断客户端套接字断开事件上的处理程序执行,以免浪费资源。


解决方案


如果客户端断开连接,gin.context.done() 将返回。 http.transport.cancelrequest() 中断对 url 的 http 请求。所以http请求是在goroutine中发出的,我们在select中等待第一个事件:

  1. http请求完成

  2. 客户端与 gin 服务器断开连接

    router.get("/v1/get/*uri", func (c *gin.context) { var url = c.param("uri") 如果 url[0:1] == "/" { 网址 = 网址[1:] }

    tr := &http.Transport{ TLSClientConfig : (&tls.Config{ InsecureSkipVerify: true}),
                               DisableKeepAlives : false,
                               DisableCompression : false,
                               MaxIdleConns : 0,
                               MaxConnsPerHost : 0,
                               IdleConnTimeout : 0,
                               ResponseHeaderTimeout : 0,
                               ExpectContinueTimeout : 0,
                               ForceAttemptHTTP2 : true}
        client := http.Client{ Timeout: 20 * time.Second, Transport : tr}
        req, err := http.NewRequest("GET", url, nil)
        if err != nil {
            fail(1, "NewRequest")
        }
        for k, v := range c.Request.Header {
            req.Header.Set(k, strings.Join(v, "\n"))
        }
        is_url_done := make(chan HTTPRequestResult, 1)
        go func() {
            resp, err := client.Do(req)
            is_url_done <- HTTPRequestResult{res, err}
        }()
        for {
        select {
        case <-c.Done():
            tr.CancelRequest(req)
            return
        case r:= <-is_url_done:
            if r.err != nil {
                c.String(http.StatusInternalServerError, "Error: %v\n", r.err)
            } else {
                var headers = map[string]string{}
                for key, values := range(r.res.Header) {
                    headers[key] = strings.Join(values, ", ")
                }
                c.DataFromReader(r.res.StatusCode, r.res.ContentLength, "test", r.res.Body, headers)
            }
    
            return
        }
    }

好了,本文到此结束,带大家了解了《是否可以在 Gin 服务器中处理客户端套接字事件关闭(基于 net/http 包)?》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多Golang知识!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>