如何用Spring Boot Admin记录Actuator健康响应至数据库并获取应用URL？

一、从Spring Boot Admin Server获取应用URL #

当然可以。Spring Boot Admin Server会维护所有已注册应用的元数据，其中就包含你截图里的应用URL（对应实例元数据中的serviceUrl）。你可以通过Admin Server提供的InstanceRepository接口直接获取：

import de.codecentric.boot.admin.server.domain.entities.Instance;
import de.codecentric.boot.admin.server.domain.entities.InstanceRepository;
import org.springframework.stereotype.Component;

@Component
public class InstanceUrlFetcher {
    private final InstanceRepository instanceRepository;

    public InstanceUrlFetcher(InstanceRepository instanceRepository) {
        this.instanceRepository = instanceRepository;
    }

    // 根据实例ID获取应用的服务URL
    public String getServiceUrl(String instanceId) {
        Instance instance = instanceRepository.find(instanceId)
                .orElseThrow(() -> new RuntimeException("目标实例未注册"));
        return instance.getRegistration().getServiceUrl();
    }
}

二、记录/health响应到数据库 #

你可以通过定时任务+RestTemplate结合Admin Server的实例数据，实现定期抓取并存储各应用的/health响应：

1. 基础配置 #

• 在Spring Boot Admin Server的启动类上添加@EnableScheduling，开启定时任务支持
• 注入InstanceRepository（获取所有注册实例）、RestTemplate（发起请求）、自定义的数据库Repository（存储记录）

2. 核心实现代码 #

import de.codecentric.boot.admin.server.domain.entities.Instance;
import de.codecentric.boot.admin.server.domain.entities.InstanceRepository;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import java.time.LocalDateTime;

@Component
public class HealthRecordJob {
    private final InstanceRepository instanceRepository;
    private final RestTemplate restTemplate;
    private final HealthRecordRepository healthRecordRepo; // 自定义JPA Repository

    public HealthRecordJob(InstanceRepository instanceRepository, RestTemplate restTemplate, HealthRecordRepository healthRecordRepo) {
        this.instanceRepository = instanceRepository;
        this.restTemplate = restTemplate;
        this.healthRecordRepo = healthRecordRepo;
    }

    // 每5分钟执行一次，可根据需求修改cron表达式
    @Scheduled(cron = "0 */5 * * * ?")
    public void captureAndSaveHealthStatus() {
        instanceRepository.findAll().forEach(instance -> {
            String healthEndpoint = instance.getRegistration().getServiceUrl() + "/actuator/health";
            try {
                // 抓取健康检查响应
                String healthResponse = restTemplate.getForObject(healthEndpoint, String.class);
                // 构建记录实体并存储
                HealthRecord record = new HealthRecord();
                record.setInstanceId(instance.getId().getValue());
                record.setHealthContent(healthResponse);
                record.setRecordTime(LocalDateTime.now());
                healthRecordRepo.save(record);
            } catch (Exception e) {
                // 处理请求失败场景，比如记录错误日志、标记实例不可达
                e.printStackTrace();
            }
        });
    }
}

3. 数据库实体类示例 #

import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.GenerationType;
import jakarta.persistence.Id;
import java.time.LocalDateTime;

@Entity
public class HealthRecord {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String instanceId; // 对应Admin Server中的实例ID
    private String healthContent; // 存储/health的JSON响应
    private LocalDateTime recordTime; // 记录时间

    // 省略getter、setter方法
}

额外注意事项 #

• 如果目标应用的Actuator接口开启了安全认证，需要在RestTemplate中配置对应的认证信息（比如Basic Auth请求头）
• 除了定时任务，也可以监听Spring Boot Admin的实例状态变更事件（如InstanceRegisteredEvent），在实例上线或状态变化时触发抓取，减少无效请求

内容的提问来源于stack exchange，提问作者Valentine Ezerins