健康检查

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/IHealthCheckService.java

@@ -0,0 +1,6 @@
+package cn.com.ctop.job.bytedance.data.service;
+
+public interface IHealthCheckService {
+
+    void check() throws Exception;
+}

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/HealthCheckServiceImpl.java

@@ -0,0 +1,46 @@
+package cn.com.ctop.job.bytedance.data.service.impl;
+
+import cn.com.ctop.job.bytedance.data.service.IHealthCheckService;
+import cn.com.ctop.job.bytedance.data.utils.HttpUtils;
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.stereotype.Service;
+
+import java.util.Arrays;
+import java.util.List;
+
+@Service
+public class HealthCheckServiceImpl implements IHealthCheckService {
+
+    public static final String FS_HOOK_URL = "https://open.feishu.cn/open-apis/bot/v2/hook/a0fcfb57-c053-47bd-b1e7-b826f44841e4";
+
+    @Override
+    public void check() throws Exception {
+
+        List<String> ips = Arrays.asList(
+//                "192.168.1.33"//localhost
+                "123.57.9.211"//test
+        );
+
+        for (int i = 0; i < 10; i++) {
+            for (String ip : ips) {
+                String url = "http://" + ip + ":9002/actuator/health";
+                System.out.println(url);
+                try {
+                    String res = HttpUtils.httpGet(url, null, null);
+                    JSONObject obj = JSONObject.parseObject(res);
+                    String status = obj.getString("status");
+                    if (!"UP".equals(status)) {
+                        System.out.println("Health check failed for " + ip + ": " + status);
+                    } else {
+                        System.out.println("Health check passed for " + ip);
+                    }
+                }catch (Exception e) {
+                    System.out.println("Health check failed for " + ip + ": " + e.getMessage());
+                }
+            }
+            Thread.sleep(3000);
+        }
+    }
+
+
+}