疯狂的狮子Li
2024-07-26 51edb74474faf186367b867cc1b6ad3e76ff03bd
fix 修复 后端发消息发送失败无限重试问题
已修改2个文件
5 ■■■■■ 文件已修改
ruoyi-admin/src/main/java/org/dromara/web/controller/AuthController.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterManager.java 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruoyi-admin/src/main/java/org/dromara/web/controller/AuthController.java
@@ -106,7 +106,7 @@
            dto.setMessage("欢迎登录RuoYi-Vue-Plus后台管理系统");
            dto.setUserIds(List.of(userId));
            SseMessageUtils.publishMessage(dto);
        }, 20, TimeUnit.SECONDS);
        }, 5, TimeUnit.SECONDS);
        return R.ok(loginVo);
    }
ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterManager.java
@@ -30,6 +30,7 @@
        emitter.onCompletion(() -> emitters.remove(token));
        emitter.onTimeout(() -> emitters.remove(token));
        emitter.onError((e) -> emitters.remove(token));
        try {
            emitter.send(SseEmitter.event().comment("connected"));
@@ -72,7 +73,7 @@
                try {
                    entry.getValue().send(SseEmitter.event()
                        .name("message")
                        .reconnectTime(10000L)
                        .reconnectTime(-1L)
                        .data(message));
                } catch (Exception e) {
                    emitters.remove(entry.getKey());