当前位置：首页 > news >正文

基于 Netty + SpringBoot + Vue 的高并发实时聊天系统设计与实现

news 来源：原创 2025/7/19 2:06:32

一、系统架构设计

1.1 整体架构图

+------------------+       WebSocket (wss)      +------------------+       Netty TCP       +------------------+
|     Vue前端      | <-------------------------> | SpringBoot网关   | <------------------> | Netty服务集群    |
| (WebSocket客户端)|        消息加密/心跳        | (WebSocket适配层) |        长连接        | (业务逻辑处理)   |
+------------------+       心跳检测              +------------------+        管理          +------------------+↓+------------------+| Redis集群        || (在线状态同步)   |+------------------+

1.2 技术选型解析
• SpringBoot：提供REST API网关、用户认证、消息路由

• Netty：核心通信框架，处理10W+级长连接，支持自定义协议

• Vue：实现实时消息推送的SPA前端，使用WebSocket API通信

• Redis：存储在线状态、离线消息、分布式Session

• Protobuf：二进制序列化协议，提升传输效率

二、核心原理剖析

2.1 WebSocket协议优势
• 双向全双工通信，避免了HTTP轮询的开销

• 减少TCP连接次数，建立一次连接即可持续通信

• 支持文本/二进制数据传输，适合JSON/Protobuf格式

2.2 Netty高性能架构
线程模型

+------------------+       +------------------+       +------------------+
|   BossGroup      |       |   WorkerGroup    |       |   SubReactor     |
| (Acceptor线程)   | <---> | (I/O处理线程)    | <---> | (业务处理线程)   |
+------------------+       +------------------+       +------------------+

• BossGroup：处理TCP三次握手，建立连接

• WorkerGroup：处理Channel读写事件

• SubReactor：多线程处理业务逻辑，避免阻塞

关键组件
• ChannelPipeline：消息处理流水线，包含编解码器、业务处理器

• EventLoop：单线程处理多个Channel，保证IO操作的原子性

• MemoryManager：内存池化技术，减少GC压力

三、实战开发指南

3.1 后端实现（SpringBoot + Netty）

3.1.1 依赖配置

<dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.86.Final</version>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

3.1.2 Netty服务端核心代码

