TextWebSocketHandler 和 @ServerEndpoint 各自实现 WebSocket 服务器

news/2025/2/12 15:37:28/

TextWebSocketHandler@ServerEndpoint 都可以用于实现 WebSocket 服务器,但它们属于不同的技术栈,使用方式和功能有一些区别。以下是它们的对比:


1. 技术栈对比

特性TextWebSocketHandler (Spring)@ServerEndpoint (Java EE/JSR-356)
所属框架Spring FrameworkJava EE 标准 (JSR-356)
依赖需要 Spring Boot 或 Spring WebSocket需要 Java EE 或兼容的实现(如 Tyrus)
配置方式基于 Spring 配置,使用 WebSocketConfigurer基于注解,直接标记类为 WebSocket 端点
功能扩展支持 Spring 的拦截器、消息转换等功能功能较为基础,依赖 Java EE 标准
适用场景适合 Spring 项目适合纯 Java EE 项目或非 Spring 项目

2. 功能对比

TextWebSocketHandler (Spring)
  • 是 Spring 框架提供的 WebSocket 处理器。
  • 需要配合 WebSocketConfigurer 进行配置。
  • 支持更高级的功能,如:
    • 消息转换(将消息转换为 Java 对象)。
    • 拦截器(在连接建立或关闭时执行额外逻辑)。
    • 与 Spring 生态无缝集成(如依赖注入、AOP 等)。

示例:

import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;public class MyTextWebSocketHandler extends TextWebSocketHandler {@Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {System.out.println("收到客户端消息: " + message.getPayload());session.sendMessage(new TextMessage("服务器回复: " + message.getPayload()));}@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {System.out.println("客户端连接成功: " + session.getId());}@Overridepublic void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {System.out.println("客户端断开连接: " + session.getId());}
}

配置类:

import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {@Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {registry.addHandler(new MyTextWebSocketHandler(), "/ws").setAllowedOrigins("*");}
}

@ServerEndpoint (Java EE/JSR-356)
  • 是 Java EE 标准(JSR-356)提供的注解。
  • 直接标记一个类为 WebSocket 端点。
  • 功能较为基础,适合简单的 WebSocket 应用。
  • 需要依赖 Java EE 或兼容的实现(如 Tyrus)。

示例:

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;@ServerEndpoint("/ws")
public class MyWebSocketServer {@OnOpenpublic void onOpen(Session session) {System.out.println("客户端连接成功: " + session.getId());}@OnMessagepublic void onMessage(String message, Session session) {System.out.println("收到客户端消息: " + message);try {session.getBasicRemote().sendText("服务器回复: " + message);} catch (IOException e) {e.printStackTrace();}}@OnClosepublic void onClose(Session session) {System.out.println("客户端断开连接: " + session.getId());}@OnErrorpublic void onError(Session session, Throwable throwable) {System.out.println("发生错误: " + throwable.getMessage());}
}

3. 使用场景对比

场景TextWebSocketHandler (Spring)@ServerEndpoint (Java EE/JSR-356)
Spring 项目推荐使用,与 Spring 生态无缝集成不推荐,功能较为基础
非 Spring 项目不适用推荐使用,纯 Java EE 标准
需要高级功能(如拦截器)支持不支持
需要消息转换支持不支持
需要依赖注入支持不支持

4. 总结

  • TextWebSocketHandler

    • 属于 Spring 框架,功能强大,支持拦截器、消息转换等高级特性。
    • 适合 Spring 项目,尤其是需要与 Spring 生态集成的场景。
  • @ServerEndpoint

    • 属于 Java EE 标准,功能较为基础,使用简单。
    • 适合非 Spring 项目或简单的 WebSocket 应用。

如果你的项目基于 Spring,推荐使用 TextWebSocketHandler;如果是纯 Java EE 项目或非 Spring 项目,可以使用 @ServerEndpoint


http://www.ppmy.cn/news/1571456.html

相关文章

嵌入式知识点总结 操作系统 专题提升(五)-内存

针对于嵌入式软件杂乱的知识点总结起来,提供给读者学习复习对下述内容的强化。 目录 1.在1G内存的计算机能否malloc(1.2G)?为什么? 2.malloc能申请多大的空间? 3.内存管理有哪几种方式? 4.什…

除了Redux-Thunk,还有哪些常用的中间件?

除了 Redux-Thunk,以下是一些常用的 Redux 中间件: 1. Redux-Saga 功能:用于处理复杂的异步操作和副作用。使用生成器函数,使得异步代码更易于管理和测试。安装:npm install redux-saga2. Redux-Logger 功能:用于记录每个 dispatched action 和状态变化,便于调试。安装…

利用爬虫获取1688商品详情的实战案例指南

在电商领域,快速获取商品数据对于市场分析、竞争情报收集以及产品选品至关重要。1688作为国内领先的B2B电商平台,拥有海量的商品资源。通过爬虫技术,我们可以高效地获取这些商品的详细信息,为商业决策提供有力支持。 一、1688商品…

链式前向星_记录

链式前向星总结 测试时尽量使用静态数组 测试时尽量使用静态数组 value和next数组是可以被cnt瞬间归零的,所以只要静态给狗他俩的空间即可,使用cnt0相当于立刻清空所有内容。 head也应该设置为静态,因为无论如何head的值都要全改为-1&#x…

日志2025.2.9

日志2025.2.9 1.增加了敌人挥砍类型 2.增加了敌人的死亡状态 在敌人身上添加Ragdoll,死后激活布偶模式 public class EnemyRagdoll : MonoBehaviour { private Rigidbody[] rigidbodies; private Collider[] colliders; private void Awake() { rigidbodi…

【物联网】电子电路基础知识

文章目录 一、基本元器件1. 电阻2. 电容3. 电感4. 二极管(1)符号(2)特性(3)实例分析5. 三极管(1)符号(2)开关特性(3)实例6. MOS管(产效应管)(1)符号(2)MOS管极性判定(3)MOS管作为开关(4)MOS管vs三极管7. 门电路(1)与门(2)或门(3)非门二、常用元器件…

在服务器部署JVM后,如何评估JVM的工作能力,比如吞吐量

在服务器部署JVM后,评估其工作能力(如吞吐量)可以通过以下步骤进行: 1. 选择合适的基准测试工具 JMH (Java Microbenchmark Harness):适合微基准测试,测量特定代码片段的性能。Apache JMeter:…

TCP传输层协议

TCP 全称为 "传输控制协议(Transmission Control Protocol"). 人如其名, 要对数据的传 输进行一个详细的控制。 对于TCP的学习主要就是要知道TCP协议报头之中各个字段的作用 除了数据之外总共报头加起来是20个字节 16位源端口号与目的端口号 这是最容易理解的两…