Polish retry time (apache#2564)

fixes apache#2550

cluster/cluster/failover/cluster_invoker.go

@@ -20,16 +20,10 @@ package failover
 import (
  "context"
  "fmt"
- "strconv"
-)
 
-import (
  "github.com/dubbogo/gost/log/logger"
-
  perrors "github.com/pkg/errors"
-)
 
-import (
  "dubbo.apache.org/dubbo-go/v3/cluster/cluster/base"
  "dubbo.apache.org/dubbo-go/v3/cluster/directory"
  "dubbo.apache.org/dubbo-go/v3/common"
@@ -114,23 +108,13 @@ func getRetries(invokers []protocol.Invoker, methodName string) int {
  if len(invokers) <= 0 {
  return constant.DefaultRetriesInt
  }
-
  url := invokers[0].GetURL()
- // get reties
- retriesConfig := url.GetParam(constant.RetriesKey, constant.DefaultRetries)
- // Get the service method loadbalance config if have
- if v := url.GetMethodParam(methodName, constant.RetriesKey, ""); len(v) != 0 {
- retriesConfig = v
- }
 
- retries, err := strconv.Atoi(retriesConfig)
- if err != nil || retries < 0 {
- logger.Error("Your retries config is invalid,pls do a check. And will use the default retries configuration instead.")
- retries = constant.DefaultRetriesInt
- }
+ retries := url.GetMethodParamIntValue(methodName, constant.RetriesKey,
+ url.GetParamByIntValue(constant.RetriesKey, constant.DefaultRetriesInt))
 
- if retries > len(invokers) {
- retries = len(invokers)
+ if retries < 0 {
+ return constant.DefaultRetriesInt
  }
  return retries
 }