public class ChatServer {private final int port;public ChatServer(int port) {this.port = port;}public void run() throws InterruptedException {EventLoopGroup bossGroup = new NioEventLoopGroup(2);EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) {ch.pipeline().addLast(new HttpServerCodec()) // HTTP编解码.addLast(new HttpObjectAggregator(65536)) // HTTP聚合.addLast(new WebSocketServerProtocolHandler("/ws")) // WebSocket协议升级.addLast(new ProtobufDecoder(ChatMessage.getDefaultInstance())) // Protobuf解码.addLast(new ChatServerHandler()); // 自定义业务处理器}});ChannelFuture f = b.bind(port).sync();f.channel().closeFuture().sync();} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}

3.1.3 消息处理器实现

public class ChatServerHandler extends SimpleChannelInboundHandler<ChatMessage> {private static final AttributeKey<String> USER_ID = AttributeKey.valueOf("userId");@Overrideprotected void channelRead0(ChannelHandlerContext ctx, ChatMessage msg) {String userId = ctx.channel().attr(USER_ID).get();RedisUtils.setOnlineStatus(userId, ctx.channel());// 消息路由：广播给所有在线用户broadcastMessage(msg);}private void broadcastMessage(ChatMessage message) {ChannelGroup channels = ChatServer.getChannelGroup();channels.writeAndFlush(message).addListener(future -> {if (!future.isSuccess()) {System.err.println("消息发送失败: " + future.cause());}});}
}

3.2 前端实现（Vue3 + WebSocket）

3.2.1 WebSocket连接管理

// src/utils/websocket.js
class WebSocketClient {constructor(url) {this.url = url;this.ws = null;this.reconnectTimer = null;}connect() {return new Promise((resolve, reject) => {this.ws = new WebSocket(this.url);this.ws.onopen = () => {console.log('WebSocket连接成功');resolve();};this.ws.onmessage = (event) => {const message = JSON.parse(event.data);this.handleMessage(message);};this.ws.onclose = () => {console.log('连接关闭，尝试重连...');this.reconnect();};});}reconnect() {this.reconnectTimer = setInterval(() => {console.log('尝试重新连接...');this.connect().catch(err => console.error(err));}, 5000);}
}

3.2.2 Vue组件集成

<template><div class="chat-container"><div v-for="msg in messages" :key="msg.id" class="message">{{ msg.sender }}: {{ msg.content }}</div><input v-model="newMessage" @keyup.enter="sendMessage" /></div>
</template><script setup>
import { ref, onMounted } from 'vue';
import WebSocketClient from '@/utils/websocket';const wsClient = new WebSocketClient('wss://api.example.com/ws');
const messages = ref([]);
const newMessage = ref('');onMounted(async () => {await wsClient.connect();wsClient.onMessage = (data) => {messages.value.push(data);};
});const sendMessage = () => {if (newMessage.value.trim()) {wsClient.send(JSON.stringify({type: 'CHAT',content: newMessage.value}));newMessage.value = '';}
};
</script>

四、性能测试报告

4.1 测试环境

组件	配置
服务器	4核8G CentOS 7.9
Netty版本	4.1.86.Final
并发用户数	50,000
消息大小	1KB JSON
测试工具	JMeter 5.6 + WebSocketSampler

4.2 测试结果

指标	数值
最大连接数	85,000+
吞吐量 (msg/s)	122,300
平均延迟	38ms
CPU利用率峰值	68%
内存消耗	1.2GB/10万连接

4.3 性能优化措施

内存优化：启用Netty内存池，减少GC频率至每分钟3次
线程调优：根据CPU核数动态调整EventLoopGroup线程数
协议优化：使用Protobuf替代JSON，消息体积减少62%
连接保活：配置心跳机制（读超时60s，写超时30s）

五、扩展功能实现

5.1 消息可靠性保证

// 消息持久化到MySQL
@Async
public void saveMessage(ChatMessage message) {chatMessageRepository.save(message);
}// 离线消息存储到Redis
public void storeOfflineMessage(String userId, ChatMessage message) {redisTemplate.opsForList().rightPush("offline:"+userId, JSON.toJSONString(message));
}

5.2 安全增强

// SSL/TLS配置
SslContext sslContext = SslContextBuilder.forServer(new File("server.crt"), new File("server.key")
).build();// 消息鉴权拦截器
public class AuthHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelActive(ChannelHandlerContext ctx) {if (!validateToken(ctx)) {ctx.close();}}
}

六、总结与展望

本文实现的系统在5万并发下仍能保持亚秒级响应，验证了Netty在高并发场景下的可靠性。未来可扩展方向：

引入MQTT协议支持物联网设备接入
使用gRPC-Web实现双向流式通信
集成WebSocket网关集群（如Spring Cloud Gateway）
实现消息轨迹追踪（ELK日志分析）

基于 Netty + SpringBoot + Vue 的高并发实时聊天系统设计与实现

编程日记 2025/7/19 2:06:32

根据当前日期计算并选取上一个月和上一个季度的日期范围，用于日期控件的快捷选取功能

代码如下： <el-date-picker v-model"value" type"monthrange" align"right" unlink-panels range-separator"至"start-placeholder"开始月份" end-placeholder"结束月份" :picker-options"pic…...

编程日记 2025/6/29 0:20:29

Spring Boot 使用 jasypt配置明文密码加密

引入依赖 <dependency><groupId>com.github.ulisesbocchio</groupId><artifactId>jasypt-spring-boot-starter</artifactId><version>3.0.4</version> </dependency>添加配置 jasypt:encryptor:password: pssw0rd&Hubt2ec…...

编程日记 2025/7/15 21:41:00

ubuntu下docker安装mongodb-支持单副本集

1.mogodb支持事务的前提 1) MongoDB 版本：确保 MongoDB 版本大于或等于 4.0，因为事务支持是在 4.0 版本中引入的。 2) 副本集配置：MongoDB 必须以副本集（Replica Set）模式运行，即使是单节点副本集&#x…...

编程日记 2025/7/19 2:06:31

科技赋能，开启现代健康养生新潮流

在科技与生活深度融合的当下，健康养生也迎来了全新的打开方式。无需传统医学的介入，借助现代科学与智能设备，我们能以更高效、精准的方式守护健康。饮食管理步入精准化时代。利用手机上的营养计算 APP，录入每日饮食&#xff0…...

编程日记 2025/7/17 1:27:26

《安徽日报》聚焦珈和科技AI创新：智慧虫情测报护航夏粮提质丰产

5月7日，《安徽日报》焦点新闻版块以《高科技助力田管，确保夏粮丰收——为4300多万亩小麦守好防线》为题，深度报道了农业科技在夏粮生产中的关键作用。其中，珈和科技自主研发的AI虫情测报一体机作为绿色防控、农业智慧化的标杆被重…...

编程日记 2025/7/19 2:04:45

企业级 Go 多版本环境部署指南-Ubuntu CentOS Rocky全兼容实践20250520

