From 8dc3482deec2f25a0618f7ae1f62a1ce07116d7a Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期三, 09 八月 2023 13:52:18 +0800
Subject: [PATCH] 1
---
src/main/java/com/moon/server/service/all/ScheduleService.java | 12 +++++++-----
src/main/java/com/moon/server/config/ScheduleConfig.java | 23 -----------------------
2 files changed, 7 insertions(+), 28 deletions(-)
diff --git a/src/main/java/com/moon/server/config/ScheduleConfig.java b/src/main/java/com/moon/server/config/ScheduleConfig.java
index 4b67724..4081942 100644
--- a/src/main/java/com/moon/server/config/ScheduleConfig.java
+++ b/src/main/java/com/moon/server/config/ScheduleConfig.java
@@ -91,27 +91,4 @@
log.error(ex.getMessage(), ex);
}
}
-
- /**
- * 鍚屾闄勪欢
- */
- @Scheduled(fixedRate = 30 * 1000)
- public void syncAttaches() {
- try {
- List<FmeLogEntity> list = attachService.selectFmeLogs();
- if (isBusy || null == list || list.isEmpty()) {
- return;
- }
-
- isBusy = true;
- for (FmeLogEntity entity : list) {
- attachService.syncAttaches(entity);
- attachService.updateFmeLog(entity.getId());
- }
- isBusy = false;
- } catch (Exception ex) {
- isBusy = false;
- log.error(ex.getMessage(), ex);
- }
- }
}
diff --git a/src/main/java/com/moon/server/service/all/ScheduleService.java b/src/main/java/com/moon/server/service/all/ScheduleService.java
index 9c44f53..4703e28 100644
--- a/src/main/java/com/moon/server/service/all/ScheduleService.java
+++ b/src/main/java/com/moon/server/service/all/ScheduleService.java
@@ -140,7 +140,6 @@
/**
* 缁熻鍦ㄧ嚎鐢ㄦ埛鏁�
- * @return
*/
public int countOnlineUsers() {
Set<String> keys = redisTemplate.keys(RedisCacheKey.signUserKey("*"));
@@ -157,23 +156,26 @@
return testResStatus(resList);
}
+ /**
+ * 娴嬭瘯璧勬簮鐘舵��
+ */
private List<ResEntity> testResStatus(List<ResEntity> resList) {
- List<ResEntity> list = new ArrayList<ResEntity>();
+ List<ResEntity> list = new ArrayList<>();
for (ResEntity re : resList) {
Socket socket = new Socket();
try {
- if (StringHelper.isEmpty(re.getTest())) {
+ if (StringHelper.isEmpty(re.getUrl())) {
list.add(re);
continue;
}
- URI uri = new URI(re.getTest());
+ URI uri = new URI(re.getUrl());
SocketAddress add = new InetSocketAddress(uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());
// Ping閫氬湴鍧�
socket.connect(add, 2000);
} catch (Exception e) {
- log.error(e.getMessage());
+ // log.error(e.getMessage())
list.add(re);
} finally {
try {
--
Gitblit v1.9.3