1、调整后台接收前端发送数据量

2、对调用进行json包装

src/main/java/admin/server/VoiceWebSocketServer.java

@@ -2,6 +2,7 @@ package admin.server;
 
 import admin.config.SpeechToTextConfig;
 import admin.service.MaxkbOpenApiService;
+import com.alibaba.fastjson.JSON;
 import lombok.extern.slf4j.Slf4j;
 import okhttp3.HttpUrl;
 import okhttp3.OkHttpClient;
@@ -59,27 +60,32 @@ public class VoiceWebSocketServer {
 
     //关闭连接时调用
     @OnClose
-    public void onClose(@PathParam(value = "memberId") String memberId) {
+    public void onClose(Session session, CloseReason closeReason,@PathParam(value = "memberId") String memberId) {
         sessionPools.remove(memberId);
         log.info("关闭连接");
         System.out.println(sessionPools);
     }
 
     //收到客户端信息
-    @OnMessage
+    @OnMessage(maxMessageSize = 10*1024*1024)
     public void onTextMessage(Session session,String message) throws IOException {
-        session.setMaxBinaryMessageBufferSize(50 * 1024 * 1024);
+//        session.setMaxBinaryMessageBufferSize(50 * 1024 * 1024);
         log.info("message:{}",message);
+        Map<String,Object> map = JSON.parseObject(message,Map.class);
+        String msg = "";
+        if("sendText".equals(map.get("action"))){
+             msg = (String)map.get("data");
+        }
         maxkbOpenApiService.talk(message,session);
     }
 
-    @OnMessage
-    public void onBinaryMessage(Session session, ByteBuffer data) {
-        session.setMaxBinaryMessageBufferSize(50 * 1024 * 1024);
-        // 处理二进制音频数据块
-        log.info("data:{}",data);
-        handleAudioChunk(session, data);
-    }
+//    @OnMessage
+//    public void onBinaryMessage(Session session, ByteBuffer data) {
+//        session.setMaxBinaryMessageBufferSize(50 * 1024 * 1024);
+//        // 处理二进制音频数据块
+//        log.info("data:{}",data);
+//        handleAudioChunk(session, data);
+//    }
 
 
     //错误时调用