!613 refactor 优化代码 * update 优化代码

DoubleH

2024-12-12 dd17246086672c9571994a062735453fb8356cd2

 ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterManager.java

@@ -67,7 +67,9 @@
        Map<String, SseEmitter> emitters = USER_TOKEN_EMITTERS.get(userId);
        if (emitters != null) {
            try {
                emitters.get(token).send(SseEmitter.event().comment("disconnected"));
                SseEmitter sseEmitter = emitters.get(token);
                sseEmitter.send(SseEmitter.event().comment("disconnected"));
                sseEmitter.complete();
            } catch (Exception ignore) {
            }
            emitters.remove(token);
@@ -124,10 +126,10 @@
        SseMessageDto broadcastMessage = new SseMessageDto();
        broadcastMessage.setMessage(sseMessageDto.getMessage());
        broadcastMessage.setUserIds(sseMessageDto.getUserIds());
        RedisUtils.publish(SSE_TOPIC, broadcastMessage, consumer -> {
        RedisUtils.publish(SSE_TOPIC, broadcastMessage, consumer ->
            log.info("SSE发送主题订阅消息topic:{} session keys:{} message:{}",
                SSE_TOPIC, sseMessageDto.getUserIds(), sseMessageDto.getMessage());
        });
            SSE_TOPIC, sseMessageDto.getUserIds(), sseMessageDto.getMessage())
        );
    }

    /**
@@ -138,8 +140,8 @@
    public void publishAll(String message) {
        SseMessageDto broadcastMessage = new SseMessageDto();
        broadcastMessage.setMessage(message);
        RedisUtils.publish(SSE_TOPIC, broadcastMessage, consumer -> {
            log.info("SSE发送主题订阅消息topic:{} message:{}", SSE_TOPIC, message);
        });
        RedisUtils.publish(SSE_TOPIC, broadcastMessage, consumer ->
            log.info("SSE发送主题订阅消息topic:{} message:{}", SSE_TOPIC, message)
        );
    }
}