修改代码

ace-control/ace-monitor/pom.xml

@@ -28,8 +28,8 @@
         </dependency>
 
         <!--<dependency>-->
-            <!--<groupId>org.springframework.cloud</groupId>-->
-            <!--<artifactId>spring-cloud-starter-consul-all</artifactId>-->
+        <!--<groupId>org.springframework.cloud</groupId>-->
+        <!--<artifactId>spring-cloud-starter-consul-all</artifactId>-->
         <!--</dependency>-->
         <dependency>
             <groupId>org.springframework.cloud</groupId>

ace-control/ace-monitor/src/main/java/com/github/wxiaoqi/security/monitor/config/NacosWatch.java

@@ -39,85 +39,85 @@ import java.util.concurrent.atomic.AtomicLong;
  */
 public class NacosWatch implements ApplicationEventPublisherAware, SmartLifecycle {
 
-	private static final Logger log = LoggerFactory.getLogger(NacosWatch.class);
+    private static final Logger log = LoggerFactory.getLogger(NacosWatch.class);
 
-	private final NacosDiscoveryProperties properties;
-	private long watchDelay = 30000;
-	private final TaskScheduler taskScheduler;
+    private final NacosDiscoveryProperties properties;
+    private long watchDelay = 30000;
+    private final TaskScheduler taskScheduler;
 
-	private final AtomicLong nacosWatchIndex = new AtomicLong(0);
+    private final AtomicLong nacosWatchIndex = new AtomicLong(0);
 
-	private final AtomicBoolean running = new AtomicBoolean(false);
+    private final AtomicBoolean running = new AtomicBoolean(false);
 
-	private ApplicationEventPublisher publisher;
+    private ApplicationEventPublisher publisher;
 
-	private ScheduledFuture<?> watchFuture;
+    private ScheduledFuture<?> watchFuture;
 
-	private Set<String> cacheServices = new HashSet<>();
+    private Set<String> cacheServices = new HashSet<>();
 
-	private HashMap<String, EventListener> subscribeListeners = new HashMap<>();
+    private HashMap<String, EventListener> subscribeListeners = new HashMap<>();
 
-	public NacosWatch(NacosDiscoveryProperties properties) {
-		this(properties, getTaskScheduler());
-	}
+    public NacosWatch(NacosDiscoveryProperties properties) {
+        this(properties, getTaskScheduler());
+    }
 
-	public NacosWatch(NacosDiscoveryProperties properties, TaskScheduler taskScheduler) {
-		this.properties = properties;
-		this.taskScheduler = taskScheduler;
-	}
+    public NacosWatch(NacosDiscoveryProperties properties, TaskScheduler taskScheduler) {
+        this.properties = properties;
+        this.taskScheduler = taskScheduler;
+    }
 
-	private static ThreadPoolTaskScheduler getTaskScheduler() {
-		ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
-		taskScheduler.initialize();
-		return taskScheduler;
-	}
+    private static ThreadPoolTaskScheduler getTaskScheduler() {
+        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
+        taskScheduler.initialize();
+        return taskScheduler;
+    }
 
-	@Override
-	public void setApplicationEventPublisher(ApplicationEventPublisher publisher) {
-		this.publisher = publisher;
-	}
+    @Override
+    public void setApplicationEventPublisher(ApplicationEventPublisher publisher) {
+        this.publisher = publisher;
+    }
 
-	@Override
-	public boolean isAutoStartup() {
-		return true;
-	}
+    @Override
+    public boolean isAutoStartup() {
+        return true;
+    }
 
-	@Override
-	public void stop(Runnable callback) {
-		this.stop();
-		callback.run();
-	}
+    @Override
+    public void stop(Runnable callback) {
+        this.stop();
+        callback.run();
+    }
 
-	@Override
-	public void start() {
-		if (this.running.compareAndSet(false, true)) {
-			this.watchFuture = this.taskScheduler.scheduleWithFixedDelay(
-					this::nacosServicesWatch, watchDelay);
-		}
-	}
+    @Override
+    public void start() {
+        if (this.running.compareAndSet(false, true)) {
+            this.watchFuture = this.taskScheduler.scheduleWithFixedDelay(
+                    this::nacosServicesWatch, watchDelay);
+        }
+    }
 
-	@Override
-	public void stop() {
-		if (this.running.compareAndSet(true, false) && this.watchFuture != null) {
-			this.watchFuture.cancel(true);
-		}
-	}
+    @Override
+    public void stop() {
+        if (this.running.compareAndSet(true, false) && this.watchFuture != null) {
+            this.watchFuture.cancel(true);
+        }
+    }
 
-	@Override
-	public boolean isRunning() {
-		return false;
-	}
+    @Override
+    public boolean isRunning() {
+        return false;
+    }
 
-	@Override
-	public int getPhase() {
-		return 0;
-	}
+    @Override
+    public int getPhase() {
+        return 0;
+    }
 
-	public void nacosServicesWatch() {
+    public void nacosServicesWatch() {
 
-		// nacos doesn't support watch now , publish an event every 30 seconds.
-		this.publisher.publishEvent(
-				new HeartbeatEvent(this, nacosWatchIndex.getAndIncrement()));
+        // nacos doesn't support watch now , publish an event every 30 seconds.
+        this.publisher.publishEvent(
+                new HeartbeatEvent(this, nacosWatchIndex.getAndIncrement()));
 
-	}
+    }
 }

ace-control/ace-monitor/src/main/java/com/github/wxiaoqi/security/monitor/config/NacosWatchAutoConfiguration.java

@@ -8,11 +8,11 @@ import org.springframework.context.annotation.Configuration;
 
 @Configuration
 public class NacosWatchAutoConfiguration {
- 
-	@Bean
-	@ConditionalOnMissingBean
-	@ConditionalOnProperty(value = "spring.cloud.nacos.discovery.watch.enabled", matchIfMissing = true)
-	public NacosWatch nacosWatch(NacosDiscoveryProperties nacosDiscoveryProperties) {
-		return new NacosWatch(nacosDiscoveryProperties);
-	}
+
+    @Bean
+    @ConditionalOnMissingBean
+    @ConditionalOnProperty(value = "spring.cloud.nacos.discovery.watch.enabled", matchIfMissing = true)
+    public NacosWatch nacosWatch(NacosDiscoveryProperties nacosDiscoveryProperties) {
+        return new NacosWatch(nacosDiscoveryProperties);
+    }
 }
\ No newline at end of file

ace-control/ace-monitor/src/main/resources/application.yml

 spring:
-    application:
-        name: ace-monitor
-    cloud:
-      nacos:
-        discovery:
-          server-addr: 127.0.0.1:8848
+  application:
+    name: ace-monitor
+  cloud:
+    nacos:
+      discovery:
+        server-addr: 127.0.0.1:8848
 
 server:
-    port: 8764 #启动端口
+  port: 8764 #启动端口
 #
 #eureka:
 #     instance: