Procházet zdrojové kódy

nacos持久化

master
wangjx před 3 roky
rodič
revize
398c31727f
1 změnil soubory, kde provedl 10 přidání a 6 odebrání
  1. +10
    -6
      sentinel-dashboard/src/main/java/com/alibaba/csp/sentinel/dashboard/discovery/SimpleMachineDiscovery.java

+ 10
- 6
sentinel-dashboard/src/main/java/com/alibaba/csp/sentinel/dashboard/discovery/SimpleMachineDiscovery.java Zobrazit soubor

@@ -24,16 +24,20 @@ import java.util.concurrent.ConcurrentMap;

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

import lombok.extern.log4j.Log4j;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

@Autowired
private static Logger logger = LoggerFactory.getLogger(SimpleMachineDiscovery.class);
private final ConcurrentMap<String, AppInfo> apps = new ConcurrentHashMap<>();

@Override
@@ -46,7 +50,7 @@ public class SimpleMachineDiscovery implements MachineDiscovery {

@Override
public boolean removeMachine(String app, String ip, int port) {
log.debug("app is " + app);
logger.info("app is " + app);
AssertUtil.assertNotBlank(app, "app name cannot be blank");
AppInfo appInfo = apps.get(app);
if (appInfo != null) {
@@ -59,20 +63,20 @@ public class SimpleMachineDiscovery implements MachineDiscovery {
public List<String> getAppNames() {


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

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

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



Načítá se…
Zrušit
Uložit