早期网站仅展示静态内容,而如今我们更期望:实时更新、即时聊天、通知推送和动态仪表盘。
那么要如何实现实时的用户体验呢?三大经典技术各显神通:
假设目前有三个业务场景,需要实现数据实时更新:
面对这些需求,我们应该如何决策选择合适的方案呢?
下面让我们从架构、性能和扩展性角度一起探讨一下。
客户端持续询问服务器:
就像在吃饭排队叫号的时候,站在店门口每隔5分钟询问是否到你一样,效率低下。
@GetMapping("/updates")
public ResponseEntity<String> getUpdate() {
// 模拟延迟或等待事件
return ResponseEntity.ok("最新更新!");
}
✔ 优点:
✘ 缺点:
当无法使用WebSocket或SSE且需要支持老旧浏览器或代理时使用,一般常见于大型企业的遗留系统中使用。
客户端建立连接后:
仅支持服务器到客户端的单向通信,适合实时数据流。
@GetMapping("/stream")
public SseEmitter stream() {
SseEmitter emitter = new SseEmitter();
// 异步推送更新
emitter.send("实时更新!");
return emitter;
}
✔ 优点:
✘ 缺点:
需要简单高效的服务器到客户端更新(如:股票行情、实时比分、状态仪表盘、监控系统等)。
建立双向通道实现实时对话:
类似对讲机的全双工通信模式。
@Configuration
@EnableWebSocket
publicclassWebSocketConfigimplementsWebSocketConfigurer {
publicvoidregisterWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(newMyHandler(), "/ws").setAllowedOrigins("*");
}
}
// 处理器
publicclassMyHandlerextendsTextWebSocketHandler {
@Override
protectedvoidhandleTextMessage(WebSocketSession session, TextMessage message) {
session.sendMessage(newTextMessage("回显:" + message.getPayload()));
}
}
✔ 优点:
✘ 缺点:
适用于聊天室、游戏、协作应用等需要双向交互的场景。
最后,结合上面的分析,对于文章开头的业务场景,最终选型方案可以是: