服务器想给指定客户端发数据，最直接的办法是让客户端先与服务端建立一条可辨识的长连接，服务端维护一张“在线客户端表”，需要推送时按标识找到对应连接并写入数据。这套逻辑在Web环境下通常用WebSocket或SSE实现，在物联网或App场景则常用MQTT或自定义TCP长连接,下面拆开讲透。
为什么“指定客户端”是核心难点
HTTP协议天生是“客户端先问，服务端再答”的模型，服务端手里的数据再新鲜，客户端不来问，服务端也递不过去，要让服务端主动找上某个客户端，前提是打破HTTP的请求-响应循环，让连接“活”起来。
业内专家指出，几乎所有实时推送方案的底层逻辑都指向同一个方向：建立一条长期不关闭的通道，并给通道里的每一端发一个唯一标识，通道负责传输，标识负责定位，没有标识，服务端面对一万条连接，根本不知道哪条属于“那个指定客户端”。
服务器怎么给指定客户端发数据：三条主流路子
WebSocket，全双工的“直连电话”
WebSocket是目前Web环境下最常用的方案，客户端与服务器完成一次HTTP握手后，连接升级为WebSocket协议，此后双方随时都能往这条通道里丢数据。
操作路径大致分四步：
- 客户端发起WebSocket连接，URL形如
ws://your-server.com/ws，握手时带上身份凭证（Token或SessionId）。 - 服务端在连接成功的回调里，把
userId和对应的socket连接对象存入一个全局的ConcurrentHashMap。 - 需要推数据时，从Map里取出目标userId对应的连接对象，调用
sendMessage()方法。 - 客户端断开时,服务端在关闭回调里从Map中移除对应记录。
这段逻辑对应实际代码，核心就是“一个Map维护在线状态，一个send方法完成定向投递”，写起来不复杂，但要注意并发安全,多线程同时读写Map时记得用并发容器。
SSE，单向管道适合“服务端单方面播报”
SSE（Server-Sent Events）是HTTP协议天然支持的推送方式，它不需要像WebSocket那样升级协议，服务端把响应头的Content-Type设为text/event-stream，连接就会保持打开,服务端可以持续往里写数据。
SSE的定向推送逻辑和WebSocket一样，也是维护一个连接池,区别在于：
- 连接是单向的,客户端只能通过另外的普通HTTP接口给服务端传数据。
- 自带断线重连机制,网络抖动后客户端会自动重新发起连接。
- 实现成本低，不需要额外引入WebSocket库,原生HTTP就能搞定。
适合场景很明确：服务端推送通知、行情刷新、日志流这类不要求客户端频繁回传数据的业务，如果业务需要双向高频互动,SSE就不合适。
MQTT，物联网场景的“邮局订阅系统”
如果把WebSocket比作直连电话，那MQTT就是一套完整的邮政系统，客户端（设备）先订阅一个“主题”，服务端往主题里发消息，所有订阅了该主题的设备都会收到，想发给指定设备，就给每台设备分配一个专属主题，比如device/{deviceId}/command。
MQTT的定向推送思路虽然是“发布-订阅”，但通过主题的精细化拆分，完全能实现一对一的精准投递,它相比WebSocket的核心优势在于：
- 协议开销极小，数据包头部只有几字节,适合低带宽高延迟的网络环境。
- 自带QoS质量等级，消息是否送达、送达几次都有明确语义。
- 内置遗嘱机制,设备异常掉线时服务端能立刻感知。
据统计，相当一部分物联网平台的消息层都跑在MQTT之上，这已经是行业共识，如果做的是智能硬件、车联网、传感器数据采集这类项目,MQTT是比WebSocket更顺手的选择。
服务器推送消息到指定客户端方案对比：选型看这五个维度
| 对比维度 | WebSocket | SSE | MQTT |
|---|---|---|---|
| 通信方向 | 全双工，双向实时 | 单向，仅服务端到客户端 | 全双工，发布-订阅模式 |
| 协议基础 | 独立协议，需握手升级 | 原生HTTP，无需额外协议 | 独立协议，需Broker服务器 |
| 连接保持 | 需自己处理心跳和重连 | 自带断线重连 | 内置心跳和QoS机制 |
| 客户端兼容性 | 浏览器、App、小程序均支持较好 | 浏览器原生支持，部分老版本IE不支持 | 需引入MQTT客户端库，嵌入式设备支持广 |
| 定向推送实现成本 | 低，维护一个连接池即可 | 低，和WebSocket思路一致 | 中，需设计主题规则，用Topic区分目标 |
选型建议直接看场景：Web网页或小程序里的实时聊天、协作编辑，选WebSocket；后台管理的站内信、通知公告、大屏数据刷新，SSE足够且更省事；涉及硬件设备、弱网环境、消息可靠性要求高的,直接上MQTT。
动手实战：WebSocket定向推送的完整操作路径
第一步：设计客户端身份标识
客户端连接时，服务端怎么知道“你是谁”？行业里最常用的做法是用Token换身份，客户端登录后拿到一个签名Token，建立WebSocket连接时把Token放在URL参数或请求头里，服务端解析Token得到userId,再把这个userId和连接对象绑定。
第二步：维护在线客户端表
用一个全局Map存放所有在线连接，键是userId，值是WebSocket会话对象，连接建立时put进去，连接关闭时remove掉，这里有个坑要注意：同一个用户可能在多个设备上同时在线，Map的值用CopyOnWriteArraySet或ConcurrentHashMap.newKeySet()存一个集合,遍历集合就能把消息推给该用户的全部设备。
第三步：定向推送的完整链路
服务端收到业务系统的推送指令后,执行以下JAVA核心逻辑：
public void sendToUser(String userId, String message) {
Set<WebSocketSession> sessions = onlineUsers.get(userId);
if (sessions == null || sessions.isEmpty()) {
return; // 用户不在线，消息需走离线存储
}
for (WebSocketSession session : sessions) {
synchronized (session) {
session.sendMessage(new TextMessage(message));
}
}
}
这段代码背后的判断逻辑值得展开说：
- 用户不在线时，消息不能直接丢弃，应该落库存为离线消息,等用户下次上线时补推。
- 多实例部署时，每台服务器只持有自己节点上的连接,需要引入Redis发布订阅或消息队列做跨节点转发。
- 发送超时或抛异常时，要把失效连接从Map中移除，避免“僵尸连接”占着内存不做事。
第四步：心跳与断线重连的兜底策略
长连接在公网环境很容易被中间设备静默断开，表现为“看起来连着，实际上已经死了”，行业共识是客户端每30秒发一个心跳包，服务端若连续3次未收到心跳，主动关闭该连接，客户端侧也要监听onclose事件，触发后延时1秒、2秒、4秒递增重连,直到恢复为止。
常见坑与避坑指南
连接池内存泄漏
每次连接建立都往Map里塞数据，但连接关闭时忘记移除，时间一长内存就被吃光了，处理办法是在onClose回调里务必执行移除操作，同时启动一个定时任务,定期扫描超过N分钟无心跳的连接并强制清理。
消息顺序错乱
业务上同时给同一客户端发多条消息，如果用多线程并发调sendMessage，底层TCP写操作可能交叉，导致接收方拿到的消息顺序颠倒，规避手段是给每个连接加同步锁，保证同一连接上的消息串行发送。
推送消息体积过大
WebSocket单帧数据不宜超过64KB，超过这个体积应该拆分成多帧发送，或者让客户端先收到“消息准备就绪”的元数据，再通过HTTP接口拉取完整内容，这个限制来自浏览器和代理服务器的通用约定,超出后连接会被强制断开。
特定场景下服务器与指定客户端交互方案
服务器怎么给指定客户端发数据不经过公网
内网穿透或局域网部署环境下，客户端和服务端在同一内网，连接更稳定，此时可以直接用TCP长连接加自定义协议，省去WebSocket的握手开销，客户端启动时先向服务端注册自己的设备编号，服务端维护一个Map<设备编号, Channel>，推送时直接channel.writeAndFlush()即可。
服务器主动推送消息给指定客户端但客户端在NAT后面
NAT导致服务端无法直接发起连接，唯一的办法是让客户端主动建立一条长连接并保持不关闭，WebSocket和MQTT天然适配这种场景，因为本质都是客户端先连出来,服务端借用这条现成通道反向推送。
服务器推送文件给指定客户端
大文件不能直接塞进WebSocket帧里，推荐做法是：服务端生成一个带时效签名的下载URL，通过长连接把URL推给指定客户端，客户端拿到URL后再用HTTP下载，这样既完成了“指定”的定向性,又避免了大报文对长连接通道的冲击。
服务器向指定客户端推送用什么语言写服务端
语言本身不限制方案落地,但生态成熟度差异明显：
- Java（Netty或Spring WebSocket）：企业级应用最多，Spring全家桶直接集成WebSocket,开箱即用。
- Go（gorilla/websocket）：并发性能好，内存占用低,适合高并发推送场景。
- Node.js（Socket.IO）：上手快，事件驱动模型和WebSocket天然匹配,适合中小型项目。
- Python（FastAPI + WebSocket）：开发效率高,适合内部工具或原型验证。
选语言看团队熟悉度，推送逻辑本身不复杂，瓶颈往往在连接数上来之后的服务端架构设计,而不是语言性能。
如何验证推送功能真正做到“指定”了
写个简单的测试脚本,思路如下：
- 同时开两个浏览器窗口，分别用两个账号登录,各建立一条WebSocket连接。
- 服务端只给账号A发一条测试消息。
- 观察账号B的窗口是否收到任何数据。
如果B没收到，说明定向逻辑正确，如果想更严谨，用抓包工具看一眼WebSocket帧的流向，确认消息只出现在A连接上，这个验证动作是行业里公认的“最小可行测试”,能覆盖绝大多数连接池误投的bug。
推送功能上线后监控哪些指标
- 连接数曲线：区分总连接数和活跃连接数，如果活跃比例持续走低,大概率是心跳配置有问题。
- 推送成功率：推送成功后客户端回执一个ACK，服务端统计N小时内的ACK比率,低于阈值时告警。
- 消息延迟分位数：从服务端发出到客户端收到的时间差,P95延迟超过500毫秒就该查链路了。
服务器推送消息到指定客户端的问题排查思路
用户反馈“收不到推送”,按这个顺序查：
- 先看客户端是否还“活着”,检查WebSocket连接状态是否为OPEN。
- 看服务端在线表里有没有这个用户的记录,没有就是身份认证或连接注册环节出了问题。
- 看服务端日志里有没有调用过
sendToUser，调了没报错但客户端没收到,多半是连接已经死了但服务端没感知到。 - 抓包确认数据是否出了服务端网卡，出去之后没到客户端,那就要查网络代理或防火墙策略。
常见问题
服务器怎么给指定客户端发数据而不发给其他人
关键在于连接维度的隔离，每个连接建立时绑定唯一userId，推送时按userId从在线表中取出对应连接，只往这条连接写数据，逻辑上不存在“广播时漏掉某个用户”的误伤可能，因为广播和定向走的是完全不同的代码路径，只要在线表的映射关系维护正确,定向推送天然就是点对点的。
WebSocket和SSE选哪个更合适
判断标准是业务是否需要客户端频繁向服务端发数据，需要双向高频互动的选WebSocket；只是服务端单方面推送通知、数据面板刷新、消息提醒的，选SSE更轻量，还能享受HTTP自带的编码和代理兼容性，SSE的断线自动重连是内建能力,WebSocket反而要自己写一套。
物联网设备场景下用MQTT还是WebSocket
多数情况下选MQTT，物联网设备往往运行在弱网环境，MQTT的协议开销小、QoS分级可靠、断线重连机制成熟，这些特性是WebSocket不具备的，WebSocket更适合浏览器和手机App这类电量相对充裕、网络相对稳定的终端，如果设备端的网络条件很好且业务简单，WebSocket也能胜任,但行业共识是物联网领域MQTT是更稳妥的默认选项。
首发原创文章，作者：王坚，如若转载，请注明出处：https://idctop.com/%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%a6%82%e4%bd%95%e5%8f%91%e6%95%b0%e6%8d%ae%e7%bb%99%e6%8c%87%e5%ae%9a%e5%ae%a2%e6%88%b7%e7%ab%af%ef%bc%8c%e6%80%8e%e4%b9%88%e5%ae%9e%e7%8e%b0%ef%bc%9f/
