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 +++++++-----
1 files changed, 7 insertions(+), 5 deletions(-)
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