需求：需要對文心一言的流式接口數據進行處理 增加屬性
return ResponseEntity.ok().header("Access-Control-Allow-Origin", "*").contentType(org.springframework.http.MediaType.TEXT_EVENT_STREAM).cacheControl(org.springframework.http.CacheControl.noCache()).body(outputStream -> {try (Response response = client.newCall(request).execute();ResponseBody responseBody = response.body();InputStream inputStream = responseBody.byteStream()) {if (!response.isSuccessful()) {throw new IOException("Failed to fetch streaming data, HTTP error code: " + response.code());}byte[] buffer = new byte[4096];int bytesRead;while ((bytesRead = inputStream.read(buffer)) != -1) {/*outputStream.write(buffer, 0, bytesRead);outputStream.flush();*/String data = new String(buffer, 0, bytesRead, StandardCharsets.UTF_8);String[] lines = data.split("\n");for (String line : lines) {if (line.startsWith("data: ")) {// 記錄流輸出結果，用于后續持久化com.zbIntel.integration.wenxin.entity.ChatResponse bean =JSONUtil.parseObj(line.substring(6).getBytes(StandardCharsets.UTF_8)).toBean(com.zbIntel.integration.wenxin.entity.ChatResponse.class);bean.setSessionId(req.getSessionId());// 序列化bean并發送String serializedBean = JSONUtil.toJsonStr(bean);outputStream.write(("data: " + serializedBean + "\n\n").getBytes(StandardCharsets.UTF_8));outputStream.flush();log.info("返回數據：{}", bean);String content = bean.getResult();if (bean.getIs_end()) {isEndflag.set(Boolean.TRUE);}// 記錄流輸出結果，用于后續持久化respContent.append(content);}}}} catch (IOException e) {log.error("Error during streaming data: ", e);outputStream.write(("{" +" \"error_code\": 112," +" \"error_msg\": \"" + e.getMessage() + "\"" +"}").getBytes(StandardCharsets.UTF_8));outputStream.flush();}if(isEndflag.get()) {// 構造回復數據對象，持久化String respContentStr = respContent.toString();SessionChatRecordEntity replyRecord = new SessionChatRecordEntity(finalAskRecord.getSessionId(), Role.ASSISTANT.name,respContentStr, ChatGPTApi.getMessageTokenNum(respContentStr));sessionChatRecordService.saveBatch(ImmutableList.of(finalAskRecord, replyRecord));// 刷新緩存chatService.refreshWindowRecordCache(finalAskRecord.getSessionId());}});主要時這段：
// 序列化bean并發送
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? String serializedBean = JSONUtil.toJsonStr(bean);
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? outputStream.write(("data: " + serializedBean + "\n\n").getBytes(StandardCharsets.UTF_8));
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? outputStream.flush();
返回的結果：
增加了 sessionId的屬性
