Fix/remove setdeadline (#2785)

Author: No-SilverBullet

protocol/rest/client/client_impl/resty_client.go

@@ -22,7 +22,6 @@ import (
 	"net"
 	"net/http"
 	"path"
-	"time"
 )
 
 import (
@@ -56,13 +55,11 @@ func NewRestyClient(restOption *client.RestOptions) client.RestClient {
 				if err != nil {
 					return nil, err
 				}
-				err = c.SetDeadline(time.Now().Add(restOption.RequestTimeout))
-				if err != nil {
-					return nil, err
-				}
 				return c, nil
 			},
+			IdleConnTimeout: restOption.KeppAliveTimeout,
 		})
+	client.SetTimeout(restOption.RequestTimeout)
 	return &RestyClient{
 		client: client,
 	}

protocol/rest/client/rest_client.go

@@ -23,8 +23,9 @@ import (
 )
 
 type RestOptions struct {
-	RequestTimeout time.Duration
-	ConnectTimeout time.Duration
+	RequestTimeout   time.Duration
+	ConnectTimeout   time.Duration
+	KeppAliveTimeout time.Duration
 }
 
 type RestClientRequest struct {

protocol/rest/rest_protocol.go

@@ -93,6 +93,7 @@ func (rp *RestProtocol) Refer(url *common.URL) protocol.Invoker {
 	requestTimeout := time.Duration(3 * time.Second)
 	requestTimeoutStr := url.GetParam(constant.TimeoutKey, "3s")
 	connectTimeout := requestTimeout // config.GetConsumerConfig().ConnectTimeout
+	keepAliveTimeout := url.GetParamDuration(constant.KeepAliveTimeout, constant.DefaultKeepAliveTimeout)
 	// end
 	if t, err := time.ParseDuration(requestTimeoutStr); err == nil {
 		requestTimeout = t
@@ -103,7 +104,7 @@ func (rp *RestProtocol) Refer(url *common.URL) protocol.Invoker {
 		logger.Errorf("%s service doesn't has consumer config", url.Path)
 		return nil
 	}
-	restOptions := client.RestOptions{RequestTimeout: requestTimeout, ConnectTimeout: connectTimeout}
+	restOptions := client.RestOptions{RequestTimeout: requestTimeout, ConnectTimeout: connectTimeout, KeppAliveTimeout: keepAliveTimeout}
 	restClient := rp.getClient(restOptions, restServiceConfig.Client)
 	invoker := NewRestInvoker(url, &restClient, restServiceConfig.RestMethodConfigsMap)
 	rp.SetInvokers(invoker)