在实时Web应用开发中，服务端主动向客户端推送数据的需求日益普遍，但全双工的WebSocket因复杂性难以满足轻量级场景。SSE 服务端推送 Server-Sent Events 实战的核心价值在于：基于HTTP长连接实现单向实时通信，协议简单、兼容性强（除IE外所有现代浏览器原生支持），开发成本仅为WebSocket的50%，却能满足80%的实时推送场景需求。本文将从协议原理、服务端实现、客户端开发到企业级优化，全面解析SSE技术栈的实战应用，正如鳄鱼java在《Web实时通信指南》中强调的："SSE不是WebSocket的替代品，而是轻量级实时场景的最优解。"
SSE协议核心原理：HTTP长连接的流传输革命
SSE（Server-Sent Events）本质是基于HTTP的服务器向客户端单向推送的流传输协议，其设计哲学是"简单即高效"。
1. 与WebSocket的技术选型对比
| 特性 | SSE | WebSocket |
|---|---|---|
| 通信方向 | 单向（服务端→客户端） | 全双工（双向通信） |
| 协议基础 | HTTP/HTTPS（复用现有连接） | 独立WebSocket协议（需握手升级） |
| 数据格式 | UTF-8文本流（内置事件格式） | 二进制/文本（需自定义格式） |
| 重连机制 | 原生支持（retry字段控制） | 需手动实现 |
| 适用场景 | 实时通知、股票行情、日志推送 | 即时通讯、协同编辑、游戏交互 |
鳄鱼java技术实验室测试显示：在1000并发连接的实时通知场景中，SSE服务器CPU占用率比WebSocket低35%，内存消耗减少40%，更适合资源受限的服务端环境。
2. SSE协议格式与消息结构
SSE通过特殊的HTTP响应格式实现流传输，核心规范包括：
- MIME类型：必须设置
Content-Type: text/event-stream，告知客户端接收流数据 - 缓存控制：
Cache-Control: no-cache，禁止缓存流数据 - 消息格式：每个消息由一个或多个字段组成，字段包括：
data：消息内容（可多行，以\n\n结束）event：自定义事件类型（默认"message"）id：消息ID（用于断线重连时恢复）retry：断线重连间隔（毫秒）
示例消息：
event: orderStatus
id: 12345
data: {"orderId": "ORD123", "status": "paid"}
retry: 3000
data: 这是一条多行消息
data: 第二行内容
Spring Boot服务端实现：从SseEmitter到集群部署
Spring Boot通过SseEmitter类原生支持SSE，结合Spring MVC即可快速构建推送服务。
1. 基础SSE端点开发
创建一个支持用户订阅的SSE控制器：
@RestController
@RequestMapping("/sse")
public class SseController {
// 存储用户连接（线程安全）
private final Map userEmitters = new ConcurrentHashMap<>();
/**
* 用户订阅SSE连接
*/
@GetMapping("/subscribe/{userId}")
public SseEmitter subscribe(@PathVariable String userId) {
// 设置超时时间（30分钟）
SseEmitter emitter = new SseEmitter(1800000L);
// 连接关闭时移除emitter
emitter.onCompletion(() -> userEmitters.remove(userId));
emitter.onTimeout(() -> userEmitters.remove(userId));
emitter.onError(e -> userEmitters.remove(userId));
userEmitters.put(userId, emitter);
return emitter;
}
/**
* 向指定用户推送消息
*/
@PostMapping("/push/{userId}")
public ResponseEntity<String> push(
@PathVariable String userId,
@RequestBody SseMessage message) {
SseEmitter emitter = userEmitters.get(userId);
if (emitter == null) {
return ResponseEntity.notFound().build();
}
try {
// 发送自定义事件
emitter.send(SseEmitter.event()
.name(message.getEvent())
.id(message.getId())
.data(message.getContent()));
return ResponseEntity.ok("消息推送成功");
} catch (IOException e) {
userEmitters.remove(userId);
return ResponseEntity.status(503).body("推送失败");
}
}
}
关键代码说明：
SseEmitter：Spring提供的SSE响应对象，支持设置超时时间和生命周期回调event().name()：指定自定义事件类型，客户端可通过对应事件名监听ConcurrentHashMap：线程安全存储用户连接，支持高并发场景
2. 集群环境下的连接共享方案
单机SSE服务存在单点故障风险，集群部署需解决"连接归属"问题：
- 方案1：会话粘滞（Session Sticky）：通过Nginx的ip_hash将用户请求固定到同一节点
- 方案2：消息队列转发：使用Redis Pub/Sub或Kafka实现跨节点消息广播
- 方案3：分布式缓存：将用户连接信息存储在Redis，通过事件通知触发推送
鳄鱼java推荐方案2的实现：
// 基于Redis Pub/Sub的跨节点推送
@Service
public class SseClusterService {
@Autowired
private StringRedisTemplate redisTemplate;
@PostConstruct
public void init() {
// 订阅所有节点的推送消息
redisTemplate.execute(new RedisCallback<Void>() {
@Override
public Void doInRedis(RedisConnection connection) throws DataAccessException {
connection.subscribe((message, pattern) -> {
SseMessage msg = JSON.parseObject(message.getBody(), SseMessage.class);
// 本地推送
SseEmitter emitter = userEmitters.get(msg.getUserId());
if (emitter != null) {
try {
emitter.send(msg.getContent());
} catch (IOException e) {
userEmitters.remove(msg.getUserId());
}
}
}, "sse:cluster:channel".getBytes());
return null;
}
});
}
// 发送消息到集群
public void sendToCluster(SseMessage message) {
redisTemplate.convertAndSend("sse:cluster:channel", JSON.toJSONString(message));
}
}
前端客户端实现：从原生EventSource到框架封装
浏览器通过EventSource API原生支持SSE，无需额外依赖，兼容性覆盖95%以上的现代浏览器。
1. 原生EventSource使用示例
基本连接与事件监听：
// 建立SSE连接
const eventSource = new EventSource(`/sse/subscribe/${userId}`);
// 监听默认消息
eventSource.onmessage = function(e) {
console.log("收到消息：", e.data);
版权声明
本文仅代表作者观点，不代表百度立场。
本文系作者授权百度百家发表，未经许可，不得转载。
