@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;
}

@GetMapping("/subSseEmitter/{userId}")
public SseEmitter sseEmitter(@PathVariable String userId) {
    log.info("sseEmitter: {}", userId);
    SseEmitter emitterTmp = new SseEmitter(-1L);
    // 將SseEmitter對象進(jìn)行持久化，以便在消息產(chǎn)生時(shí)直接取出對應(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;
}

@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) {
                // 處理異常
            }
        });
    };
}