update 优化Monitor监控服务通知分类(可扩展邮箱发送,短信发送)

This commit is contained in:
AprilWind 2024-07-25 10:00:10 +08:00
parent 105c007f03
commit 52b0fa9a54

View File

@ -9,6 +9,8 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
import static de.codecentric.boot.admin.server.domain.values.StatusInfo.*;
/** /**
* 自定义事件通知处理 * 自定义事件通知处理
* *
@ -28,13 +30,55 @@ public class CustomNotifier extends AbstractEventNotifier {
return Mono.fromRunnable(() -> { return Mono.fromRunnable(() -> {
// 实例状态改变事件 // 实例状态改变事件
if (event instanceof InstanceStatusChangedEvent) { if (event instanceof InstanceStatusChangedEvent) {
// 获取实例注册名称
String registName = instance.getRegistration().getName(); String registName = instance.getRegistration().getName();
// 获取实例ID
String instanceId = event.getInstance().getValue(); String instanceId = event.getInstance().getValue();
// 获取实例状态
String status = ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus(); String status = ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus();
log.info("Instance Status Change: [{}],[{}],[{}]", registName, instanceId, status); // 获取服务URL
} String serviceUrl = instance.getRegistration().getServiceUrl();
String statusName = null;
// 根据实例状态执行相应的操作
switch (status) {
// 服务上线实例成功启动并可以正常处理请求
case STATUS_UP:
statusName = "服务上线";
break;
// 服务离线实例被手动或自动地从服务中移除
case STATUS_OFFLINE:
statusName = "服务离线";
break;
// 服务受限表示实例在某些方面受限可能无法完全提供所有服务
case STATUS_RESTRICTED:
statusName = "服务受限";
break;
// 停止服务状态表示实例已被标记为停止提供服务可能是计划内维护或测试
case STATUS_OUT_OF_SERVICE:
statusName = "停止服务状态";
break;
// 服务下线实例因崩溃错误或其他原因停止运行
case STATUS_DOWN:
statusName = "服务下线";
break;
// 服务未知异常监控系统无法确定实例的当前状态
case STATUS_UNKNOWN:
statusName = "服务未知异常";
break;
// 默认情况没有匹配的状态
default:
break;
}
log.info("Instance Status Change: 状态名称【{}】, 注册名称【{}】, 实例ID【{}】, 状态【{}】, 服务URL【{}】",
statusName, registName, instanceId, status, serviceUrl);
}
}); });
} }
} }