diff --git a/internal/nodes/http_client_pool.go b/internal/nodes/http_client_pool.go index 06cd64e..58d0839 100644 --- a/internal/nodes/http_client_pool.go +++ b/internal/nodes/http_client_pool.go @@ -84,7 +84,6 @@ func (this *HTTPClientPool) Client(req *HTTPRequest, origin *serverconfigs.Origi if idleConns <= 0 { idleConns = numberCPU * 8 } - //logs.Println("[ORIGIN]max connections:", maxConnections) // TLS通讯 tlsConfig := &tls.Config{ @@ -101,7 +100,7 @@ func (this *HTTPClientPool) Client(req *HTTPRequest, origin *serverconfigs.Origi } } - transport := &http.Transport{ + var transport = &http.Transport{ DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) { // 支持TOA的连接 toaConfig := sharedTOAManager.Config() diff --git a/internal/nodes/http_request_reverse_proxy.go b/internal/nodes/http_request_reverse_proxy.go index 4aeef68..e545df0 100644 --- a/internal/nodes/http_request_reverse_proxy.go +++ b/internal/nodes/http_request_reverse_proxy.go @@ -293,6 +293,13 @@ func (this *HTTPRequest) doReverseProxy() { this.writer.WriteHeader(resp.StatusCode) } + // 是否有内容 + if resp.ContentLength == 0 && len(resp.TransferEncoding) == 0 { + _ = resp.Body.Close() + this.writer.SetOk() + return + } + // 输出到客户端 pool := this.bytePool(resp.ContentLength) buf := pool.Get()