构建异步高并发服务器：Netty与Spring Boot的完美结合

前言

在这里插入图片描述
「作者主页」：雪碧有白泡泡
「个人网站」：雪碧的个人网站
请添加图片描述

ChatGPT体验地址

请添加图片描述

文章目录

  • 前言
  • IO
  • Netty
      • 1. 引入依赖
      • 2. 服务端
      • 4. 客户端
      • 结果
  • 总结
      • 引导类-Bootstarp和ServerBootstrap
      • 连接-NioSocketChannel
      • 事件组-EventLoopGroup和NioEventLoopGroup
  • 送书活动

IO

在Java基础中，IO流是一个重要操作，先上八股

在这里插入图片描述

  1. BIO：传统的IO，同步阻塞，一个连接一个线程。一般不怎么使用
  2. AIO：JDK7引入的，异步非阻塞IO
  3. NIO：JDK1.4之后新的API，是多路复用，允许你一次性处理多个连接，而不需要等待每个连接的完成。（NIO 多路复用的核心概念是 Selector（选择器）和 Channel（通道）通过Channel、Buffer和Selector来进行数据传输和事件处理）

Netty

Netty是建立在NIO之上的一个框架，提供了更高级的抽象，如ChannelHandler和EventLoop，简化了事件处理和网络编程。
执行流程如下图
在这里插入图片描述

具有高性能，高可靠性，高可扩展性，还支持多种协议

我们以聊天流程为例

  1. 服务端启动
  2. 客户端启动
  3. 客户端启动连接上的时候，告知服务端
  4. 服务端读取到客户端的信息后立即发送信息给客户端
  5. 客户端收到信息后也发送给服务端

1. 引入依赖

  		<dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.76.Final</version></dependency>

2. 服务端

@Slf4j
public class NettyServer {private final static int PORT = 9012;public static void main(String[] args) throws InterruptedException {/*** 包含childGroup，childHandler，config，继承的父类AbstractBootstrap包括了parentGroup* */ServerBootstrap bootstrap = new ServerBootstrap();/*** EventLoopGroup用于处理所有ServerChannel和Channel的所有事件和IO* */EventLoopGroup parentGroup = new NioEventLoopGroup();EventLoopGroup childGroup = new NioEventLoopGroup();try {/*** 绑定两个事件组* */bootstrap.group(parentGroup, childGroup)/*** 初始化socket，定义tcp连接的实例* 内部调用ReflectiveChannelFactory实现对NioServerSocketChannel实例化* channelFactory是在AbstractBootstrap，也就是bootstrap的父类* */.channel(NioServerSocketChannel.class)/*** 添加处理器* ChannelInitializer包括了Set<ChannelHandlerContext> initMap** 这里比较有趣的事情就是使用被注册的channel去初始化其他的channel，* 等初始化结束后移除该channel* 所以SocketChannel是一个工具，** 在bind绑定端口的时候，进行初始化和注册initAndRegister，* 通过channel = channelFactory.newChannel()得到初始化channel* init(channel)真正开始初始化，* p = channel.pipeline()得到ChannelPipeline，* p.addLast开始添加* ch.eventLoop().execute将childHandler赋值并开启一个任务setAutoRead* 所以最后在监听读取的时候将会按照下面添加的channel进行读取** ChannelInitializer继承了ChannelInboundHandlerAdapter* 间接继承ChannelHandlerAdapter，ChannelInboundHandler，* */.childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();/*** ByteBuf和String之间的转换**  Decoders解密*  pipeline.addLast("frameDecoder", new {@link LineBasedFrameDecoder}(80))*  pipeline.addLast("stringDecoder", new {@link StringDecoder}(CharsetUtil.UTF_8))**  Encoder加密*  pipeline.addLast("stringEncoder", new {@link StringEncoder}(CharsetUtil.UTF_8))**  使用上面的加密解密后就可以直接读取字符串*   void channelRead({@link ChannelHandlerContext} ctx, String msg) {*       ch.write("Did you say '" + msg + "'?\n")*  }** */pipeline.addLast(new StringDecoder());pipeline.addLast(new StringEncoder());//自定义处理器pipeline.addLast(new ServerHandler1());}});ChannelFuture future = bootstrap.bind(PORT).sync();log.info("服务器已启动");future.channel().closeFuture().sync();} finally {parentGroup.shutdownGracefully();childGroup.shutdownGracefully();}}
}

这段代码实现了一个使用Netty框架的服务器端，它监听指定的端口并处理客户端的连接请求。

