介绍

网页接收服务端消息，一般有如下几种方式

• 直接轮询
• WebSocket 长链接
• 长轮询
• Server send event

一、短轮询方式

前端页面按照时间间隔轮询拉取最新消息

缺点：

• 实时性差！最长耗时等于时间间隔耗时
• 没有消息也会有大量的请求，消耗服务器资源

优点：

• 开发简单，可以快速实现功能

二、TCP 长链接 WebSocket 和 FlashSocket

• WebSocket协议

WebSocket 协议

WebSocket 是一种全双工通信协议，建立在 TCP 之上，允许客户端（如浏览器）与服务器之间建立持久连接，实现双向实时数据传输。webSocket 解决了 Http 请求-响应模型无法实现服务器主动推送的问题。

特点：双向通信、持久链接、低延迟(数据帧小，无需每次携带头部)、原生支持(现代浏览器均原生支持)

链接：通过 Http 协议的 upgrade 方法建立 tcp 长链接

WebSocket 服务集群如何精确推送

方案 1：集中式连接管理 + 消息路由（推荐）

• 每个服务节点维护自己当前连接的用户（如内存 Map：userId -> WebSocketSession）
• 引入一个集中式存储（如 Redis、ETCD、ZooKeeper）记录“用户ID → 所在节点标识”的映射关系。
• 发送消息时，先查集中存储，找到目标用户所在的节点，再通过节点间通信（如 RPC、消息队列）将消息路由到目标节点，由目标节点通过本地 WebSocket 推送。

方案 2：通过消息队列的消息广播

• 所有节点订阅相同的 MQ 队列
• 各个节点需要发送消息，只需要将消息发送到队列中
• 各个节点消费消息时，只需判断对应的消息接受用户是否连接到本服务了，连接到本服务了则发送消息

FlashSocket 已被淘汰的历史产物

FlashSocket 并不是一个官方协议，而是在 Flash 时代，开发者利用 Adobe Flash 的 Socket API 实现的浏览器端 TCP 长连接方案，用于在 WebSocket 出现之前模拟“实时通信”。

诞生背景：

• 2005~2012 年，浏览器原生不支持 WebSocket。
• Flash Player 支持 TCP Socket，可绕过浏览器限制实现“伪长连接”。
• 需要浏览器安装 Flash 插件 + 用户授权安全策略。

三、Http 长轮询

长轮询是在 WebSocket 普及之前，实现**“伪实时”**通信的一种经典方案。它通过“拉”模式模拟“推”效果：

客户端发起 HTTP 请求 → 服务器“hold 住”请求不立即返回 → 有新消息时才响应 → 客户端收到后立即再次发起新请求

客户端 服务器 │ │ ├─ 请求新消息 ─────────>│ │ │ │ │ ← 无消息？Hold 住连接（不返回） │ │ │ │ ← 有新消息到达！立即返回数据 │<──────── 响应消息 ────┤ │ │ ├─ 立即再次请求 ────────>│ │ │ │ │ ← 继续 hold 或返回...

与普通轮询(短轮询)对比

优点和缺点：

在现代项目中，优先使用 WebSocket；长轮询仅用于兼容性要求高或临时过渡场景。

** 优点：**

• 兼容性好：所有浏览器都支持 HTTP。
• 实现简单：无需特殊协议或插件。
• 适合低频消息推送（如通知、订单状态变更）。

缺点：

• 每次请求有 HTTP 头开销。
• 服务器需维持大量挂起连接（消耗线程/内存）。
• 不如 WebSocket 实时和高效。
• 超时、断连需手动处理。

SpringBoot 案例

// MessageManager.java@ComponentpublicclassMessageManager{// 模拟每个用户的“消息阻塞队列”privatefinalMap<String,BlockingQueue<String>>userQueues=newConcurrentHashMap<>();// 获取用户队列（不存在则创建）privateBlockingQueue<String>getQueue(StringuserId){returnuserQueues.computeIfAbsent(userId,k->newLinkedBlockingQueue<>());}// 发送消息给用户publicvoidsendMessage(StringuserId,Stringmessage){BlockingQueue<String>queue=getQueue(userId);queue.offer(message);// 非阻塞放入}// 长轮询：等待消息（最多30秒）publicStringawaitMessage(StringuserId,longtimeoutMillis)throwsInterruptedException{BlockingQueue<String>queue=getQueue(userId);returnqueue.poll(timeoutMillis,TimeUnit.MILLISECONDS);// 阻塞等待}// 可选：清理用户队列（用户下线时调用）publicvoidremoveUser(StringuserId){userQueues.remove(userId);}}// LongPollingController.java@RestControllerpublicclassLongPollingController{@AutowiredprivateMessageManagermessageManager;/** * 长轮询接口：客户端调用，等待新消息 */@GetMapping("/long-polling")publicResponseEntity<String>longPolling(@RequestParamStringuserId){try{// 最多等待 30 秒Stringmessage=messageManager.awaitMessage(userId,30_000);if(message!=null){returnResponseEntity.ok(message);}else{returnResponseEntity.status(204).body("");// 204 No Content 表示超时无消息}}catch(InterruptedExceptione){Thread.currentThread().interrupt();returnResponseEntity.status(500).body("Interrupted");}}/** * 模拟发送消息接口（用于测试） */@GetMapping("/send")publicStringsendMessage(@RequestParamStringto,@RequestParamStringmsg){messageManager.sendMessage(to,msg);return"Message sent to "+to+": "+msg;}}

基于 Http 的 SSE 技术

七、WebSocket和SSE对比

基于Http的Server-Sent Events 技术

基于Http的Server-Sent Events 技术