👉 这是一个或许对你有用的社群

🐱 一对一交流/面试小册/简历优化/求职解惑，欢迎加入「芋道快速开发平台」知识星球。下面是星球提供的部分资料：

• 《项目实战（视频）》：从书中学，往事上“练”
• 《互联网高频面试题》：面朝简历学习，春暖花开
• 《架构 x 系统设计》：摧枯拉朽，掌控面试高频场景题
• 《精进 Java 学习指南》：系统学习，互联网主流技术栈
• 《必读 Java 源码专栏》：知其然，知其所以然

来源：blog.csdn.net/u013615903/article/details/129044283

• 项目背景
• 正文
• 一、项目架构
• 二、项目模块
• 三、业务流程
• 四、代码详解
• 五、测试
• 六、源码
• 后记

项目背景

最近公司某物联网项目需要使用socket长连接进行消息通讯，捣鼓了一版代码上线，结果BUG不断，本猿寝食难安，于是求助度娘，数日未眠项目终于平稳运行了，本着开源共享的精神，本猿把项目代码提炼成了一个demo项目，尽量摒弃了其中丑陋的业务部分，希望与同学们共同学习进步。

基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

• 项目地址：https://github.com/YunaiV/ruoyi-vue-pro
• 视频教程：https://doc.iocoder.cn/video/

正文

一、项目架构

本项目使用了netty、redis以及springboot2.2.0

二、项目模块

本项目目录结构如下图：

netty-tcp-core是公共模块，主要是工具类。netty-tcp-server是netty服务端，服务端仅作测试使用，实际项目中我们只使用了客户端。netty-tcp-client是客户端，也是本文的重点。

三、业务流程

我们实际项目中使用RocketMQ作为消息队列，本项目由于是demo项目于是改为了BlockingQueue。数据流为：

生产者->消息队列->消费者(客户端)->tcp通道->服务端->tcp通道->客户端。

当消费者接收到某设备发送的消息后，将判断缓存中是否存在该设备与服务端的连接，如果存在并且通道活跃则使用该通道发送消息，如果不存在则创建通道并在通道激活后立即发送消息，当客户端收到来自服务端的消息时进行响应的业务处理。

四、代码详解

1.消息队列

由于本demo项目移除了消息中间件，于是需要自己创建一个本地队列模拟真实使用场景

packageorg.example.client.controller;importorg.example.client.QueueHolder;importorg.example.client.model.NettyMsgModel;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RequestParam;importorg.springframework.web.bind.annotation.RestController;/***@authorReWind00*@date2023/2/1513:48*/@RestController@RequestMapping("/demo")publicclassDemoController{/***间隔发送两条消息*/@GetMapping("testOne")publicvoidtestOne(){QueueHolder.get().offer(NettyMsgModel.create("87654321","HelloWorld!"));try{Thread.sleep(5000);}catch(InterruptedExceptione){e.printStackTrace();}QueueHolder.get().offer(NettyMsgModel.create("87654321","HelloWorldToo!"));}/***任意发送消息**@paramimei*@parammsg*/@GetMapping("testTwo")publicvoidtestTwo(@RequestParamStringimei,@RequestParamStringmsg){QueueHolder.get().offer(NettyMsgModel.create(imei,msg));}/***连续发送两条消息第二条由于redis锁将会重新放回队列延迟消费*/@GetMapping("testThree")publicvoidtestThree(){QueueHolder.get().offer(NettyMsgModel.create("12345678","HelloWorld!"));QueueHolder.get().offer(NettyMsgModel.create("12345678","HelloWorldToo!"));}}

测试接口代码如上，调用testOne，日志如下：

可以看到第一条消息触发了客户端创建流程，创建后发送了消息，而5秒后的第二条消息直接通过已有通道发送了。

测试接口代码如上，调用testTwo，日志如下：

发送shutdown可以主动断开已有连接。

测试接口代码如上，调用testThree，日志如下：

可以看到第二条消息重新入列并被延迟消费了。

六、源码

https://gitee.com/jaster/netty-tcp-demo

基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

• 项目地址：https://github.com/YunaiV/yudao-cloud
• 视频教程：https://doc.iocoder.cn/video/

后记

本demo项目仅作学习交流使用，如果要应用到生产环境还有些许不足，有问题的同学可以留言交流。