springboot-admin3.1.x监控服务器端

package org.yxt.monitor.config; import de.codecentric.boot.admin.server.domain.entities.Instance; import de.codecentric.boot.admin.server.domain.entities.InstanceRepository; import de.codecentric.boot.admin.server.domain.events.InstanceEvent; import de.codecentric.boot.admin.server.notify.AbstractStatusChangeNotifier; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import reactor.core.publisher.Mono; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Map; /** * 自定义配置监控预警消息推送 * * @author Yang douya * @date 2023/6/29 14:36 */ @Slf4j @Component public class WarnNotifier extends AbstractStatusChangeNotifier { public WarnNotifier(InstanceRepository repository) { super(repository); } @Override protected Mono<Void> doNotify(InstanceEvent event, Instance instance) { // 服务名 String serviceName = instance.getRegistration().getName(); // 服务url String serviceUrl = instance.getRegistration().getServiceUrl(); // 服务状态 String status = instance.getStatusInfo().getStatus(); // 详情 Map<String, Object> details = instance.getStatusInfo().getDetails(); // 当前服务掉线时间 Date date = new Date(); SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String format = simpleDateFormat.format(date); // 拼接短信内容 StringBuilder str = new StringBuilder(); str.append("服务名：【" + serviceName + "】 \r\n"); str.append("服务状态：【" + status + "】 \r\n"); str.append("地址：【" + serviceUrl + "】\r\n"); str.append("时间：" + format + "\r\n"); /** switch (status) { case "DOWN": System.out.println("健康检查没通过！"); break; case "OFFLINE": System.out.println("服务离线！"); break; case "UP": System.out.println("服务上线！"); break; case "UNKNOWN": System.out.println("服务未知异常！"); break; default: System.out.println(status); break; } **/ return Mono.fromRunnable(() -> { // 这里写你服务发生改变时，要提醒的方法 // 如服务掉线了，就发送短信告知 log.info("应用状态变化消息通知 {}", str.toString()); }); } }