watcher connectid four tuple

sofastack · Aug 23, 2020 · c3b4e09 · c3b4e09
1 parent 3edbbcc
commit c3b4e09
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...va/com/alipay/sofa/registry/server/session/scheduler/task/ProvideDataChangeFetchTask.java b/...va/com/alipay/sofa/registry/server/session/scheduler/task/ProvideDataChangeFetchTask.java
@@ -16,6 +16,7 @@
  */
 package com.alipay.sofa.registry.server.session.scheduler.task;
 
+import com.alipay.sofa.registry.common.model.constants.ValueConstants;
 import com.alipay.sofa.registry.common.model.metaserver.DataOperator;
 import com.alipay.sofa.registry.common.model.metaserver.NotifyProvideDataChange;
 import com.alipay.sofa.registry.common.model.metaserver.ProvideData;
@@ -126,7 +127,7 @@ public void execute() {
             for (Channel channel : sessionServer.getChannels()) {
 
                 //filter all connect client has watcher registerId
-                String connectId = NetUtil.toAddressString(channel.getRemoteAddress());
+                String connectId = NetUtil.toAddressString(channel.getRemoteAddress()) + ValueConstants.CONNECT_ID_SPLIT + NetUtil.toAddressString(channel.getLocalAddress());
                 Map<String, Watcher> map = getCache(connectId);
                 List<String> registerIds = new ArrayList<>();
                 map.forEach((registerId, watchers) -> {