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

Spring Boot + Netty + WebSocket 实现消息推送

news 2026/4/6 9:43:55

1、关于Netty

Netty 是一个利用 Java 的高级网络的能力，隐藏其背后的复杂性而提供一个易于使用的 API 的客户端/服务器框架。

2、Maven依赖

<dependencies><!-- https://mvnrepository.com/artifact/io.netty/netty-all --><dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.36.Final</version></dependency>
</dependencies>

3、SpringBootApplication

启动器中需要new一个NettyServer，并显式调用启动netty。

@SpringBootApplication
public class SpringCloudStudyDemoApplication {public static void main(String[] args) {SpringApplication.run(SpringCloudStudyDemoApplication.class,args);try {new NettyServer(12345).start();System.out.println("https://blog.csdn.net/moshowgame");System.out.println("http://127.0.0.1:6688/netty-websocket/index");}catch(Exception e) {System.out.println("NettyServerError:"+e.getMessage());}}
}

4、NettyServer

启动的NettyServer，这里进行配置

/*** NettyServer Netty服务器配置*/
public class NettyServer {private final int port;public NettyServer(int port) {this.port = port;}public void start() throws Exception {EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup group = new NioEventLoopGroup();try {ServerBootstrap sb = new ServerBootstrap();sb.option(ChannelOption.SO_BACKLOG, 1024);sb.group(group, bossGroup) // 绑定线程池.channel(NioServerSocketChannel.class) // 指定使用的channel.localAddress(this.port)// 绑定监听端口.childHandler(new ChannelInitializer<SocketChannel>() { // 绑定客户端连接时候触发操作@Overrideprotected void initChannel(SocketChannel ch) throws Exception {System.out.println("收到新连接");//websocket协议本身是基于http协议的，所以这边也要使用http解编码器ch.pipeline().addLast(new HttpServerCodec());//以块的方式来写的处理器ch.pipeline().addLast(new ChunkedWriteHandler());ch.pipeline().addLast(new HttpObjectAggregator(8192));ch.pipeline().addLast(new WebSocketServerProtocolHandler("/ws", null, true, 65536 * 10));ch.pipeline().addLast(new MyWebSocketHandler());}});ChannelFuture cf = sb.bind().sync(); // 服务器异步创建绑定System.out.println(NettyServer.class + " 启动正在监听：" + cf.channel().localAddress());cf.channel().closeFuture().sync(); // 关闭服务器通道} finally {group.shutdownGracefully().sync(); // 释放线程池资源bossGroup.shutdownGracefully().sync();}}
}

5、MyChannelHandlerPool

通道组池，管理所有websocket连接

/*** MyChannelHandlerPool* 通道组池，管理所有websocket连接*/
public class MyChannelHandlerPool {public MyChannelHandlerPool(){}public static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
}

6、MyWebSocketHandler

处理ws一下几种情况：

channelActive与客户端建立连接
channelInactive与客户端断开连接
channelRead0客户端发送消息处理

/*** NettyServer Netty服务器配置*/
public class NettyServer {private final int port;public NettyServer(int port) {this.port = port;}public void start() throws Exception {EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup group = new NioEventLoopGroup();try {ServerBootstrap sb = new ServerBootstrap();sb.option(ChannelOption.SO_BACKLOG, 1024);sb.group(group, bossGroup) // 绑定线程池.channel(NioServerSocketChannel.class) // 指定使用的channel.localAddress(this.port)// 绑定监听端口.childHandler(new ChannelInitializer<SocketChannel>() { // 绑定客户端连接时候触发操作@Overrideprotected void initChannel(SocketChannel ch) throws Exception {System.out.println("收到新连接");//websocket协议本身是基于http协议的，所以这边也要使用http解编码器ch.pipeline().addLast(new HttpServerCodec());//以块的方式来写的处理器ch.pipeline().addLast(new ChunkedWriteHandler());ch.pipeline().addLast(new HttpObjectAggregator(8192));ch.pipeline().addLast(new WebSocketServerProtocolHandler("/ws", "WebSocket", true, 65536 * 10));ch.pipeline().addLast(new MyWebSocketHandler());}});ChannelFuture cf = sb.bind().sync(); // 服务器异步创建绑定System.out.println(NettyServer.class + " 启动正在监听：" + cf.channel().localAddress());cf.channel().closeFuture().sync(); // 关闭服务器通道} finally {group.shutdownGracefully().sync(); // 释放线程池资源bossGroup.shutdownGracefully().sync();}}
}

7、socket.html

主要是连接ws，发送消息，以及消息反馈

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head><meta http-equiv="Content-Type" content="text/html; charset=utf-8" /><title>Netty-Websocket</title><script type="text/javascript">// by zhengkai.blog.csdn.netvar socket;if(!window.WebSocket){window.WebSocket = window.MozWebSocket;}if(window.WebSocket){socket = new WebSocket("ws://127.0.0.1:12345/ws");socket.onmessage = function(event){var ta = document.getElementById('responseText');ta.value += event.data+"\r\n";};socket.onopen = function(event){var ta = document.getElementById('responseText');ta.value = "Netty-WebSocket服务器。。。。。。连接 \r\n";};socket.onclose = function(event){var ta = document.getElementById('responseText');ta.value = "Netty-WebSocket服务器。。。。。。关闭 \r\n";};}else{alert("您的浏览器不支持WebSocket协议！");}function send(message){if(!window.WebSocket){return;}if(socket.readyState == WebSocket.OPEN){socket.send(message);}else{alert("WebSocket 连接没有建立成功！");}}</script>
</head>
<body>
<form onSubmit="return false;"><label>ID</label><input type="text" name="uid" value="${uid!!}" /> <br /><label>TEXT</label><input type="text" name="message" value="这里输入消息" /> <br /><br /> <input type="button" value="发送ws消息"onClick="send(this.form.uid.value+':'+this.form.message.value)" /><hr color="black" /><h3>服务端返回的应答消息</h3><textarea id="responseText" style="width: 1024px;height: 300px;"></textarea>
</form>
</body>
</html>

8、Controller

写好了html当然还需要一个controller来引导页面。

@RestController
public class IndexController {@GetMapping("/index")public ModelAndView index(){ModelAndView mav=new ModelAndView("socket");mav.addObject("uid", RandomUtil.randomNumbers(6));return mav;}
}

9、改造netty支持url参数

1.首先，调整一下加载handler的顺序，优先MyWebSocketHandler在WebSocketServerProtocolHandler之上。

ch.pipeline().addLast(new MyWebSocketHandler());
ch.pipeline().addLast(new WebSocketServerProtocolHandler("/ws", null, true, 65536 * 10));

2.其次，改造MyWebSocketHandler 的channelRead方法，首次连接会是一个FullHttpRequest类型，可以通过FullHttpRequest.uri()获取完整ws的URL地址，之后接受信息的话，会是一个TextWebSocketFrame类型。

public class MyWebSocketHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {System.out.println("与客户端建立连接，通道开启！");//添加到channelGroup通道组MyChannelHandlerPool.channelGroup.add(ctx.channel());}@Overridepublic void channelInactive(ChannelHandlerContext ctx) throws Exception {System.out.println("与客户端断开连接，通道关闭！");//添加到channelGroup 通道组MyChannelHandlerPool.channelGroup.remove(ctx.channel());}@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {//首次连接是FullHttpRequest，处理参数 by zhengkai.blog.csdn.netif (null != msg && msg instanceof FullHttpRequest) {FullHttpRequest request = (FullHttpRequest) msg;String uri = request.uri();Map paramMap=getUrlParams(uri);System.out.println("接收到的参数是："+JSON.toJSONString(paramMap));//如果url包含参数，需要处理if(uri.contains("?")){String newUri=uri.substring(0,uri.indexOf("?"));System.out.println(newUri);request.setUri(newUri);}}else if(msg instanceof TextWebSocketFrame){//正常的TEXT消息类型TextWebSocketFrame frame=(TextWebSocketFrame)msg;System.out.println("客户端收到服务器数据：" +frame.text());sendAllMessage(frame.text());}super.channelRead(ctx, msg);}@Overrideprotected void channelRead0(ChannelHandlerContext channelHandlerContext, TextWebSocketFrame textWebSocketFrame) throws Exception {}private void sendAllMessage(String message){//收到信息后，群发给所有channelMyChannelHandlerPool.channelGroup.writeAndFlush( new TextWebSocketFrame(message));}private static Map getUrlParams(String url){Map<String,String> map = new HashMap<>();url = url.replace("?",";");if (!url.contains(";")){return map;}if (url.split(";").length > 0){String[] arr = url.split(";")[1].split("&");for (String s : arr){String key = s.split("=")[0];String value = s.split("=")[1];map.put(key,value);}return  map;}else{return map;}}
}

3.html中的ws地址也进行改造

socket = new WebSocket("ws://127.0.0.1:12345/ws?uid=666&gid=777");

4.改造后控制台输出情况

收到新连接
与客户端建立连接，通道开启！
接收到的参数是：{"uid":"666","gid":"777"}
/ws
客户端收到服务器数据：142531:这里输入消息
客户端收到服务器数据：142531:这里输入消息
客户端收到服务器数据：142531:这里输入消息

failed: WebSocket opening handshake timed out

Spring Boot + Netty + WebSocket 实现消息推送

1、关于Netty Netty 是一个利用 Java 的高级网络的能力，隐藏其背后的复杂性而提供一个易于使用的 API 的客户端/服务器框架。 2、Maven依赖 <dependencies><dependency><gr…...

编程日记 2025/1/23 8:07:43

Python3 【字符串】：方法和函数使用示例手册

Python3 【字符串】：方法和函数使用示例手册 Python 提供了丰富的字符串处理方法和函数，以下是一些常用的方法和函数分类整理，并提供详细使用示例，简单易懂，值得收藏。 1. 字符串大小写转换 str.upper()：…...

编程日记 2025/1/23 8:01:33

数据结构与算法整理复习（一）：数据结构概念与线性表

目录第一章：绪论 1.1 数据结构的基本概念 1.2 算法与算法评价第二章：线性表 2.1 线性表的定义和基本操作 2.2 线性表的顺序表示（顺序表） 应用题 2.3 线性表的链式表达（链表） 2.3.1 单链表 2.3.2…...

编程日记 2025/1/23 7:59:31

【Block总结】PConv风车卷积，更大的感受野，提高特征提取能力|即插即用

论文信息论文标题：《Pinwheel-shaped Convolution and Scale-based Dynamic Loss for Infrared Small Target Detection》论文链接：https://arxiv.org/pdf/2412.16986 GitHub链接：https://github.com/JN-Yang/PConv-SDloss-Data 创新点 …...

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

Python新春烟花

目录系列文章写在前面技术需求完整代码下载代码代码分析 1. 程序初始化与显示设置 2. 烟花类 (Firework) 3. 粒子类 (Particle) 4. 痕迹类 (Trail) 5. 烟花更新与显示 6. 主函数 (fire) 7. 游戏循环 8. 总结注意事项写在后面系列文章序号直达链接爱…...

编程日记 2025/1/23 7:53:24

VirtualBox can‘t enable the AMD-V extension

个人博客地址：VirtualBox cant enable the AMD-V extension | 一张假钞的真实世界最近一次完成Deepin的系统更新后，进入VirtualBox创建的虚拟机（Widows10）时，出现以下错误： 根据网址“https://askubuntu.…...

编程日记 2025/1/23 7:51:22

掘金--创意标题匹配问题

问题描述在广告平台中，为了给广告主一定的自由性和效率，允许广告主在创造标题的时候以通配符的方式进行创意提交。线上服务的时候，会根据用户的搜索词触发的 bidword 对创意中的通配符（通配符是用成对 {} 括起来的字符串&#x…...

编程日记 2025/1/23 7:50:21

OBU和T-Box

OBU（On-Board Unit，车载单元）和T-Box（Telematics Box，远程信息处理控制单元）都是用于车联网和智能交通系统的车载设备，但它们的功能、应用场景和技术特点存在显著差异。以下是两者的详细对比&am…...

编程日记 2025/1/23 7:48:19

【PVE】Proxmox VE8.0+创建LXC容器安装docker

为了不影响PVE宿主机，通常使用套娃的形式安装Docker容器，再安装相关docker应用。首先在CT模板中创建 Linux 容器，推荐使用Debian。开启ssh登录，修改debian配置，安装docker 一、创建 LXC 容器 1、CT模板下载点击“模…...

编程日记 2025/1/23 7:47:18

一文大白话讲清楚webpack基本使用——11——chunkIds和runtimeChunk

文章目录一文大白话讲清楚webpack基本使用——11——chunkIds和runtimeChunk1. 建议按文章顺序从头看，一看到底，豁然开朗2. 啥是chunkIds3.怎么使用chunkIds4. 啥是runtimeChunk5. 怎么使用runtimeChunk 一文大白话讲清楚webpack基本使用——11——chun…...

编程日记 2025/1/23 7:37:06

Java 中的设计模式：经典与现代实践

Java 中的设计模式：经典与现代实践 1. 设计模式简介设计模式是一种软件开发中的思想，它为我们提供了一些经过验证的、能够应对常见问题的解决方案。学习和掌握设计模式能够让开发者在面对复杂的需求时，能够设计出更加灵活、可维护的代码。…...

编程日记 2025/1/23 7:29:59

DRG_DIP 2.0时代医院程序结构转型与数据结构优化研究

一、引言 1.1 DRG_DIP 2.0 改革背景与意义医保支付方式改革在医疗保障制度改革中占据着极为关键的地位，是推动医疗领域变革的核心力量。它犹如一把精准的手术刀，对医疗资源的合理分配、医疗服务质量的稳步提升以及医疗费用的有效控制起着决定性作用。…...

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

一部手机如何配置内网电脑同时访问内外网

做过运维的朋友都知道，最麻烦的是运维电脑不能远程，每次都得现场进行维护，明明客户那边有可以访问内网的电脑，怎么操作能将这台电脑能访问跟到外网呢，这样不就能通过远程软件远程了吗？嘿嘿。按以下步骤试试…...

编程日记 2025/1/23 7:23:47

国产低功耗带LCD驱动和触摸按键功能的MCU

以下是国产低功耗、集成LCD驱动和触摸按键功能的MCU精选型号及其核心特性，结合性能、功耗和适用场景进行综合推荐： 1.灵动微MM32L0130系列 257 核心特性：低功耗：待机模式功耗低至100nA，支持多种低功耗模式。 LCD驱动&a…...

编程日记 2025/1/23 7:20:43

XCP 协议基础

文章目录一、XCP 简介二、XCP的主要功能三、什么是标定四、什么时候进行标定五、标定的意义六、标定的三层架构XCP协议和 CCP协议的区别参考一、XCP 简介 XCP 协议的全称为 eXtended Calibration Protocol，即扩展标定协议。另有其他定义，XCP 协议全…...

编程日记 2025/1/23 7:16:33

Swift 中 Codable 和 Hashable 的理解

最近初学Swift，碰到下面的代码脑袋里冒出疑问：Codable 和 Hashable是啥？怎么理解？ struct Landmark: Hashable, Codable {var id: Intvar name: Stringvar park: Stringvar state: Stringvar description: String }针对上面的疑问…...

编程日记 2025/1/23 7:13:26

基于 WPF 平台实现成语游戏

一、引言在软件开发领域，利用各种框架开发有趣的应用程序是提升技术能力和增加开发乐趣的有效方式。WPF（Windows Presentation Foundation）作为微软强大的桌面应用开发框架，提供了丰富的图形和交互功能。本文将带领大家基于 WPF…...

编程日记 2025/1/23 7:08:14

2024“博客之星”——我的博客成长与技术洞察

🌟欢迎来到我的博客 —— 探索技术的无限可能！ 🌟博客的简介（文章目录） 目录一、引言二、个人成长与突破盘点（一）技能提升与知识拓展（二）创作风格与影响力提升&#xf…...

编程日记 2025/1/23 7:07:07

HTTPS协议简述

HTTPS 协议简介 HTTPS 是 HTTP Security 的组合，即在 HTTP 的基础上加入了安全性机制，主要通过加密传输、身份认证和数据完整性保护来确保通信的安全性。为了实现这一目标，HTTPS 引入了加密技术，包括对称加密、非对称加密和数…...

编程日记 2025/1/23 7:06:05

前沿技术趋势洞察：2024年技术的崭新篇章与未来走向！

引言时光飞逝，2024年已经来临，回顾过去一年，科技的迅猛进步简直让人目不暇接。在人工智能（AI）越来越强大的今天，我们不再停留在幻想阶段，量子计算的雏形开始展示它的无穷潜力，Web …...

编程日记 2025/1/23 7:02:59

OpenClaw语音交互方案：Qwen3.5-9B对接Whisper实现语音指令控制

OpenClaw语音交互方案：Qwen3.5-9B对接Whisper实现语音指令控制 1. 为什么需要语音交互能力？ 上周我在整理电脑文件时突然想到：既然OpenClaw能模拟人类操作电脑，为什么不给它加上耳朵呢？这个想法源于我经常双手沾满咖…...

编程新知 2026/4/6 8:36:39

Windows Cleaner：彻底解决C盘爆红问题的免费系统清理工具

Windows Cleaner：彻底解决C盘爆红问题的免费系统清理工具【免费下载链接】WindowsCleaner Windows Cleaner——专治C盘爆红及各种不服！ 项目地址: https://gitcode.com/gh_mirrors/wi/WindowsCleaner 你是否曾经面对C盘爆红的警告感到束手无策&a…...

编程新知 2026/4/6 8:02:34

Pixel Dream Workshop 创意激发：利用算法生成无限可能的艺术图案与纹理

Pixel Dream Workshop 创意激发：利用算法生成无限可能的艺术图案与纹理 1. 当算法遇见艺术：数字创作的新纪元在传统艺术创作中，设计师们常常需要花费大量时间手工绘制图案和纹理。而如今，Pixel Dream Workshop的出现彻底改变了…...

编程新知 2026/4/6 7:10:00

Infect工具完整教程：快速掌握Android设备病毒传播技术

Infect工具完整教程：快速掌握Android设备病毒传播技术【免费下载链接】infect Infect Any Android Device With Virus From Link In Termux 项目地址: https://gitcode.com/gh_mirrors/in/infect Infect是一款基于Bash的Android病毒传播工具，专为…...

编程新知 2026/4/6 6:41:27

MDK5.39编译报错Error:#268？手把手教你切换C99模式解决变量声明问题

MDK5.39编译报错Error:#268的深度解析与C99模式实战指南当你在Windows 11环境下使用MDK5.39进行ARM嵌入式开发时，突然遇到"Error:#268: declaration may not appear after executable statement in block"这样的编译错误，确实会让人感到困惑。…...

编程新知 2026/4/6 5:24:17

智能家居中枢：OpenClaw桥接Qwen3.5-9B实现语音控制图片检索

智能家居中枢：OpenClaw桥接Qwen3.5-9B实现语音控制图片检索 1. 为什么需要智能家居中的图片检索每次家庭聚会后整理照片都让我头疼。手机相册里堆积着上千张照片，当亲友们围坐在客厅想回顾某次旅行时，"找那张在雪山前跳起来的合影&qu…...

编程新知 2026/4/6 4:39:17

OpenClaw+Qwen3-14B自动化测试：3种Python脚本执行方案对比

OpenClawQwen3-14B自动化测试：3种Python脚本执行方案对比 1. 为什么需要测试Python脚本执行方案？ 上周我在尝试用OpenClaw自动化执行数据分析任务时，遇到了一个典型问题：同样的Python脚本，在不同执行环境下表现差异巨…...

编程新知 2026/4/6 4:22:41

Webpack Tree Shaking配置终极指南：如何在Awesome-Webpack中优化现代前端项目

Webpack Tree Shaking配置终极指南：如何在Awesome-Webpack中优化现代前端项目【免费下载链接】awesome-webpack A curated list of awesome Webpack resources, libraries and tools 项目地址: https://gitcode.com/gh_mirrors/aw/awesome-webpack Webpack …...

编程新知 2026/4/6 3:21:38