ziin/TKDataSave
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.在每一次Sse发消息前发送 Start

Browse Source
This commit is contained in:
Ziin
2025-07-28 19:20:11 +08:00
parent 097145dfc6
commit a7a17667e4
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java
View File

@@ -61,6 +61,8 @@ public class HostInfoServiceImpl extends ServiceImpl<NewHostsMapper, NewHosts> i
NewHosts sseConnectConfirmInfo = newHosts.get(0); NewHosts sseConnectConfirmInfo = newHosts.get(0);
SseEmitter sseEmitter = SseEmitterUtil.getSseEmitter(sseConnectConfirmInfo.getTenantId().toString() + "-" + sseConnectConfirmInfo.getUserId().toString()); SseEmitter sseEmitter = SseEmitterUtil.getSseEmitter(sseConnectConfirmInfo.getTenantId().toString() + "-" + sseConnectConfirmInfo.getUserId().toString());
if (sseEmitter != null) { if (sseEmitter != null) {
NewHosts forChannelInfo = newHosts.get(0);
SseEmitterUtil.sendMessage(forChannelInfo.getTenantId().toString()+"-"+forChannelInfo.getUserId().toString(),"start");
newHosts.forEach(newHost -> { newHosts.forEach(newHost -> {
SseEmitterUtil.sendMessage(newHost.getTenantId().toString()+"-"+newHost.getUserId().toString(), SseEmitterUtil.sendMessage(newHost.getTenantId().toString()+"-"+newHost.getUserId().toString(),
JsonUtils.toJsonString(newHost)); JsonUtils.toJsonString(newHost));