快捷導(dǎo)航

Spring Boot實(shí)現(xiàn)SSE實(shí)時推送實(shí)戰(zhàn)示例

更新時間：2025年08月11日 11:52:15 作者：Vesper63

本文給大家介紹基于SpringBoot實(shí)現(xiàn)SSE示例,包括創(chuàng)建項目、SSE控制器處理連接與消息推送、跨域配置、客戶端使用EventSource訂閱,以及動態(tài)推送和WebFlux擴(kuò)展,感興趣的朋友跟隨小編一起看看吧

一、服務(wù)端實(shí)現(xiàn)

1. 創(chuàng)建 Spring Boot 項目

首先，創(chuàng)建一個基本的 Spring Boot 項目，并添加 spring-boot-starter-web 依賴。在 pom.xml 中添加以下內(nèi)容：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

2. 創(chuàng)建 SSE 控制器

創(chuàng)建一個控制器來處理 SSE 連接并推送實(shí)時消息。

SseController.java

package com.example.sse;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
@RestController
public class SseController {
    private final ExecutorService executorService = Executors.newCachedThreadPool();
    @GetMapping("/sse")
    public SseEmitter handleSse() {
        SseEmitter emitter = new SseEmitter();
        executorService.execute(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    emitter.send("Message " + i, MediaType.TEXT_PLAIN);
                    TimeUnit.SECONDS.sleep(1);
                }
                emitter.complete();
            } catch (IOException | InterruptedException e) {
                emitter.completeWithError(e);
            }
        });
        return emitter;
    }
}

3. 配置跨域（可選）

如果前端和后端運(yùn)行在不同端口上，需要配置跨域。

CorsConfig.java

package com.example.sse;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.CorsRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
@Configuration
public class CorsConfig implements WebMvcConfigurer {
    @Override
    public void addCorsMappings(CorsRegistry registry) {
        registry.addMapping("/**")
                .allowedOriginPatterns("*")
                .allowedMethods("GET", "POST", "PUT", "DELETE")
                .allowedHeaders("*")
                .allowCredentials(true);
    }
}

二、客戶端實(shí)現(xiàn)

在前端頁面中，使用 EventSource 來訂閱 SSE。

index.html

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>SSE Example</title>
</head>
<body>
    <h1>Server-Sent Events Example</h1>
    <div id="events"></div>
    <script>
        const eventSource = new EventSource('/sse');
        eventSource.onmessage = function(event) {
            const newElement = document.createElement("div");
            newElement.innerHTML = "Message: " + event.data;
            document.getElementById("events").appendChild(newElement);
        };
        eventSource.onerror = function(event) {
            eventSource.close();
            alert("EventSource failed: " + event);
        };
    </script>
</body>
</html>

三、運(yùn)行和測試

啟動 Spring Boot 應(yīng)用。
在瀏覽器中訪問 http://localhost:8080，即可看到服務(wù)端每秒推送的消息。

四、擴(kuò)展功能

1. 動態(tài)推送消息

可以通過維護(hù)一個 SseEmitter 的映射來動態(tài)推送消息。

SseController.java（動態(tài)推送版本）

package com.example.sse;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
@RestController
public class SseController {
    private final Map<String, SseEmitter> emitterMap = new ConcurrentHashMap<>();
    @GetMapping("/sse/{userId}")
    public SseEmitter connect(@PathVariable String userId) {
        SseEmitter emitter = new SseEmitter();
        emitterMap.put(userId, emitter);
        emitter.onCompletion(() -> emitterMap.remove(userId));
        emitter.onTimeout(() -> emitterMap.remove(userId));
        emitter.onError(e -> emitterMap.remove(userId));
        return emitter;
    }
    @GetMapping("/push/{userId}")
    public void push(@PathVariable String userId, @RequestParam String message) {
        SseEmitter emitter = emitterMap.get(userId);
        if (emitter != null) {
            try {
                emitter.send(message);
            } catch (IOException e) {
                emitter.completeWithError(e);
                emitterMap.remove(userId);
            }
        }
    }
}

2. 使用 WebFlux 實(shí)現(xiàn) SSE

如果需要更高效的響應(yīng)式編程支持，可以使用 Spring WebFlux。

SseController.java（WebFlux 版本）

package com.example.sse;
import org.springframework.http.MediaType;
import org.springframework.http.codec.ServerSentEvent;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import java.time.Duration;
@RestController
public class SseController {
    @GetMapping("/sse/stream")
    public Flux<ServerSentEvent<String>> streamSse() {
        return Flux.interval(Duration.ofSeconds(1))
                .map(sequence -> ServerSentEvent.<String>builder()
                        .id(String.valueOf(sequence))
                        .event("periodic-event")
                        .data("Current time: " + java.time.LocalTime.now())
                        .build());
    }
}

通過以上步驟，你可以實(shí)現(xiàn)一個完整的基于 Spring Boot 的 SSE 應(yīng)用。

到此這篇關(guān)于Spring Boot實(shí)現(xiàn)SSE實(shí)時推送實(shí)戰(zhàn)示例的文章就介紹到這了,更多相關(guān)springboot sse實(shí)時推送內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: