zhuyijun/nacos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

listener bugfix (#5079)

Browse Source
This commit is contained in:
nov.lzf 2021-03-12 10:30:52 +08:00 committed by GitHub
parent 711afc7bac
commit 481d25a6c7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
config/src/main/java/com/alibaba/nacos/config/server/controller/CommunicationController.java
View File

@ -16,6 +16,7 @@
package com.alibaba.nacos.config.server.controller;
import com.alibaba.nacos.common.utils.CollectionUtils;
import com.alibaba.nacos.config.server.constant.Constants;
import com.alibaba.nacos.config.server.model.SampleResult;
import com.alibaba.nacos.config.server.remote.ConfigChangeListenContext;
@ -102,18 +103,20 @@ public class CommunicationController {
// rpc listeners.
String groupKey = GroupKey2.getKey(dataId, group, tenant);
Set<String> listenersClients = configChangeListenContext.getListeners(groupKey);
SampleResult rpcSample = new SampleResult();
Map<String, String> lisentersGroupkeyStatus = new HashMap<String, String>(listenersClients.size(), 1);
for (String connectionId : listenersClients) {
Connection client = connectionManager.getConnection(connectionId);
if (client != null) {
String md5 = configChangeListenContext.getListenKeyMd5(connectionId, groupKey);
if (md5 != null) {
lisentersGroupkeyStatus.put(client.getMetaInfo().getClientIp(), md5);
if (CollectionUtils.isNotEmpty(listenersClients)) {
Map<String, String> lisentersGroupkeyStatus = new HashMap<String, String>(listenersClients.size(), 1);
for (String connectionId : listenersClients) {
Connection client = connectionManager.getConnection(connectionId);
if (client != null) {
String md5 = configChangeListenContext.getListenKeyMd5(connectionId, groupKey);
if (md5 != null) {
lisentersGroupkeyStatus.put(client.getMetaInfo().getClientIp(), md5);
}
}
}
result.getLisentersGroupkeyStatus().putAll(lisentersGroupkeyStatus);
}
result.getLisentersGroupkeyStatus().putAll(lisentersGroupkeyStatus);
return result;
}
@ -136,5 +139,5 @@ public class CommunicationController {
return result;
}
}