watch add createSignRequest

Author: chengyouling

clients/service-center-client/src/main/java/org/apache/servicecomb/service/center/client/ServiceCenterWatch.java

@@ -17,12 +17,14 @@
 
 package org.apache.servicecomb.service.center.client;
 
+import java.net.URI;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.atomic.AtomicBoolean;
 
+import org.apache.servicecomb.foundation.auth.SignRequest;
 import org.apache.servicecomb.http.client.auth.RequestAuthHeaderProvider;
 import org.apache.servicecomb.http.client.common.HttpConfiguration.SSLProperties;
 import org.apache.servicecomb.http.client.common.WebSocketListener;
@@ -107,7 +109,7 @@ private void startWatch() {
         Map<String, String> headers = new HashMap<>();
         headers.put("x-domain-name", this.tenantName);
         headers.putAll(this.extraGlobalHeaders);
-        headers.putAll(this.requestAuthHeaderProvider.loadAuthHeader(null));
+        headers.putAll(this.requestAuthHeaderProvider.loadAuthHeader(createSignRequest(address)));
         currentServerUri = convertAddress(address);
         LOGGER.info("start watch to address {}", currentServerUri);
         webSocketTransport = new WebSocketTransport(currentServerUri, sslProperties,
@@ -121,6 +123,17 @@ private void startWatch() {
     });
   }
 
+  private SignRequest createSignRequest(String url) {
+    try {
+      URI uri = URI.create(url);
+      SignRequest signRequest = new SignRequest();
+      signRequest.setEndpoint(uri);
+      return signRequest;
+    } catch (Exception e) {
+      return null;
+    }
+  }
+
   private String convertAddress(String address) {
     String url = String.format(WATCH, project, serviceId);
     if (address.startsWith(HTTP)) {