隨著 ChatGPT 的興起，流式輸出技術逐漸走進大眾視野。在技術社區中，很多開發者開始研究和實踐 SSE（服務器推送事件）。不過，SSE 仍然存在一定的局限性，而 Spring 提供的 ResponseBodyEmitter 則是一種更簡便的異步流式輸出方式。雖然 ResponseBodyEmitter 并非新技術，它早在 Spring Framework 4.2 版本就已經引入，但在實際開發中仍然具有極高的實用價值，特別是在處理實時數據推送時。

ResponseBodyEmitter 的作用

ResponseBodyEmitter 主要用于異步 HTTP 響應處理，其核心優勢在于 支持逐步向客戶端發送數據，而不是一次性返回所有內容。這種特性特別適用于流式傳輸或需要長時間處理的任務，例如：

• 長輪詢服務器保持連接開放，待有數據時立即返回。
• 服務器推送事件（SSE）持續向客戶端推送更新信息。
• 流式傳輸逐步推送大量數據，如文件下載或實時數據流。
• 異步處理在后臺執行耗時任務，并實時返回處理結果。

典型應用場景

在實際業務中，ResponseBodyEmitter 可廣泛應用于：

• 實時進度更新（例如文件上傳進度條）
• 實時聊天
• 股票價格推送
• AI 實時響應
• 服務器日志流式輸出

實戰：構建實時日志流

假設我們需要實現一個實時日志查看功能，服務器可以不斷地向客戶端推送最新的日志信息。

創建控制器

首先，在 Spring Boot 3.4 應用中創建 LogController，使用 ResponseBodyEmitter 處理流式日志輸出。

package com.icoderoad.controller;

importorg.springframework.http.MediaType;
importorg.springframework.web.bind.annotation.GetMapping;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RestController;
importorg.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter;

@RestController
@RequestMapping("/api/log")
publicclassLogController{
    
    @GetMapping(value ="/stream", produces =MediaType.TEXT_EVENT_STREAM_VALUE)
    publicResponseBodyEmitterstreamLogs(){
        ResponseBodyEmitter emitter =newResponseBodyEmitter();
        
        newThread(()->{
            try{
                while(true){
                    String logEntry =getLatestLogEntry();
                    if(logEntry !=null){
                        emitter.send(logEntry);
                    }
                    Thread.sleep(1000);// 每秒推送一次
                }
            }catch(Exception e){
                emitter.completeWithError(e);
            }
        }).start();
        
        return emitter;
    }
    
    privateStringgetLatestLogEntry(){
        return"2025-02-12 12:00:00 - INFO: 用戶成功登錄。";
    }
}

運行效果：

訪問 http://localhost:8080/api/log/stream，服務器將每秒推送一條新的日志條目，前端可以實時接收并展示。

ResponseBodyEmitter 的核心方法

• send(Object data)逐步向客戶端發送數據，可多次調用。
• complete()結束響應流。
• onTimeout(Runnable callback)連接超時時觸發回調。
• onCompletion(Runnable callback)數據發送完成后觸發回調。

ResponseBodyEmitter 的工作原理

異步數據生成與推送

在傳統 HTTP 響應模式中，服務器通常需要等待整個響應數據生成完成后再返回。而 ResponseBodyEmitter 允許 異步逐步推送數據，即部分數據準備好后立即 send() 給客戶端，提高響應速度。

分塊傳輸（Chunked Encoding）

傳統 HTTP 響應頭需要指定 Content-Length，但 ResponseBodyEmitter 采用 分塊傳輸（Chunked Encoding），無需指定數據總長度，而是將數據分塊推送，客戶端收到后即可立即處理，減少等待時間。

連接生命周期管理

• 數據發送完畢時調用 complete() 關閉連接，避免資源浪費。
• 若發生異常，調用 completeWithError()，通知客戶端連接關閉。

注意事項

• 客戶端支持：大多數現代瀏覽器和 HTTP 客戶端都支持 ResponseBodyEmitter，但部分舊版本可能存在兼容性問題。
• 超時管理：建議設置超時時間，避免長連接占用資源，例如：

emitter.onTimeout(() -> emitter.complete());

• 線程安全：send() 方法是線程安全的，但仍需合理管理任務線程，避免資源泄漏。
• 連接關閉：務必調用 complete() 或 completeWithError() 以釋放資源。

ResponseBodyEmitter 與其他流式技術對比

在 AI 流式輸出等場景下，ResponseBodyEmitter 相比 SSE 具有更好的 HTTP 兼容性，且使用方式更靈活。

結語

ResponseBodyEmitter 是 Spring 提供的一種輕量級流式傳輸解決方案，非常適用于 高并發、實時數據推送 需求。無論是 進度條實時更新、實時聊天、股票數據推送、系統日志流式輸出，它都能提供更絲滑的用戶體驗。如果你的應用需要高效的異步數據推送，不妨試試 ResponseBodyEmitter 吧！