From 408d6dcac976193ef0da37df6fa7fe6f623287d0 Mon Sep 17 00:00:00 2001
From: AprilWind <2100166581@qq.com>
Date: Thu, 25 Jul 2024 11:16:34 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E4=BC=98=E5=8C=96Monitor=E7=9B=91?=
=?UTF-8?q?=E6=8E=A7=E6=9C=8D=E5=8A=A1=E9=80=9A=E7=9F=A5=E5=88=86=E7=B1=BB?=
=?UTF-8?q?=E6=89=93=E5=8D=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../monitor/notifier/CustomNotifier.java | 22 +++++++++++++++----
1 file changed, 18 insertions(+), 4 deletions(-)
diff --git a/ruoyi-visual/ruoyi-monitor/src/main/java/org/dromara/modules/monitor/notifier/CustomNotifier.java b/ruoyi-visual/ruoyi-monitor/src/main/java/org/dromara/modules/monitor/notifier/CustomNotifier.java
index 165e28e7..4bae134d 100644
--- a/ruoyi-visual/ruoyi-monitor/src/main/java/org/dromara/modules/monitor/notifier/CustomNotifier.java
+++ b/ruoyi-visual/ruoyi-monitor/src/main/java/org/dromara/modules/monitor/notifier/CustomNotifier.java
@@ -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.events.InstanceEvent;
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 io.micrometer.core.lang.NonNullApi;
-import lombok.NonNull;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
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(() -> {
// 实例状态改变事件
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);
}
});