update 优化Monitor监控服务信息事件通知

AprilWind

2024-07-25 e74f0ca6f8af892b707f1504cfd1913461191885

update 优化Monitor监控服务信息事件通知

 ruoyi-extend/ruoyi-monitor-admin/pom.xml

@@ -39,6 +39,11 @@
            <artifactId>lombok</artifactId>
        </dependency>

        <dependency>
            <groupId>org.dromara</groupId>
            <artifactId>ruoyi-common-core</artifactId>
        </dependency>

    </dependencies>

    <build>

 ruoyi-extend/ruoyi-monitor-admin/src/main/java/org/dromara/monitor/admin/event/NotifierEvent.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,44 @@
package org.dromara.monitor.admin.event;

import lombok.Data;

import java.io.Serial;
import java.io.Serializable;

/**
 * é€šçŸ¥äº‹ä»¶
 *
 * @author AprilWind
 */
@Data
public class NotifierEvent implements Serializable {

    @Serial
    private static final long serialVersionUID = 1L;

    /**
     * å®žä¾‹æ³¨å†Œåç§°
     */
    private String registName;

    /**
     * å®žä¾‹çŠ¶æ€åç§°
     */
    private String statusName;

    /**
     * å®žä¾‹ID
     */
    private String instanceId;

    /**
     * å®žä¾‹çŠ¶æ€
     */
    private String status;

    /**
     * æœåŠ¡URL
     */
    private String serviceUrl;

}

 ruoyi-extend/ruoyi-monitor-admin/src/main/java/org/dromara/monitor/admin/notifier/CustomNotifier.java

@@ -6,6 +6,8 @@
import de.codecentric.boot.admin.server.domain.events.InstanceStatusChangedEvent;
import de.codecentric.boot.admin.server.notify.AbstractEventNotifier;
import lombok.extern.slf4j.Slf4j;
import org.dromara.common.core.utils.SpringUtils;
import org.dromara.monitor.admin.event.NotifierEvent;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Mono;

@@ -38,46 +40,24 @@
                String status = ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus();
                // èŽ·å–服务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;
                }
                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);
                NotifierEvent notifier = new NotifierEvent();
                notifier.setRegistName(registName);
                notifier.setStatusName(statusName);
                notifier.setInstanceId(instanceId);
                notifier.setStatus(status);
                notifier.setServiceUrl(serviceUrl);
                SpringUtils.context().publishEvent(notifier);
            }
        });
    }

 ruoyi-extend/ruoyi-monitor-admin/src/main/java/org/dromara/monitor/admin/notifier/InfoNotifier.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,34 @@
package org.dromara.monitor.admin.notifier;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.dromara.monitor.admin.event.NotifierEvent;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

/**
 * ä¿¡æ¯é€šçŸ¥
 *
 * @author AprilWind
 */
@RequiredArgsConstructor
@Slf4j
@Service
public class InfoNotifier {

    /**
     * å¼‚步处理通知事件的方法
     * <p>
     * è¯¥æ–¹æ³•ä¼šå¤„理 `NotifierEvent` äº‹ä»¶ï¼Œæ‰§è¡Œé€šçŸ¥ç›¸å…³çš„操作，如发送邮件或短信
     *
     * @param notifier äº‹ä»¶å¯¹è±¡ï¼ŒåŒ…含了需要通知的详细信息，包括注册名称、状态名称、实例 ID、状态和服务 URL
     */
    @Async
    @EventListener
    public void infoNotification(NotifierEvent notifier) {
        // åœ¨è¿™é‡Œæ·»åŠ å¤„理通知事件的逻辑
        // ä¾‹å¦‚，依据 notifier å¯¹è±¡çš„信息发送邮件或短信通知
    }

}