Java WebSocket服务端如何接收客户端消息消息传输协议详解【进阶】-js教程-PHP中文网

java websocket服务端接收消息核心是确保@onmessage正确触发且参数类型匹配：文本帧用string，二进制帧用byte[]或bytebuffer；消息边界由协议保证，无需手动切分；超大消息需调优缓冲区配置。

java websocket服务端如何接收客户端消息消息传输协议详解【进阶】

Java WebSocket服务端接收消息，核心就两件事：确保 @OnMessage 方法被正确触发，且传入参数能准确还原客户端原始数据类型和内容边界。其他所谓“协议解析”在标准 API 层几乎全自动完成，手动干预反而容易出错。

为什么 `@OnMessage` 有时收不到字符串？

常见现象是客户端发了 "{\"type\":\"ping\",\"id\":123}"，但服务端 @OnMessage 方法没被调用，或抛 DecodeException。

检查客户端是否真的发送了 文本帧（TEXT frame）：WebSocket 协议中，字符串必须用 opcode 0x1 发送；若误用二进制帧（opcode 0x2），@OnMessage(String) 不会匹配，需改用 @OnMessage(byte[]) 或自定义 Decoder.Text
确认服务端方法签名与消息类型严格对应：@OnMessage 只支持一种参数类型（String、byte[]、ByteBuffer、PongMessage 等），不能重载多个 @OnMessage 处理不同格式
若客户端使用分片（fragmented frames），标准 javax.websocket API 会自动重组为完整消息再投递给 @OnMessage，无需手动拼接 —— 但前提是所有分片属于同一条消息且 FIN 位正确

`@OnMessage` 的参数类型怎么选？

选错参数类型会导致消息丢弃或解码失败，不是“兼容处理”，而是协议层面不匹配。

Java JDK 25

Java JDK 25 来自 OpenJDK 官方归档，版本为 JDK 25，本条下载地址已指向官方 Windows x64 zip 安装包直链，适合调试旧项目或兼容旧版 Java 运行环境。

下载

@OnMessage(String message)：仅接收 UTF-8 编码的文本帧，且整个 payload 必须可解析为合法 UTF-8 字符串；遇到非法字节序列（如截断的多字节字符）会抛 DecodeException
@OnMessage(byte[] message)：接收原始字节，不校验编码，适合传输二进制协议（如 Protocol Buffers）、或你明确知道编码但不想依赖 UTF-8 自动解码的场景
@OnMessage(ByteBuffer buffer)：适用于大消息流式处理，buffer.position() 和 buffer.limit() 定义有效数据范围；注意 buffer 是只读视图，不可直接修改
不要用 InputStream 参数 —— javax.websocket 规范未定义对该类型的默认 decoder，运行时会报 DeploymentException

消息边界在哪？JSON 解析前要不要自己切分？

不需要。WebSocket 协议本身以“消息（message）”为单位交付，不是字节流。每个 @OnMessage 调用对应一个完整的、由客户端封装好的 WebSocket 消息。

客户端调用 send("abc") → 服务端 @OnMessage(String) 收到完整 "abc"；调用两次 send("a")、send("b") → 服务端触发两次 @OnMessage，分别收到 "a" 和 "b"
即使客户端底层用了分片（例如发一个 5MB JSON 分成 10 帧），只要符合 RFC6455，服务端收到的仍是一个完整 String 或 byte[]，不会出现半截 JSON
唯一需要你介入边界的场景：客户端把多条逻辑消息打包进单个 WebSocket 消息（如 "{msg1} {msg2}" 连发无分隔），这违反了 WebSocket 设计本意，应由应用层协议约定（比如每条加换行符），而非依赖传输层

接收大消息时容易卡死或 OOM？

默认配置下，Tomcat/Jetty 对单条 WebSocket 消息大小有限制（通常 8KB–64KB），超限会直接关闭连接，且不触发 @OnError，只在容器日志里报 warn。

Spring Boot 项目：在 application.yml 中显式扩大缓冲区：

server:
  tomcat:
    max-http-post-size: 10MB
websocket:
  text-message-size: 10MB
  binary-message-size: 10MB

纯 javax.websocket 部署（如独立 WAR）：需在 web.xml 或容器配置中设置 maxTextMessageBufferSize 和 maxBinaryMessageBufferSize
注意：增大缓冲区不解决根本问题；若频繁收发 >1MB 消息，建议改用分块上传 + 后端异步组装，避免阻塞 IO 线程

真正容易被忽略的是：WebSocket 消息到达顺序与发送顺序严格一致，但 @OnMessage 执行是**单线程 per session** 的 —— 同一个客户端的多条消息绝不会并发进入你的方法体，所以无需对 session 或共享变量加锁；但跨 session 的广播操作（如群聊转发），仍需考虑线程安全。