重学SpringBoot3-Spring WebFlux之SSE服务器发送事件_springboot3 sse

更多SpringBoot3内容请关注我的专栏：《SpringBoot3》
期待您的点赞👍收藏⭐评论✍

Spring WebFlux之SSE服务器发送事件

• 1. 什么是 SSE？
• 2. Spring Boot 3 响应式编程与 SSE
• • 为什么选择响应式编程实现 SSE？
• 3. 实现 SSE 的基本步骤
• • 3.1 创建 Spring Boot 项目
  • 3.2 实现服务端推送 SSE 事件流
  • 3.3 客户端接收 SSE 数据
• 4. 测试 SSE
• 5. 优化与扩展
• • 5.1 增加随机数据推送
  • 5.2 增加心跳检测（Ping）
  • 5.3 使用 `MediaType.TEXT_EVENT_STREAM` 响应
• 6. SSE 与 WebSocket 的对比
• 7. 总结

ChatGPT 刚出的时候，让大伙很好奇的是它是如何实现的逐字输出的？答案就是 SSE （服务器发送事件）。随着实时数据和响应式编程的需求不断增加，服务器发送事件（Server-Sent Events，简称 SSE）在现代 Web 应用程序中越来越受欢迎。SSE 提供了一种轻量级的服务器推送数据给客户端的方式，适合用于监控、实时通知、股票价格更新等场景。

在 Spring Boot 3 中，结合响应式编程的理念，SSE 的实现变得更加简洁和高效。本文将详细介绍如何使用 Spring Boot 3 来实现 SSE 服务端推送，并讨论响应式编程在此过程中的重要性和优势。

1. 什么是 SSE？

服务器发送事件（SSE） 是一种从服务器向客户端推送数据的技术，属于 HTML5 的一部分。与传统的 HTTP 请求-响应模型不同，SSE 是单向的，服务器可以持续不断地向客户端发送数据，而客户端通过一次长连接持续接收这些更新。

相比 WebSocket，SSE 有以下特点：

• 单向通信：SSE 仅允许服务器向客户端推送数据，客户端无法向服务器发送数据。
• 基于 HTTP 协议：SSE 是建立在 HTTP 协议之上的，浏览器原生支持，不需要额外的协议处理。
• 自动重连：SSE 支持自动重连，当连接意外断开时，客户端会自动尝试重新连接服务器。

2. Spring Boot 3 响应式编程与 SSE

Spring Boot 3 提供了对响应式编程的全面支持，基于 Project Reactor 实现异步、非阻塞的流式数据处理。而响应式编程非常适合实现 SSE，因为它允许我们以非阻塞的方式持续推送数据，而不会阻塞服务器的资源。

Spring WebFlux 是 Spring Boot 3 中用于构建响应式应用的核心框架，它可以无缝集成 SSE，为我们提供简单高效的服务器推送功能。

为什么选择响应式编程实现 SSE？

传统的阻塞式编程在处理长连接（如 SSE）时可能会占用大量服务器资源。响应式编程通过非阻塞 I/O 操作，不仅可以高效处理长时间的连接，还能在有新数据时立即推送给客户端。响应式流（如 Flux）天然适合于这种流式数据推送场景。

3. 实现 SSE 的基本步骤

我们将通过以下步骤实现一个简单的 SSE 服务端推送应用：

1. 创建 Spring Boot 项目并引入 WebFlux 依赖。
2. 实现服务端推送 SSE 事件流。
3. 编写客户端接收 SSE 数据。
4. 测试与优化。

3.1 创建 Spring Boot 项目

首先，创建一个新的 Spring Boot 3 项目，并确保引入了 spring-boot-starter-webflux 依赖。可以通过 Maven 或 Gradle 配置：

Maven 依赖

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

3.2 实现服务端推送 SSE 事件流

在 Spring WebFlux 中，SSE 通过返回 Flux<ServerSentEvent> 这种响应流来实现。下面我们实现一个简单的 SSE 控制器，它会每隔一段时间向客户端推送当前的时间信息。

示例控制器

package com.coderjia.boot3webflux.controller;import org.springframework.http.codec.ServerSentEvent;import org.springframework.stereotype.Controller;import org.springframework.web.bind.annotation.GetMapping;import reactor.core.publisher.Flux;import java.time.Duration;import java.time.LocalTime;/** * @author CoderJia * @create 2024/10/27 下午 07:03 * @Description **/@Controllerpublic class SseController {  @GetMapping(\"/sse/stream\"