  1. 创建一个ServerBootstrap实例，用于启动服务器。
  2. 创建两个EventLoopGroup实例，parentGroup用于处理服务器的连接请求，childGroup用于处理客户端的数据通信。
  3. 绑定事件组到ServerBootstrap实例。
  4. 指定使用的NioServerSocketChannel作为服务器套接字通道的实现类。
  5. 添加处理器到ChannelInitializer中，该处理器负责初始化和配置新连接的SocketChannel。
  6. 在处理器中，通过ChannelPipeline添加了如下处理器：
    • StringDecoder：处理传入的字节数据，并将其解码为字符串。
    • StringEncoder：处理传出的字符串数据，并将其编码为字节。
    • ServerHandler1：自定义的处理器，用于处理客户端发送的消息。
  7. 绑定服务器的端口号，启动服务器。
  8. 等待服务器的关闭事件。
  1. 处理器
@Slf4j
public class ServerHandler1 extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {log.info("Client Address ====== {}，读取的信息：{}", ctx.channel().remoteAddress(),msg);ctx.channel().writeAndFlush("服务端writeAndFlush：我是服务端");ctx.fireChannelActive();//睡眠TimeUnit.MILLISECONDS.sleep(500);}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {//打印异常cause.printStackTrace();//关闭Channel连接，并通知ChannelFuture，通常是出现异常或者是完成了操作ctx.close();}
}

4. 客户端

@Slf4j
public class NettyClient {private final static int PORT = 9012;private final static String IP = "localhost";public static void main(String[] args) throws InterruptedException {/*** 服务端是ServerBootstrap，客户端是Bootstrap* Bootstrap引导channel连接，UDP连接用bind方法，TCP连接用connect方法* */Bootstrap bootstrap = new Bootstrap();/*** 服务端是EventLoopGroup，客户端是NioEventLoopGroup* 这里创建默认0个线程，一个线程工厂，一个选择器提供者* */NioEventLoopGroup eventLoopGroup = new NioEventLoopGroup();try {bootstrap.group(eventLoopGroup)/*** 初始化socket，定义tcp连接的实例* */.channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();/*** 进行字符串的转换* */pipeline.addLast(new StringDecoder(CharsetUtil.UTF_8));pipeline.addLast(new StringEncoder(CharsetUtil.UTF_8));/*** 自定义处理器* */pipeline.addLast(new ClientHandler1());}});ChannelFuture future = bootstrap.connect(IP, PORT).sync();log.info("客户端访问");future.channel().closeFuture().sync();} finally {eventLoopGroup.shutdownGracefully();}}
}

这段代码实现了一个使用Netty框架的客户端，它连接到指定的服务器端并与服务器进行通信。

  1. 创建一个Bootstrap实例，用于启动客户端。
  2. 创建一个NioEventLoopGroup实例，用于处理客户端的事件和IO操作。
  3. 绑定事件组到Bootstrap实例。
  4. 指定使用的NioSocketChannel作为客户端套接字通道的实现类。
  5. 添加处理器到ChannelInitializer中，该处理器负责初始化和配置客户端连接的SocketChannel。
  6. 在处理器中，通过ChannelPipeline添加了如下处理器：
    • StringDecoder：处理传入的字节数据，并将其解码为字符串。
    • StringEncoder：处理传出的字符串数据，并将其编码为字节。
    • ClientHandler1：自定义的处理器，用于处理与服务器之间的通信。
  7. 使用Bootstrap的connect()方法连接到指定的服务器IP和端口。
  8. 等待连接完成。
  9. 在连接成功后，打印日志信息。
  10. 等待客户端的关闭事件。
  1. 处理器
