| | |
| | | dto.setMessage("欢迎登录RuoYi-Vue-Plus后台管理系统"); |
| | | dto.setUserIds(List.of(userId)); |
| | | SseMessageUtils.publishMessage(dto); |
| | | }, 20, TimeUnit.SECONDS); |
| | | }, 5, TimeUnit.SECONDS); |
| | | return R.ok(loginVo); |
| | | } |
| | | |
| | |
| | | |
| | | emitter.onCompletion(() -> emitters.remove(token)); |
| | | emitter.onTimeout(() -> emitters.remove(token)); |
| | | emitter.onError((e) -> emitters.remove(token)); |
| | | |
| | | try { |
| | | emitter.send(SseEmitter.event().comment("connected")); |
| | |
| | | try { |
| | | entry.getValue().send(SseEmitter.event() |
| | | .name("message") |
| | | .reconnectTime(10000L) |
| | | .reconnectTime(-1L) |
| | | .data(message)); |
| | | } catch (Exception e) { |
| | | emitters.remove(entry.getKey()); |