欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Spring中實(shí)現(xiàn)的三種異步流式接口方法

 更新時(shí)間:2024年10月21日 11:15:41   作者:Deh0rs  
在現(xiàn)代Web開(kāi)發(fā)中,接口超時(shí)是一個(gè)常見(jiàn)的問(wèn)題,尤其是在處理耗時(shí)操作時(shí),傳統(tǒng)的同步接口在處理長(zhǎng)時(shí)間任務(wù)時(shí)會(huì)阻塞請(qǐng)求線程,從而影響系統(tǒng)的響應(yīng)能力,本文將詳細(xì)講解Spring中實(shí)現(xiàn)的三種異步流式接口方法,需要的朋友可以參考下

前言

在現(xiàn)代Web開(kāi)發(fā)中,接口超時(shí)是一個(gè)常見(jiàn)的問(wèn)題,尤其是在處理耗時(shí)操作時(shí)。傳統(tǒng)的同步接口在處理長(zhǎng)時(shí)間任務(wù)時(shí)會(huì)阻塞請(qǐng)求線程,從而影響系統(tǒng)的響應(yīng)能力。Spring框架提供了多種工具來(lái)支持異步流式接口,從而有效地解決這一問(wèn)題。本文將詳細(xì)講解Spring中實(shí)現(xiàn)的三種異步流式接口方法:ResponseBodyEmitter、SseEmitter和StreamingResponseBody。

一、ResponseBodyEmitter

ResponseBodyEmitter適用于需要?jiǎng)討B(tài)生成內(nèi)容并逐步發(fā)送給客戶端的場(chǎng)景,例如文件上傳進(jìn)度、實(shí)時(shí)日志等。使用ResponseBodyEmitter,可以在任務(wù)執(zhí)行過(guò)程中逐步向客戶端發(fā)送更新,使交互體驗(yàn)更加生動(dòng)和自然。

使用示例:

@GetMapping("/bodyEmitter")
public ResponseBodyEmitter handle() {
    // 創(chuàng)建一個(gè)ResponseBodyEmitter,-1代表不超時(shí)
    ResponseBodyEmitter emitter = new ResponseBodyEmitter(-1L);

    // 異步執(zhí)行耗時(shí)操作
    CompletableFuture.runAsync(() -> {
        try {
            for (int i = 0; i < 10000; i++) {
                System.out.println("bodyEmitter " + i);
                // 發(fā)送數(shù)據(jù)
                emitter.send("bodyEmitter " + i + " @ " + new Date() + "\n");
                Thread.sleep(2000);
            }
            // 完成
            emitter.complete();
        } catch (Exception e) {
            // 發(fā)生異常時(shí)結(jié)束接口
            emitter.completeWithError(e);
        }
    });

    return emitter;
}

在這個(gè)示例中,通過(guò)模擬每2秒響應(yīng)一次結(jié)果,可以看到頁(yè)面數(shù)據(jù)在動(dòng)態(tài)生成。ResponseBodyEmitter的超時(shí)時(shí)間可以設(shè)置為0或-1,表示連接不會(huì)超時(shí)。如果不設(shè)置,到達(dá)默認(rèn)的超時(shí)時(shí)間后連接會(huì)自動(dòng)斷開(kāi)。

二、SseEmitter

SseEmitter是ResponseBodyEmitter的一個(gè)子類(lèi),主要用于服務(wù)器向客戶端推送實(shí)時(shí)數(shù)據(jù),如實(shí)時(shí)消息推送、狀態(tài)更新等場(chǎng)景。Server-Sent Events (SSE)技術(shù)在服務(wù)器和客戶端之間打開(kāi)一個(gè)單向通道,服務(wù)端響應(yīng)的不再是一次性的數(shù)據(jù)包,而是text/event-stream類(lèi)型的數(shù)據(jù)流信息。

使用示例:

@GetMapping("/subSseEmitter/{userId}")
public SseEmitter sseEmitter(@PathVariable String userId) {
    log.info("sseEmitter: {}", userId);
    SseEmitter emitterTmp = new SseEmitter(-1L);
    // 將SseEmitter對(duì)象進(jìn)行持久化,以便在消息產(chǎn)生時(shí)直接取出對(duì)應(yīng)的發(fā)送器
    EMITTER_MAP.put(userId, emitterTmp);

    CompletableFuture.runAsync(() -> {
        try {
            // 模擬發(fā)送數(shù)據(jù)
            SseEmitter.SseEventBuilder event = SseEmitter.event()
                .data("sseEmitter" + userId + " @ " + LocalTime.now());
            emitterTmp.send(event);
            // 這里可以添加更多的發(fā)送邏輯
        } catch (Exception e) {
            emitterTmp.completeWithError(e);
        }
    });

    return emitterTmp;
}

在客戶端,可以通過(guò)EventSource對(duì)象建立連接,并監(jiān)聽(tīng)message事件來(lái)接收服務(wù)器發(fā)送的數(shù)據(jù)。

三、StreamingResponseBody

StreamingResponseBody用于將響應(yīng)體作為流來(lái)輸出,適用于需要輸出大量數(shù)據(jù)且不適合使用ResponseBodyEmitter或SseEmitter的場(chǎng)景。

使用示例:

@GetMapping("/streaming")
public StreamingResponseBody streaming() {
    return outputStream -> {
        // 異步執(zhí)行耗時(shí)操作
        CompletableFuture.runAsync(() -> {
            try {
                for (int i = 0; i < 10000; i++) {
                    String data = "Streaming data " + i + "\n";
                    outputStream.write(data.getBytes());
                    outputStream.flush();
                    Thread.sleep(1000);
                }
                outputStream.close();
            } catch (Exception e) {
                // 處理異常
            }
        });
    };
}

在這個(gè)示例中,通過(guò)異步執(zhí)行耗時(shí)操作,逐步將數(shù)據(jù)寫(xiě)入到響應(yīng)的輸出流中。StreamingResponseBody適用于需要持續(xù)輸出數(shù)據(jù)流的場(chǎng)景,例如視頻流、文件下載等。

總結(jié)

通過(guò)使用ResponseBodyEmitter、SseEmitter和StreamingResponseBody,Spring框架提供了強(qiáng)大的異步流式接口支持,有效地解決了接口超時(shí)的問(wèn)題。這些方法允許在任務(wù)執(zhí)行過(guò)程中逐步向客戶端發(fā)送更新,提高了系統(tǒng)的響應(yīng)能力和用戶體驗(yàn)。根據(jù)具體的應(yīng)用場(chǎng)景,可以選擇合適的工具來(lái)實(shí)現(xiàn)異步流式接口。

以上就是Spring中實(shí)現(xiàn)的三種異步流式接口方法的詳細(xì)內(nèi)容,更多關(guān)于Spring異步流式接口方法的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

最新評(píng)論