fix(contrib): fix eureka server load too high (#2546)

Co-authored-by: fangyong <fangyong@haodf.com>

contrib/registry/eureka/client.go

@@ -19,9 +19,9 @@ const (
 	statusOutOfService = "OUT_OF_SERVICE"
 	heartbeatRetry     = 3
 	maxIdleConns       = 100
-	heartbeatTime      = 10
+	heartbeatTime      = 10 * time.Second
-	httpTimeout        = 3
+	httpTimeout        = 3 * time.Second
-	refreshTime        = 30
+	refreshTime        = 30 * time.Second
 )
 
 type Endpoint struct {
@@ -139,8 +139,8 @@ func NewClient(urls []string, opts ...ClientOption) *Client {
 		urls:              urls,
 		eurekaPath:        "eureka/v2",
 		maxRetry:          len(urls),
-		heartbeatInterval: time.Second * heartbeatTime,
+		heartbeatInterval: heartbeatTime,
-		client:            &http.Client{Transport: tr, Timeout: time.Second * httpTimeout},
+		client:            &http.Client{Transport: tr, Timeout: httpTimeout},
 		keepalive:         make(map[string]chan struct{}),
 	}
 

contrib/registry/eureka/eureka.go

@@ -29,7 +29,7 @@ func NewAPI(ctx context.Context, client *Client, refreshInterval time.Duration)
 	}
 
 	// it is required to broadcast for the first time
-	e.broadcast()
+	go e.broadcast()
 
 	go e.refresh(ctx)
 
@@ -112,6 +112,7 @@ func (e *API) Subscribe(serverName string, fn func()) error {
 		appID:    appID,
 		callBack: fn,
 	}
+	go e.broadcast()
 	return nil
 }