@Slf4j
public class ClientHandler1 extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {log.info("客户端读取的信息：{}", msg);ctx.channel().writeAndFlush("客户端writeAndFlush：我是客户端");TimeUnit.MILLISECONDS.sleep(5000);}/*** 当事件到达pipeline时候触发*/@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {ctx.channel().writeAndFlush("客户端：开始聊天");}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {cause.printStackTrace();//关闭Channel连接ctx.close();}}

在这里插入图片描述

结果

服务端日志

Client Address ====== /127.0.0.1:63740，读取的信息：客户端：开始聊天
Client Address ====== /127.0.0.1:63740，读取的信息：客户端writeAndFlush：我是客户端
Client Address ====== /127.0.0.1:63740，读取的信息：客户端writeAndFlush：我是客户端

客户端日志

客户端读取的信息：服务端writeAndFlush：我是服务端
客户端读取的信息：服务端writeAndFlush：我是服务端

总结

在这里插入图片描述

引导类-Bootstarp和ServerBootstrap

Bootstarp和ServerBootstrap被称为引导类，使你的应用程序和网络层相隔离。类似java项目的启动类。

连接-NioSocketChannel

客户端和服务端的启动都是采用配置的channel去连接处理器，这里服务端和客户端是用NioSocketChannel

事件组-EventLoopGroup和NioEventLoopGroup

客户端使用的是NioEventLoopGroup，服务端使用的是EventLoopGroup。 服务端和客户端的引导类启动后实现了配置的运行，客户端和服务端的连接都是采用NioSocketChannel。 连接的流程：

