如何在spring boot中发送请求之前检查端点的连接性

import org.springframework.boot.actuate.health.Health;
import org.springframework.boot.actuate.health.HealthIndicator;
import org.springframework.stereotype.Component;

@Component
public class EndpointHealthIndicator implements HealthIndicator {

    @Override
    public Health health() {
        // 在这里编写检查端点连接性的逻辑
        // 如果连接正常，返回Health.up().build()
        // 如果连接失败，返回Health.down().build()
    }
}

import org.springframework.boot.actuate.health.Health;
import org.springframework.boot.actuate.health.HealthIndicator;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.URL;

@Component
public class EndpointHealthIndicator implements HealthIndicator {

    @Override
    public Health health() {
        try {
            URL url = new URL("http://example.com"); // 替换为要检查的端点URL
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            connection.setRequestMethod("GET");
            int responseCode = connection.getResponseCode();
            if (responseCode == 200) {
                return Health.up().build();
            } else {
                return Health.down().withDetail("Response Code", responseCode).build();
            }
        } catch (IOException e) {
            return Health.down(e).build();
        }
    }
}

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

import org.springframework.boot.actuate.health.Health;
import org.springframework.boot.actuate.health.HealthIndicator;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.URL;

@Component
public class EndpointHealthIndicator implements HealthIndicator {

    @Override
    public Health health() {
        // 省略健康检查逻辑
    }

    @Scheduled(fixedRate = 5000) // 每隔5秒执行一次健康检查
    public void checkHealth() {
        Health health = health();
        if (health.getStatus().equals(Status.DOWN)) {
            // 发送警报通知
        }
    }
}