基于Netty-WebSocket构建高性能实时通信服务

引言：WebSocket在现代应用中的重要性

在当今实时交互应用盛行的时代，WebSocket协议已成为实现双向通信的核心技术。相比传统的HTTP轮询，WebSocket提供了：

  • 真正的全双工通信
  • 极低的延迟（毫秒级）
  • 高效的连接管理
  • 减少不必要的网络流量

本文将介绍如何使用netty-websocket-spring-boot-starter构建高性能WebSocket服务，实现消息收发功能。

一、Netty-WebSocket框架简介

Netty作为高性能NIO框架，是构建WebSocket服务的理想选择。netty-websocket-spring-boot-starter封装了Netty的复杂配置，提供Spring Boot风格的开发体验：

核心优势：
  1. 高性能：基于Netty的Reactor模型，支持百万级并发
  2. 简化开发：注解驱动，类似Spring MVC
  3. 无缝集成：与Spring生态完美融合
  4. 可扩展性：支持自定义编解码器和拦截器
<!-- Maven依赖 -->
<dependency><groupId>org.yeauty</groupId><artifactId>netty-websocket-spring-boot-starter</artifactId><version>0.11.0</version>
</dependency>

二、构建WebSocket服务端

1. 基础服务端实现
@ServerEndpoint(path = "/chat", port = "8080")
@Component
public class ChatServer {private static final Map<String, Session> sessions = new ConcurrentHashMap<>();@OnOpenpublic void onOpen(Session session) {String clientId = session.id().asShortText();sessions.put(clientId, session);System.out.println("客户端连接: " + clientId);}@OnClosepublic void onClose(Session session) {String clientId = session.id().asShortText();sessions.remove(clientId);System.out.println("客户端断开: " + clientId);}@OnMessagepublic void onMessage(Session session, String message) {System.out.println("收到消息: " + message);// 处理消息逻辑processMessage(session, message);}// 发送消息给指定客户端public static void sendToClient(String clientId, String message) {Session session = sessions.get(clientId);if (session != null && session.isOpen()) {session.sendText(message);}}// 广播消息public static void broadcast(String message) {sessions.values().forEach(session -> {if (session.isOpen()) {session.sendText(message);}});}
}
2. 核心注解解析
注解说明示例
@ServerEndpoint定义服务端点@ServerEndpoint(path="/ws", port="8080")
@OnOpen连接建立时触发public void onOpen(Session session)
@OnClose连接关闭时触发public void onClose(Session session)
@OnMessage收到消息时触发public void onMessage(String message)
@OnError发生错误时触发public void onError(Throwable error)

三、消息收发实战

1. 接收客户端消息
@OnMessage
public void onMessage(Session session, String message) {try {// 解析JSON消息JsonNode json = new ObjectMapper().readTree(message);// 消息路由switch (json.get("type").asText()) {case "TEXT":handleTextMessage(session, json);break;case "IMAGE":handleImageMessage(session, json);break;case "COMMAND":handleCommand(session, json);break;default:sendError(session, "未知消息类型");}} catch (Exception e) {sendError(session, "消息格式错误");}
}private void handleTextMessage(Session session, JsonNode json) {String content = json.get("content").asText();String sender = json.get("sender").asText();// 业务处理逻辑MessageEntity message = messageService.saveMessage(sender, content);// 回复客户端session.sendText("{\"status\":\"SUCCESS\",\"messageId\":" + message.getId() + "}");
}
2. 发送消息给客户端
// 发送文本消息
public void sendTextMessage(String clientId, String content) {Session session = sessions.get(clientId);if (session != null && session.isOpen()) {JsonObject message = new JsonObject();message.addProperty("type", "TEXT");message.addProperty("content", content);message.addProperty("timestamp", System.currentTimeMillis());session.sendText(message.toString());}
}// 发送二进制数据（如图片）
public void sendImage(String clientId, byte[] imageData) {Session session = sessions.get(clientId);if (session != null && session.isOpen()) {session.sendBinary(imageData);}
}// 带回调的异步发送
public void sendWithCallback(String clientId, String message) {Session session = sessions.get(clientId);if (session != null && session.isOpen()) {session.sendText(message, new FutureCallback<Void>() {@Overridepublic void onSuccess(Void result) {log.info("消息发送成功");}@Overridepublic void onFailure(Throwable t) {log.error("消息发送失败", t);// 重试逻辑}});}
}

四、高级功能实现

1. 心跳检测机制
@OnEvent
public void onEvent(Session session, Object evt) {if (evt instanceof IdleStateEvent) {IdleStateEvent idleEvent = (IdleStateEvent) evt;if (idleEvent.state() == IdleState.READER_IDLE) {// 30秒无读操作，发送心跳session.sendText("{\"type\":\"HEARTBEAT\"}");} else if (idleEvent.state() == IdleState.WRITER_IDLE) {// 60秒无写操作，关闭连接session.close();}}
}
2. 消息压缩传输
@OnMessage
public void onBinaryMessage(Session session, byte[] compressedData) {try {// 解压缩消息String message = decompress(compressedData);// 处理消息...} catch (IOException e) {log.error("解压缩失败", e);}
}private String decompress(byte[] compressed) throws IOException {ByteArrayInputStream bis = new ByteArrayInputStream(compressed);GZIPInputStream gis = new GZIPInputStream(bis);return new String(gis.readAllBytes(), StandardCharsets.UTF_8);
}
3. 分布式会话管理
@Service
public class RedisSessionStore {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;public void saveSession(String sessionId, SessionInfo info) {redisTemplate.opsForValue().set("ws:session:" + sessionId, info,1, TimeUnit.HOURS);}public SessionInfo getSessionInfo(String sessionId) {return (SessionInfo) redisTemplate.opsForValue().get("ws:session:" + sessionId);}
}// 会话信息类
@Data
public class SessionInfo {private String userId;private String deviceId;private String nodeId;private long lastActiveTime;
}

五、最佳实践建议

  1. 连接管理优化

    • 设置合理的最大连接数
    • 实现连接数监控和告警
    @Bean
public ServerEndpointConfig config() {return ServerEndpointConfig.builder().port(8080).bossEventLoopGroup(2) // boss线程数.workerEventLoopGroup(16) // worker线程数.maxFramePayloadLength(1048576) // 1MB.build();
}

  2. 安全防护措施

    • 实现WSS(WebSocket Secure)
    • 添加身份验证
    • 防止DDoS攻击
    @BeforeHandshake
public void handshake(Session session, @RequestParam String token) {if (!authService.validate(token)) {session.close();}
}

  3. 性能监控指标

    指标说明健康值
    活动连接数当前在线连接< 80% 最大容量
    消息吞吐量消息/秒根据业务调整
    平均延迟消息处理时间< 100ms
    错误率失败消息比例< 0.1%

六、客户端实现示例

// WebSocket客户端
const socket = new WebSocket('wss://yourserver.com/chat');// 连接建立
socket.onopen = () => {console.log('连接已建立');// 发送文本消息socket.send(JSON.stringify({type: 'TEXT',content: '你好服务器!'}));
};// 接收消息
socket.onmessage = (event) => {const message = JSON.parse(event.data);console.log('收到消息:', message);

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.tpcf.cn/pingmian/87120.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

咸虾米项目总结1--const用法

咸虾米项目总结1--const用法

在 UniApp&#xff08;或 Vue 3&#xff09;中&#xff0c;声明一个空对象可使用下面这2种写法&#xff1a; // 写法1 const a ref(null);// 写法2 const a ref({}); 在UniApp中&#xff0c;const a ref()用法概述&#xff1a; 用途&#xff1a; 创建一个响应式引用&#x…
阅读更多...
在mac下手动编译迁移的android版webrtc组件

在mac下手动编译迁移的android版webrtc组件

我原先使用的android版webrtc是在linux下编译的&#xff0c;现在因为某些原因需要把整个库迁移到mac下编译。 把代码迁移完后&#xff0c;正常是需要通过gclient sync 重新构建编译环境&#xff0c;但是由于网络限制等方面原因&#xff0c;会导致完成的比较慢。 在摸索一阵后…
阅读更多...
Linux 命令：mkdir

Linux 命令：mkdir

Linux mkdir 命令详细教程 一、mkdir 命令的基本功能 mkdir&#xff08;Make Directory&#xff09;是 Linux 系统中用于创建新目录&#xff08;文件夹&#xff09;的基础命令。它支持一次性创建单个或多个目录&#xff0c;以及递归创建多层目录结构&#xff0c;是文件系统操…
阅读更多...
Django 数据迁移全解析：makemigrations migrate 常见错误与解决方案

Django 数据迁移全解析：makemigrations migrate 常见错误与解决方案

1. 迁移机制与底层原理 在 Django 中&#xff0c;ORM&#xff08;Object-Relational Mapping&#xff09;是连接模型&#xff08;Model&#xff09;和数据库结构的桥梁。Django 鼓励开发者通过编写 Python 类&#xff08;模型&#xff09;来定义业务数据结构&#xff0c;而不是…
阅读更多...
SuperGlue：使用图神经网络学习特征匹配

SuperGlue：使用图神经网络学习特征匹配

摘要 本文提出了 SuperGlue&#xff0c;一种神经网络&#xff0c;用于通过联合寻找对应关系并排除不可匹配点来匹配两组局部特征。匹配结果通过求解一个可微的最优传输问题来估计&#xff0c;该问题的代价由一个图神经网络预测。我们引入了一种基于注意力的灵活上下文聚合机制…
阅读更多...
ssh -T git@github.com失败后解决方案

ssh -T git@github.com失败后解决方案

这个错误表示你的 SSH 连接无法到达 GitHub 服务器。以下是详细解决方案&#xff0c;按照优先级排序&#xff1a; 首选解决方案&#xff1a;使用 SSH over HTTPS&#xff08;端口 443&#xff09; 这是最有效的解决方案&#xff0c;因为许多网络会阻止 22 端口&#xff1a; …
阅读更多...
从苹果事件看 ARM PC市场的未来走向

从苹果事件看 ARM PC市场的未来走向

最近&#xff0c;苹果宣布部分搭载 Intel 处理器的 Mac 不再支持最新的 macOS 系统更新&#xff0c;这一消息犹如一颗石子投入平静湖面&#xff0c;激起层层涟漪。它不仅让 Intel 芯片在 Mac 产品线上彻底成为历史&#xff0c;也促使我们重新审视 PC 行业的发展脉络&#xff0c…
阅读更多...
vue + element ui 实现超出宽度展示..，鼠标移入显示完整内容

vue + element ui 实现超出宽度展示..，鼠标移入显示完整内容

vue element ui 实现超出宽度展示…&#xff0c;鼠标移入显示完整内容 代码理念&#xff1a; 当高度大于对应行数的高度 则说明需要展示"…" 子组件 <template><div class"tooltip"><div ref"tooltipRef" :class"[tooltip…
阅读更多...
HarmonyOSNext应用无响应全解析：从机制到实战的卡死问题排查

HarmonyOSNext应用无响应全解析：从机制到实战的卡死问题排查

HarmonyOSNext应用无响应全解析&#xff1a;从机制到实战的卡死问题排查 ##Harmony OS Next ##Ark Ts ##教育 本文适用于教育科普行业进行学习&#xff0c;有错误之处请指出我会修改。 喂喂喂&#xff01;应用卡成PPT了&#xff1f;点啥都没反应&#xff1f;别慌&#xff01…
阅读更多...
git 迁移之获取原库所有分支

git 迁移之获取原库所有分支

以下是一个安全的 Bash 脚本&#xff0c;用于将远程 Git 仓库的所有分支检出到本地&#xff08;自动跳过已存在的分支&#xff09;&#xff1a; #!/bin/bash# 获取所有远程分支&#xff08;排除 HEAD&#xff09; remote_branches$(git branch -r | grep -v HEAD\|->)# 循环…
阅读更多...
设计模式 | 适配器模式

设计模式 | 适配器模式

适配器模式&#xff08;Adapter Pattern&#xff09; 是结构型设计模式中的连接器大师&#xff0c;它允许不兼容接口的类能够协同工作。本文将深入探索适配器模式的核心思想、实现技巧以及在C中的高效实践&#xff0c;解决现实开发中的接口兼容性问题。 为什么需要适配器模式 …
阅读更多...
RTL 级机器人电机控制器的 FPGA 设计

RTL 级机器人电机控制器的 FPGA 设计

借助Verilog&#xff0c;在FPGA中实现了带编码器的两台电机的电机控制系统的RTL级设计。 介绍 借助硬件描述语言 (HDL) Verilog 和 AMD Vivado 设计套件&#xff0c;在 AMD Spartan-7 FPGA 中实现带编码器的两个电机的控制器系统的 RTL 设计。 在这个项目中&#xff0c;使用了搭…
阅读更多...
4_Flink CEP

4_Flink CEP

Flink CEP 1、何为CEP&#xff1f; CEP&#xff0c;全称为复杂事件处理&#xff08;Complex Event Processing&#xff09;&#xff0c;是一种用于实时监测和分析数据流的技术。 CEP详细讲解&#xff1a; CEP是基于动态环境的事件流的分析技术&#xff0c;事件是状态变化&am…
阅读更多...
容器基础知识2-K8s 和 Docker 的关系与管理逻辑详解

容器基础知识2-K8s 和 Docker 的关系与管理逻辑详解

K8s 和 Docker 的关系与管理逻辑详解 一、先搞懂&#xff1a;Docker 和 K8s 分别是做什么的&#xff1f; Docker&#xff08;容器工具&#xff09;&#xff1a;好比「集装箱工厂」&#xff0c;负责把应用和依赖打包成标准化容器&#xff08;类似集装箱&#xff09;&#xff0…
阅读更多...
QT MaintenanceTool 登录无法找到 QtAccount 凭据

QT MaintenanceTool 登录无法找到 QtAccount 凭据

亲测有效&#xff1a;QT6 Maintenance Tool 登录问题_qt6 maintenancetool-CSDN博客 将ini这个配置文件移出文件夹后&#xff0c;在切换自己账户登录即可
阅读更多...
华为云Flexus+DeepSeek征文｜利用华为云一键部署 Dify 平台并接入 DeepSeek 大模型，构建长篇文章生成助手

华为云Flexus+DeepSeek征文｜利用华为云一键部署 Dify 平台并接入 DeepSeek 大模型，构建长篇文章生成助手

目录 前言 1 华为云一键部署 Dify 平台 1.1 华为云 Dify 平台介绍 1.2 部署过程介绍 1.3 登录 Dify 平台 2 接入华为云 ModelArts Studio 中的 DeepSeek 大模型 3 构建长篇文章生成助手 3.1 简要介绍长篇文章生成助手 3.2 开始节点 3.3 生成标题和大纲&#xff08;LL…
阅读更多...
js的一些基础概念总结

js的一些基础概念总结

1.变量声明 首先js变量声明有三种&#xff0c;var&#xff0c;const&#xff0c;let&#xff0c;这三种变量声明中我们第一优先使用const&#xff0c;需要改变这个值的时候我们用ley&#xff0c;var是尽量不去使用。 那么我们现在来总结一下三种声明变量的区别。首先是var let …
阅读更多...
防 XSS和CSRF 过滤器（Filter）

防 XSS和CSRF 过滤器（Filter）

会话管理存在问题&#xff1a; 1.服务集群部署或者是分布式服务如何实现会话共享 2.会话的不同存储地方的安全性问题 答&#xff1a; 会话共享 可以使用后端集中管理(redis)或者客户端管理 &#xff08;jwt&#xff09;&#xff1b; 存储安全性 这个还真的没有太好的方式&…
阅读更多...
鸿蒙容器组件 WaterFlow、FlowItem解析：动态瀑布流布局实践

鸿蒙容器组件 WaterFlow、FlowItem解析：动态瀑布流布局实践

一、引言&#xff1a;不规则布局的智能化解决方案 在图片社交、电商导购、资讯聚合等现代应用场景中&#xff0c;瀑布流布局以其灵活的空间利用率和自然的视觉流动感成为界面设计的重要选择。鸿蒙提供的 WaterFlow 与 FlowItem 组件&#xff0c;通过智能布局算法与声明式语法&…
阅读更多...
概率密度基本概念

概率密度基本概念

概率密度&#xff08;Probability Density&#xff09;是概率论中用于描述随机变量分布的一种方式&#xff0c;特别适用于连续随机变量。它并不是一个概率值&#xff0c;而是表示单位范围内的概率大小或“浓度”。更具体地说&#xff0c;概率密度表示在某个特定值附近&#xff…
阅读更多...
最新文章

Copyright @ 2022~2023