| | |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import reactor.core.publisher.Mono; |
|---|
| | | |
|---|
| | | import static de.codecentric.boot.admin.server.domain.values.StatusInfo.*; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 自定义事件通知处理 |
|---|
| | | * |
|---|
| | |
|---|
| | | return Mono.fromRunnable(() -> { |
|---|
| | | // 实例状态改变事件 |
|---|
| | | if (event instanceof InstanceStatusChangedEvent) { |
|---|
| | | // 获取实例注册名称 |
|---|
| | | String registName = instance.getRegistration().getName(); |
|---|
| | | // 获取实例ID |
|---|
| | | String instanceId = event.getInstance().getValue(); |
|---|
| | | // 获取实例状态 |
|---|
| | | 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); |
|---|
| | | } |
|---|
| | | |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
