From b290834b2f832a974045c94fb571a6f0852c141b Mon Sep 17 00:00:00 2001 From: boyce Date: Wed, 30 Jan 2019 18:29:26 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E9=80=9Frpc=E8=AE=BF=E9=97=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc/client.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/rpc/client.go b/rpc/client.go index cad2d45..784c8a6 100644 --- a/rpc/client.go +++ b/rpc/client.go @@ -247,9 +247,13 @@ func DialHTTP(network, address string) (*Client, error) { func DialHTTPPath(network, address, path string) (*Client, error) { var err error conn, err := net.Dial(network, address) + if err != nil { return nil, err } + tcpconn, _ := conn.(*net.TCPConn) + tcpconn.SetNoDelay(true) + io.WriteString(conn, "CONNECT "+path+" HTTP/1.0\n\n") // Require successful HTTP response @@ -276,6 +280,9 @@ func Dial(network, address string) (*Client, error) { if err != nil { return nil, err } + tcpconn, _ := conn.(*net.TCPConn) + tcpconn.SetNoDelay(true) + return NewClient(conn), nil }