🛠️ 企业级 Go 多版本环境部署指南-Ubuntu / CentOS / Rocky 全兼容实践兼顾多版本管理、安全合规、最小权限原则与 CI/CD 可复现性，本指南以 Go 官方 toolchain 为主，结合 asdf 实现跨语言统一管理，并剔除已过时的 GVM。支持 …...

编程日记 2025/7/19 1:50:00

MCP 协议传输机制大变身：抛弃 SSE，投入 Streamable HTTP 的怀抱

在技术的江湖里，变革的浪潮总是一波接着一波。最近，模型上下文协议（MCP）的传输机制就搞出了大动静，决定和传统的服务器发送事件（SSE）说拜拜，转身拥抱 Streamable HTTP，这…...

编程日记 2025/7/14 9:10:53

Windows 上配置 Docker，Docker 的基本原理和用途，以及如何在 Docker 中运行程序

Windows 系统上的 Docker 安装与使用指南 1. Windows 上配置 Docker 检查系统要求：使用 64 位 Windows 10/11，BIOS 已启用硬件虚拟化（VT-x/AMD-V）。Windows 版本最好更新到 2004 及以上（内部版本19041）&am…...

编程日记 2025/6/28 22:04:57

CBCharacteristic：是「特征」还是「数据通道」？

目录名词困惑：两种中文译法的由来官方定义 & 开发者视角乐高类比：文件夹与文件智能手表实例：Characteristic 长什么样？iOS 代码实战：读 / 写 / 订阅小结 & Best Practice 1. 名词困惑：为什么有两…...

编程日记 2025/7/14 23:18:57

【JavaEE】多线程

线程在Java中，鼓励多线程编程。进程可以满足并发编程，但是效率不高（创建、销毁、调度时间都比较长，这些都消耗在申请资源上了），而线程就不一样。线程也叫“轻量级进程”，创建、销毁、调度都更…...

编程日记 2025/7/19 1:56:28

docker- Harbor 配置 HTTPS 协议的私有镜像仓库

Harbor通过配置 HTTPS 协议，可以确保镜像传输的安全性，防止数据被窃取或篡改。本文将详细介绍如何基于 Harbor 配置 HTTPS 协议的私有镜像仓库。 1.生成自建ca证书 [rootdocker01 ~]# mkdir -p /liux/softwares/harbor/certs/custom/{ca,server,client…...

编程日记 2025/7/18 5:02:13

[SpringBoot]Spring MVC(5.0)----留言板

Spring留言板实现预期结果可以发布并显示点击提交后，显示并清除输入框并且再次刷新后，不会清除下面的缓存约定前后端交互接口 Ⅰ 发布留言 url : /message/publish . param(参数) : from,to,say . return : true / false . Ⅱ 查询留言 url : /messag…...

编程日记 2025/7/19 2:05:38

Jules 从私有预览阶段推向全球公测

每周跟踪AI热点新闻动向和震撼发展想要探索生成式人工智能的前沿进展吗？订阅我们的简报，深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同，从行业内部的深度分析和实用指南中受益。不要错过这个机会，成为AI领…...

编程日记 2025/7/16 5:55:17

vLLM框架高效原因分析

vLLM框架在模型推理中以高效出名，主要基于以下核心原理和技术优化，这些设计使其在处理大语言模型时显著提升性能： 一、PagedAttention：动态显存管理技术 vLLM的核心创新在于PagedAttention，灵感源自操作系统的虚拟内存…...

编程日记 2025/7/19 1:59:10

【Git】常用命令大全

以下是 Git 的常用命令大全，分为几个常见类别，便于理解和使用： 1. 初始化与克隆初始化本地仓库：git init克隆远程仓库到本地：git clone <repository_url> 2. 添加与提交添加指定文件到暂存区：git…...

编程日记 2025/7/19 2:00:04

pycharm无需科学上网工具下载插件的解决方案

以下是两种无需科学上网即可下载 PyCharm 插件的解决思路： 方法 1：设置 PyCharm 代理打开 PyCharm选择菜单：File → Settings → Appearance & Behavior → System Settings → HTTP Proxy在代理设置中进行如下配置： 代理地…...

编程日记 2025/7/19 1:43:46

学习threejs，使用Physijs物理引擎，使用DOFConstraint自由度约束，模拟小车移动

👨‍⚕️ 主页： gis分享者 👨‍⚕️ 感谢各位大佬点赞👍 收藏⭐ 留言📝 加关注✅! 👨‍⚕️ 收录于专栏：threejs gis工程师文章目录一、🍀前言1.1 ☘️Physijs 物理引擎1.1.1 ☘️…...

