/**
 * 流式調(diào)用
 */
@GetMapping("/generateStream")
public SseEmitter streamChat(@RequestParam String message) {
    // 創(chuàng)建 SSE 發(fā)射器，設(shè)置超時時間（例如 1 分鐘）
    SseEmitter emitter = new SseEmitter(60_000L);
    // 創(chuàng)建 Prompt 對象
    Prompt prompt = new Prompt(new UserMessage(message));
    // 訂閱流式響應(yīng)
    // 完成處理
    // 異常處理
    openAiChatModel.stream(prompt).subscribe(response -> {
                try {
                    String content = response.getResult().getOutput().getContent();
                    System.out.print(content);
                    // 發(fā)送 SSE 事件
                    emitter.send(SseEmitter.event()
                            .data(content)
                            .id(String.valueOf(System.currentTimeMillis()))
                            .build());
                } catch (Exception e) {
                    emitter.completeWithError(e);
                }
            },
            emitter::completeWithError,
            emitter::complete
    );
    // 處理客戶端斷開連接
    emitter.onCompletion(() -> {
        // 可在此處釋放資源
        System.out.println("SSE connection completed");
    });
    emitter.onTimeout(() -> {
        emitter.complete();
        System.out.println("SSE connection timed out");
    });
    return emitter;
}

$('#send-button').click(function () {
  const message = $('#chat-input').val();
  // 立即清空輸入框
  $('#chat-input').val('');
  // 用戶消息（保持原有樣式）
  var userMessage = $('<div class="message user"></div>');
  userMessage.append('<img class="avatar" src="/images/user.png" alt="用戶頭像">');
  userMessage.append(`<div class="content"><span class="nickname">你</span><div class="text">${message}</div></div>`);
  // 機器人消息容器（先創(chuàng)建空容器）
  var botMessage = $('<div class="message bot"></div>');
  botMessage.append('<img class="avatar" src="/images/robot.png" alt="助手頭像">');
  botMessage.append('<div class="content"><span class="nickname">助手</span><div class="text"></div></div>');
  // 按順序添加消息
  $('#chat-messages').append(userMessage, botMessage);
  // 流式處理
  const eventSource = new EventSource(`/ai/generateStream?message=` + message);
  eventSource.onmessage = function (event) {
  botMessage.find('.text').append(event.data);  // 追加到機器人消息內(nèi)容區(qū)
  };
  // 錯誤處理
  eventSource.onerror = function (err) {
  $('#chat-input').val(''); // 確保網(wǎng)絡(luò)異常時也清空
  console.error("連接錯誤:", err);
  eventSource.close();
  };
});