  1. 客户端创建一个channel
  2. channel对应一个EventLoop，EventLoop存放到NioEventLoopGroup中
  3. 服务端监听到后，创建一个channel连接，channel对应一个EventLoop，EventLoop存放到子的EventLoopGroup，父的事件组负责监听，一个事件对应一个子事件组。
    在这里可以认为父是boss监听组，子是工作组。
  4. 当客户端发送信息的时候，先被父监听，然后将异步调用工作组。
  5. 消息会经过事件组的所有处理器。

实际上服务端的事件组也可以使用NioEventLoopGroup。
![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/5e676670b49e40dd83155e76094e9017.png

送书活动

在这里插入图片描述

  • 🎁本次送书1~3本【取决于阅读量，阅读量越多，送的越多】👈
  • ⌛️活动时间：截止到2024-1月10号
  • ✳️参与方式：关注博主+三连（点赞、收藏、评论）
    购买链接：https://item.jd.com/13836258.html

在这里插入图片描述

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

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

相关文章

C#之反编译之路(二)

C#之反编译之路(二)

先阅读C#之反编译之路(一)可以增加文章连续性 阅读C#之反编译之路(一) 如何快速定位代码位置 用一个小小的例子举例,用户反馈新能源车牌号无法录入,燃油车牌正常,查看日志报如下错误 拿到关键字车牌号长度错误直接反编译代码 打开dnSpy.exe→加载项目→CtrlF打开搜索框→输入…
阅读更多...
学习笔记16——操作系统

学习笔记16——操作系统

学习笔记系列开头惯例发布一些寻亲消息&#xff0c;感谢关注&#xff01; 链接&#xff1a;https://www.mca.gov.cn/lljz/indexdetail.html?idd0afa7f6f36946319a206d61937f9b63&type0&t10.11199120579373845 八股——操作系统一些基础知识整理 一个java程序对应一个…
阅读更多...
极海APM32F003通过IEC 60730/60335功能安全认证，为产品安全保驾护航

极海APM32F003通过IEC 60730/60335功能安全认证，为产品安全保驾护航

近日&#xff0c;极海APM32F003系列工业级超值型MCU&#xff0c;已顺利通过IEC 60730/60335功能安全认证&#xff0c;并可提供符合CLASS B标准的功能安全设计套件&#xff0c;有助于客户减少认证时间与成本&#xff0c;快速推出稳定可靠的终端产品。 *VDE是德国的一个权威性电气…
阅读更多...
Spring - 配置支持多数据源

Spring - 配置支持多数据源

目录 SpringBoot整合多数据源整合步骤具体整合步骤如下&#xff1a;1、在application.properties中配置出多个数据源2、在代码中创建出mapper目录&#xff0c;在mapper目录下创建出不同数据源的目录创建出目录MySQL数据源的MapperSQL Server数据源的Mapper 3、创建config packa…
阅读更多...
Excel：通过excel将表数据批量转换成SQL语句

Excel：通过excel将表数据批量转换成SQL语句

这里有一张表《student》&#xff0c;里面有10条测试数据&#xff0c;现在将这10条测试数据自动生成 insert语句&#xff0c;去数据库 批量执行 P.S. 主要用到excel表格中的 CONCATENATE函数&#xff0c;将单元格里面的内容填入到sql里面对应的位置 1. 先写好一条insert语句&a…
阅读更多...
Vue使用printJS导出网页为pdf、printJS导出pdf

Vue使用printJS导出网页为pdf、printJS导出pdf

先放几个参考链接 感谢&#xff01; Vue使用PrintJS实现页面打印功能_vue print.js 设置打印pdf的大小-CSDN博客 前台导出pdf经验汇总 &#xff08;html2canvas.js和浏览器自带的打印功能-print.js&#xff09;以及后台一些导出pdf的方法_iqc后台管理系统怎么做到导出pdf-CSD…
阅读更多...
使用fs.renameSync(oldPath,newPath)方法，报错Error: EPERM: operation not permitted

使用fs.renameSync(oldPath,newPath)方法，报错Error: EPERM: operation not permitted

出错翻译&#xff1a;表示操作被拒绝&#xff0c;因为当前用户没有足够的权限执行该操作。这可能是由于文件或目录 的权限设置不正确或操作系统限制所致 出现错误场景&#xff1a;使用element-plus的Upload 上传功能&#xff1b;后端使用Nodejs提供的fs.renameSync(oldPath,ne…
阅读更多...
可碧教你C++——位图

可碧教你C++——位图

本章节是哈希的延申 可碧教你C——哈希http://t.csdnimg.cn/3R8TU 一文详解C——哈希 位图 位图是基于哈希表的原理产生的一种新的container——bitset 基于哈希映射的原理&#xff0c;我们在查找的时候&#xff0c;可以直接去定址到元素的具体位置&#xff0c;然后直接访问该…
阅读更多...
OpenAI ChatGPT-4开发笔记2024-04：Chat之Tool之2：multiple functions

OpenAI ChatGPT-4开发笔记2024-04：Chat之Tool之2：multiple functions

从程序员到ai Expert 1 定义参数和函数2 第一轮chatgpt3 第一轮结果和function定义全部加入prompt再喂给chatgpt4 大结局7 参考资料 上一篇解决了调用一个函数的问题。这一篇扩展为调用3个。n个自行脑补。 1 定义参数和函数 #1.设定目标 import json import openai#1.定义para…
阅读更多...
基于JavaWeb+BS架构+SpringBoot+Vue协同推荐的黔醉酒业白酒销售系统的设计和实现

基于JavaWeb+BS架构+SpringBoot+Vue协同推荐的黔醉酒业白酒销售系统的设计和实现

基于JavaWebBS架构SpringBootVue基于协同推荐的黔醉酒业白酒销售系统系统的设计和实现 文末获取源码Lun文目录前言主要技术系统设计功能截图订阅经典源码专栏Java项目精品实战案例《500套》 源码获取 文末获取源码 Lun文目录 1.2 国内外研究概况 2 1.3 研究的内容 2 1.4 本章…
阅读更多...
mybatisPlus 将List＜String＞字段转成json字符串,使用JacksonTypeHandler以及自定义类型处理器实现

mybatisPlus 将List＜String＞字段转成json字符串,使用JacksonTypeHandler以及自定义类型处理器实现

文章目录 场景使用JacksonTypeHandler实现类型转换自定义StringListTypeHandler处理器实现 场景 项目中经常需要将List转成json存储到配置文件中, mybatisPlus默认实现了JacksonTypeHandler&#xff0c;GsonTypeHandler&#xff0c;FastjsonTypeHandler&#xff0c;也可以自定义…
阅读更多...
JAVA基础语句1

JAVA基础语句1

目录 前言 一.JAVA特性 简单 面向对象 分布式 多线程 二.关键字 三.对象和类 对象 类 构造方法 创建对象 访问实例变量和方法 源文件声明规则 Java 包 import 语句 总结 前言 这里参考了&#xff1a;Java 教程 | 菜鸟教程 (runoob.com) 第一个必须是&#xff1a; hello world&a…
阅读更多...
Github 2024-01-09Python开源项目日报 Top10

Github 2024-01-09Python开源项目日报 Top10

根据Github Trendings的统计&#xff0c;今日(2024-01-09统计)共有10个项目上榜。根据开发语言中项目的数量&#xff0c;汇总情况如下&#xff1a; 开发语言项目数量Python项目10Jupyter Notebook项目1 Payloads All The Things - 有用的Web应用程序安全负载和绕过列表 创建…
阅读更多...
带前后端H5即时通讯聊天系统源码

带前后端H5即时通讯聊天系统源码

带有前后端的H5即时通讯聊天系统源码。该源码是一个开源的即时通信demo&#xff0c;需要前后端配合使用。它的主要目的是为了促进学习和交流&#xff0c;并为大家提供开发即时通讯功能的思路。尽管该源码提供了许多功能&#xff0c;但仍需要进行自行开发。该项目最初的开发初衷…
阅读更多...
C#.Net学习笔记——CLR核心机制

C#.Net学习笔记——CLR核心机制

一、CLR基本介绍 &#xff08;1&#xff09;C(Common) L&#xff08;Language&#xff09; R&#xff08;Runtime&#xff09; IL的运行环境 &#xff08;2&#xff09;从下图可以看到&#xff0c;我们的计算机会先把我们写的语言&#xff0c;编写成IL语言&#xff0c;再给计…
阅读更多...
Gartner发布2024年SASE融合战略路线图

Gartner发布2024年SASE融合战略路线图

向云计算和远程工作的转变增加了 SASE 需求&#xff0c;以实现从任何设备的安全访问。安全和风险管理领导者必须将网络和安全融合到一两个明确合作的 SASE 供应商产品中&#xff0c;并淘汰遗留的边界系统。 主要发现 安全访问服务边缘 (SASE) 框架为混合劳动力以及设备、分支机…
阅读更多...
java基础之HashMap练习题

java基础之HashMap练习题

应用了 外循环&#xff0c;自循环&#xff0c;Lambda表达式&#xff0c;keySet&#xff08;&#xff09;方法&#xff0c;values&#xff08;&#xff09;方法&#xff0c;Entry对象 &#xff0c;entrySet&#xff08;&#xff09;方法 Map集合框架 1:(Map)关于下列Map 接口中…
阅读更多...
AI问答系统与对话机器人服务（一）

AI问答系统与对话机器人服务（一）

知识要点 微软认知服务中知识库服务的申请与搭建 如何用REST API访问知识库数据 微软认知服务中机器人服务的申请与搭建 如何无缝集成知识库服务与机器人服务 建立知识库 什么叫QnA Maker? 知识库&#xff0c;就是人们总结出的一些历史知识的集合&#xff0c;存储、索引…
阅读更多...
Windows 双网卡链路聚合解决方案

Windows 双网卡链路聚合解决方案

Windows 双网卡链路聚合解决方案 链路聚合方案1&#xff1a;Metric介绍操作 方案2&#xff1a;NetSwitchTeam介绍操作 方案3&#xff1a;NIC介绍操作 方案4&#xff1a;Intel PROSet 链路聚合 指将多个物理端口汇聚在一起&#xff0c;形成一个逻辑端口&#xff0c;以实现出/入…
阅读更多...
办公文档，私人专用

办公文档，私人专用

一、安装Minio 1.1、创建文件夹&#xff0c;并在指定文件夹中下载minio文件 cd /opt mkdir minio cd minio touch minio.log wget https://dl.minio.io/server/minio/release/linux-amd64/minio1.2、赋予minio文件执行权限 chmod 777 minio1.3、启动minio ./minio server /…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023