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

语音文件流压缩

Browse Source
This commit is contained in:
wangxiangshun
2025-10-09 13:16:03 +08:00
parent c63c206877
commit c4efb6d9ce
1 changed files with 5 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
vetti-admin/src/main/java/com/vetti/socket/ChatWebSocketHandler.java
View File

@@ -6,6 +6,7 @@ import com.vetti.common.ai.whisper.WhisperClient;
import com.vetti.common.config.RuoYiConfig; import com.vetti.common.config.RuoYiConfig;
import com.vetti.common.utils.spring.SpringUtils; import com.vetti.common.utils.spring.SpringUtils;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FileUtils;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import javax.websocket.*; import javax.websocket.*;
@@ -106,9 +107,10 @@ public class ChatWebSocketHandler {
try { try {
//文件转换成文件流 //文件转换成文件流
ByteBuffer outByteBuffer = convertFileToByteBuffer(resultPathUrl); ByteBuffer outByteBuffer = convertFileToByteBuffer(resultPathUrl);
//发送文件流数据
session.getBasicRemote().sendBinary(outByteBuffer); session.getBasicRemote().sendBinary(outByteBuffer);
// 发送响应确认 // 发送响应确认
session.getBasicRemote().sendText("已收到二进制数据，长度: " + bytes.length); // session.getBasicRemote().sendText("已收到二进制数据，长度: " + bytes.length);
log.info("7、运行时间:{}",System.currentTimeMillis()/1000); log.info("7、运行时间:{}",System.currentTimeMillis()/1000);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); e.printStackTrace();
@@ -185,16 +187,8 @@ public class ChatWebSocketHandler {
*/ */
private ByteBuffer convertFileToByteBuffer(String fileUrl) { private ByteBuffer convertFileToByteBuffer(String fileUrl) {
File file = new File(fileUrl); File file = new File(fileUrl);
// 使用RandomAccessFile获取FileChannel try {
try (RandomAccessFile raf = new RandomAccessFile(file, "r"); return ByteBuffer.wrap(FileUtils.readFileToByteArray(file));
FileChannel channel = raf.getChannel()) {
// 分配与文件大小相同的ByteBuffer
ByteBuffer buffer = ByteBuffer.allocate((int) channel.size());
// 从通道读取数据到缓冲区
channel.read(buffer);
// 切换为读模式
buffer.flip();
return buffer;
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }