dongyongkui6329 2019-04-19 14:36
浏览 230
已采纳

Go中每个处理程序方法的并发连接数

func handleForServer1(res http.ResponseWriter, req *http.Request) {
    rPayload := parseRequestBody(req)
    serve("http://server1:8080", res, req)
}

func handleForServer2(res http.ResponseWriter, req *http.Request) {
    rPayload := parseRequestBody(req)
    serve("http://server2:8080", res, req)
}

func serve(dest string, res http.ResponseWriter, req *http.Request) {
    url, _ := url.Parse(dest)
    p := httputil.NewSingleHostReverseProxy(url)

    req.URL.Host = url.Host
    req.URL.Scheme = url.Scheme
    req.Header.Set("X-Forwarded-Host", req.Header.Get("Host"))
    req.Host = url.Host

    p.ServeHTTP(res, req)
}

I have a code like above. I'm wondering if there's a way to find out how many concurrent connections does handler "handleForServe2" has?

Goal for that code is making a reverse proxy function. But, also I'd like to add balance loading based on concurrent connections per server that is connected to.

Thank you so much!

  • 写回答

1条回答 默认 最新

  • doutang1873 2019-04-19 16:00
    关注

    One way could be to approximate this number by explicitly counting the number of concurrent invocations. This may not be sufficient, as it can only tell you how many times handleForServe2 is being invoked. To illustrate:

    mu sync.RWMutex
    concurrentInvocations := 0
    
    func handleForServer2(res http.ResponseWriter, req *http.Request) {
        mu.Lock()
        concurrentInvocations++
        mu.Unlock()
    
        defer func() {
           mu.Lock()
           concurrentInvocations--
           mu.Unlock()
        }()
    
        rPayload := parseRequestBody(req)
        serve("http://server2:8080", res, req)
    }
    
    ticker := time.NewTicker(5 * time.Second)
    for {
       select {
         case <- ticker.C:
           mu.RLock()
           fmt.Printf("Current %d concurrent requests
    ", concurrentInvocations)
           mu.RUnlock()
       }
    }
    

    Now at anytime, you should be able to see the number of concurrent invocations of handleForServer2. If this is sufficient, it probably needs to be extended to keep track of each server/handler's capacity.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥30 关于php页面调取、更新数据提交刷新等问题
  • ¥50 使用 java+selenium 接管手动打开的IE浏览器
  • ¥15 ios 新安装app收不到fcm推送
  • ¥15 有没有实力的写手?有过成品的优先
  • ¥15 图像信息库的建立与识别
  • ¥15 韩国网站购物,KG支付的支付回调如何解决
  • ¥15 workstation导入ovf文件,报错,怎么解决呢?
  • ¥15 关于#c语言#的问题:构成555单稳态触发器,采用LED指示灯延时时间,对延时时间进行测量并显示(如楼道声控延时灯)需要Proteus仿真图和C语言代码
  • ¥15 workstation加载centos进入emergency模式,查看日志报警如图,怎样解决呢?
  • ¥50 如何用单纯形法寻优不能精准找不到给定的参数,并联机构误差识别,给定误差有7个?matlab