编程日记 2025/7/17 1:26:32

仓颉开发语言入门教程：常见UI组件介绍和一些问题踩坑

幽蓝君发现一个问题，仓颉开发语言距离发布马上一年了，一些知名App已经使用仓颉开发了许多功能，但是网络上关于仓颉开发语言的教程少之又少，系统性的教程更是没有，仓颉官网的文档也远远不如ArkTS详尽。现阶段对于想学…...

编程日记 2025/7/16 23:54:50

[Git] 初识 Git 与安装入门

告别文件噩梦：初识 Git 与安装入门嘿，朋友！不知道你是不是也遇到过这样的情况：你在写一份重要的文档、报告，或者更常见的，一段代码时，为了安全起见，怕改错了回不去，或者…...

编程日记 2025/6/28 22:05:09

海康威视摄像头C#开发指南：从SDK对接到安全增强与高并发优化

一、海康威视SDK核心对接流程 1. 开发环境准备官方SDK获取：从海康开放平台下载最新版SDK（如HCNetSDK.dll、PlayCtrl.dll）。依赖项安装：确保C运行库（如vcredist_x86.exe）与S…...

编程日记 2025/7/19 1:59:10

大语言模型 14 - Manus 超强智能体开源版本 OpenManus 上手指南

写在前面 Manus 是由中国初创公司 Monica.im 于 2025 年 3 月推出的全球首款通用型 AI 智能体（AI Agent），旨在实现“知行合一”，即不仅具备强大的语言理解和推理能力，还能自主执行复杂任务，直接交付完整成…...

编程日记 2025/7/17 4:31:34

使用 LibreOffice 实现各种文档格式转换（支持任何开发语言调用和 Linux + Windows 环境）[全网首发，保姆级教程，建议收藏]

以下能帮助你可以使用任何开发语言，在任何平台都能使用 LibreOffice 实现 Word、Excel、PPT 等文档的自动转换，目前展示在 ASP.NET Core 中为 PDF的实战案例，其他的文档格式转换逻辑同理。 📦 1. 安装 LibreOffice 🐧…...

编程日记 2025/7/15 9:06:10

CentOS Stream 9 中部署 MySQL 8.0 MGR（MySQL Group Replication）一主两从高可用集群

🐇明明跟你说过：个人主页 🏅个人专栏：《MySQL技术精粹》🏅 🔖行路有良友，便是天堂🔖 目录一、前言 1、MySQL 8.0 中的高可用方案 2、适用场景二、环境准备 1、系统环境说明…...

编程日记 2025/6/29 1:11:42

软考中级软件设计师——计算机网络篇

一、计算机网络体系结构 1.OSI七层模型 1. 物理层（Physical Layer） 功能：传输原始比特流（0和1），定义物理介质（如电缆、光纤）的电气、机械特性。关键设备：中继器&#…...

编程日记 2025/7/19 2:05:41

RK3568 OH5.1 源码编译及问题

安装编译器和二进制工具在源码根目录下执行prebuilts脚本，安装编译器及二进制工具。 bash build/prebuilts_download.sh在源码根目录执行如下指令安装hb编译工具： python3 -m pip install --user build/hb使用build.sh脚本编译源码进入源码根目录&…...

编程日记 2025/6/28 23:17:42

【razor】回环结构导致的控制信令错位：例如发送端收到 SR的问题

一、razor的echo程序根据对 yuanrongxi/razor 仓库的代码和 echo 测试程序相关实现的分析，下面详细解读 echo 程序中 RTCP sender report（SR）、receiver report（RR）回显的问题及项目的解决方式。 1. 问题背景在 RTP/RTCP 体系下，SR（Sender Report）由发送端周期性发…...

编程日记 2025/7/19 1:53:05

leetcode hot100：三、解题思路大全：哈希（两数之和、字母异位词分组、最长连续序列）、双指针（移动零、盛最多水的容器、三数之和、接雨水）

哈希两数之和给定一个整数数组 nums 和一个整数目标值 target，请你在该数组中找出和为目标值 target 的那两个整数，并返回它们的数组下标。你可以假设每种输入只会对应一个答案，并且你不能使用两次相同的元素。你可以按任意顺序返…...

编程日记 2025/7/19 1:46:53

MySQL 8.0 OCP 1Z0-908 161-170题

Q161.Examine this command, which executes successfully: cluster.addInstance ( ‘:’,{recoveryMethod: ‘clone’ 1}) Which three statements are true? (Choose three.) A)The account used to perform this recovery needs the BACKUP_ ADMIN privilege. B)A target i…...

编程日记 2025/7/19 2:03:48

相关文章：