|
|
@ -4,14 +4,13 @@ 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.entities.InstanceRepository;
|
|
|
|
import de.codecentric.boot.admin.server.domain.events.InstanceEvent;
|
|
|
|
import de.codecentric.boot.admin.server.domain.events.InstanceEvent;
|
|
|
|
import de.codecentric.boot.admin.server.domain.events.InstanceStatusChangedEvent;
|
|
|
|
import de.codecentric.boot.admin.server.domain.events.InstanceStatusChangedEvent;
|
|
|
|
import de.codecentric.boot.admin.server.domain.values.InstanceId;
|
|
|
|
|
|
|
|
import de.codecentric.boot.admin.server.notify.AbstractEventNotifier;
|
|
|
|
import de.codecentric.boot.admin.server.notify.AbstractEventNotifier;
|
|
|
|
import io.micrometer.core.lang.NonNullApi;
|
|
|
|
|
|
|
|
import lombok.NonNull;
|
|
|
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
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.*;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 自定义事件通知处理
|
|
|
|
* 自定义事件通知处理
|
|
|
|
*
|
|
|
|
*
|
|
|
@ -31,10 +30,25 @@ 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 = switch (status) {
|
|
|
|
|
|
|
|
case STATUS_UP -> "服务上线"; // 实例成功启动并可以正常处理请求
|
|
|
|
|
|
|
|
case STATUS_OFFLINE -> "服务离线"; //实例被手动或自动地从服务中移除
|
|
|
|
|
|
|
|
case STATUS_RESTRICTED -> "服务受限"; //表示实例在某些方面受限,可能无法完全提供所有服务
|
|
|
|
|
|
|
|
case STATUS_OUT_OF_SERVICE -> "停止服务状态"; //表示实例已被标记为停止提供服务,可能是计划内维护或测试
|
|
|
|
|
|
|
|
case STATUS_DOWN -> "服务下线"; //实例因崩溃、错误或其他原因停止运行
|
|
|
|
|
|
|
|
case STATUS_UNKNOWN -> "服务未知异常"; //监控系统无法确定实例的当前状态
|
|
|
|
|
|
|
|
default -> "未知状态"; //没有匹配的状态
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
log.info("Instance Status Change: 状态名称【{}】, 注册名称【{}】, 实例ID【{}】, 状态【{}】, 服务URL【{}】",
|
|
|
|
|
|
|
|
statusName, registName, instanceId, status, serviceUrl);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
});
|
|
|
|
});
|
|
|
|