sxc/Vetti-Service-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

websocket 生成完整的文件

Browse Source
This commit is contained in:
wangxiangshun
2025-10-05 13:11:24 +08:00
parent 54053728ab
commit ab7213e4ab
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
vetti-admin/src/main/java/com/vetti/socket/VoiceWebSocketHandler.java
View File

@@ -3,6 +3,7 @@ package com.vetti.socket;
import com.vetti.socket.vo.FileMetadata; import com.vetti.socket.vo.FileMetadata;
import com.vetti.socket.vo.FileTransferState; import com.vetti.socket.vo.FileTransferState;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.*; import org.springframework.web.socket.*;
import org.springframework.web.socket.handler.TextWebSocketHandler; import org.springframework.web.socket.handler.TextWebSocketHandler;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
@@ -13,6 +14,7 @@ import java.util.*;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
@Slf4j @Slf4j
@Component
public class VoiceWebSocketHandler extends TextWebSocketHandler { public class VoiceWebSocketHandler extends TextWebSocketHandler {
// 存储客户端的文件传输状态：clientId -> FileTransferState // 存储客户端的文件传输状态：clientId -> FileTransferState
private final Map<String, FileTransferState> transferStates = new ConcurrentHashMap<>(); private final Map<String, FileTransferState> transferStates = new ConcurrentHashMap<>();