Browse Source

nacos持久化

master
wangjx 3 years ago
parent
commit
b8ac3e899e
1 changed files with 8 additions and 0 deletions
  1. +8
    -0
      sentinel-dashboard/src/main/java/com/alibaba/csp/sentinel/dashboard/discovery/SimpleMachineDiscovery.java

+ 8
- 0
sentinel-dashboard/src/main/java/com/alibaba/csp/sentinel/dashboard/discovery/SimpleMachineDiscovery.java View File

@@ -24,11 +24,13 @@ import java.util.concurrent.ConcurrentMap;


import com.alibaba.csp.sentinel.util.AssertUtil; import com.alibaba.csp.sentinel.util.AssertUtil;


import lombok.extern.log4j.Log4j;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;


/** /**
* @author leyou * @author leyou
*/ */
@Log4j
@Component @Component
public class SimpleMachineDiscovery implements MachineDiscovery { public class SimpleMachineDiscovery implements MachineDiscovery {


@@ -44,6 +46,7 @@ public class SimpleMachineDiscovery implements MachineDiscovery {


@Override @Override
public boolean removeMachine(String app, String ip, int port) { public boolean removeMachine(String app, String ip, int port) {
log.debug("app is " + app);
AssertUtil.assertNotBlank(app, "app name cannot be blank"); AssertUtil.assertNotBlank(app, "app name cannot be blank");
AppInfo appInfo = apps.get(app); AppInfo appInfo = apps.get(app);
if (appInfo != null) { if (appInfo != null) {
@@ -54,17 +57,22 @@ public class SimpleMachineDiscovery implements MachineDiscovery {


@Override @Override
public List<String> getAppNames() { public List<String> getAppNames() {


log.debug("apps.keySet is " + apps.keySet());
return new ArrayList<>(apps.keySet()); return new ArrayList<>(apps.keySet());
} }


@Override @Override
public AppInfo getDetailApp(String app) { public AppInfo getDetailApp(String app) {
log.debug("app is " + app);
AssertUtil.assertNotBlank(app, "app name cannot be blank"); AssertUtil.assertNotBlank(app, "app name cannot be blank");
return apps.get(app); return apps.get(app);
} }


@Override @Override
public Set<AppInfo> getBriefApps() { public Set<AppInfo> getBriefApps() {
log.debug("apps is " + apps.toString());
return new HashSet<>(apps.values()); return new HashSet<>(apps.values());
} }




Loading…
Cancel
Save