io.netty学习（十二）Netty 工作原理

news/2024/11/23 20:29:18/

目录

前言

Netty 模型

代码示例

引入Maven依赖

服务端的管道处理器

服务端主程序

客户端管道处理器

客户端主程序

测试运行

总结

前言

上一篇文章我们对 Reactor 模型进行了详细的讲解，下面我们就来探究一下 Netty 模型，Netty 采用的就是 主从 Reactor 多线程模型。

Netty 模型

下图就是 Netty 的工作原理图：

 执行流程如下：

  • Netty 抽象出两组线程池 BossGroup 专门负责接收客户端的连接，WorkerGroup 专门负责网络的读写。

  • BossGroup 和 WorkerGroup 类型都是 NioEventLoopGroup。

  • NioEventLoopGroup 相当于一个事件循环组，这个组中含有多个事件循环 ，每一个事件循环是 NioEventLoop。

  • NioEventLoop 表示一个不断循环的执行处理任务的线程， 每个NioEventLoop 都有一个selector ，用于监听绑定在其上的 socket 的网络通讯。

  • NioEventLoopGroup 可以有多个线程，即可以含有多个 NioEventLoop。

  • 每个Boss NioEventLoop 循环执行的步骤有3步 ：

    • 1、轮询accept 事件 ；

    • 2、处理accept 事件 ，与 client 建立连接 ，生成 NioScocketChannel，并将其注册到某个 worker NIOEventLoop 上的 selector；

    • 3、处理任务队列的任务 ， 即 runAllTasks。

  • 每个 Worker NIOEventLoop 循环执行的步骤 ：

    • 1、轮询read，write 事件 处理 I/O 事件， 即 read , write 事件；

    • 2、在对应NioScocketChannel处理；

    • 3、处理任务队列的任务 ， 即 runAllTasks；

  • 每个Worker NIOEventLoop 处理业务时，会使用pipeline(管道)，pipeline 中包含了channel ，即通过pipeline 可以获取到对应通道，管道中维护了很多的 处理器（ChannelHandler）。

代码示例

引入Maven依赖

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

服务端的管道处理器

public class NettyServerHandler extends ChannelInboundHandlerAdapter {//读取数据实际(这里我们可以读取客户端发送的消息)/*1. ChannelHandlerContext ctx:上下文对象, 含有 管道pipeline , 通道channel, 地址2. Object msg: 就是客户端发送的数据 默认Object*/@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {System.out.println("server ctx =" + ctx);Channel channel = ctx.channel();//将 msg 转成一个 ByteBuf//ByteBuf 是 Netty 提供的，不是 NIO 的 ByteBuffer.ByteBuf buf = (ByteBuf) msg;System.out.println("客户端发送消息是:" + buf.toString(CharsetUtil.UTF_8));System.out.println("客户端地址:" + channel.remoteAddress());}//数据读取完毕@Overridepublic void channelReadComplete(ChannelHandlerContext ctx) throws Exception {//writeAndFlush 是 write + flush//将数据写入到缓存，并刷新//一般讲，我们对这个发送的数据进行编码ctx.writeAndFlush(Unpooled.copiedBuffer("公司最近账户没啥钱，再等几天吧！", CharsetUtil.UTF_8));}//处理异常, 一般是需要关闭通道@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {ctx.close();}
}

服务端主程序

public class NettyServer {public static void main(String[] args) throws Exception {//创建BossGroup 和 WorkerGroup//说明//1. 创建两个线程组 bossGroup 和 workerGroup//2. bossGroup 只是处理连接请求 , 真正的和客户端业务处理，会交给 workerGroup完成//3. 两个都是无限循环//4. bossGroup 和 workerGroup 含有的子线程(NioEventLoop)的个数//   默认实际 cpu核数 * 2//EventLoopGroup bossGroup = new NioEventLoopGroup(1);EventLoopGroup workerGroup = new NioEventLoopGroup(); //8try {//创建服务器端的启动对象，配置参数ServerBootstrap bootstrap = new ServerBootstrap();//使用链式编程来进行设置bootstrap.group(bossGroup, workerGroup) //设置两个线程组.channel(NioServerSocketChannel.class) //bossGroup使用NioSocketChannel 作为服务器的通道实现.option(ChannelOption.SO_BACKLOG, 128) // 设置线程队列得到连接个数 option主要是针对boss线程组，.childOption(ChannelOption.SO_KEEPALIVE, true) //设置保持活动连接状态 child主要是针对worker线程组.childHandler(new ChannelInitializer<SocketChannel>() {//workerGroup使用 SocketChannel创建一个通道初始化对象																														(匿名对象)//给pipeline 设置处理器@Overrideprotected void initChannel(SocketChannel ch) throws Exception {//可以使用一个集合管理 SocketChannel， 再推送消息时，可以将业务加入到各个channel 对应的 NIOEventLoop 的 									taskQueue 或者 scheduleTaskQueuech.pipeline().addLast(new NettyServerHandler());}}); // 给我们的workerGroup 的 EventLoop 对应的管道设置处理器System.out.println(".....服务器 is ready...");//绑定一个端口并且同步, 生成了一个 ChannelFuture 对象//启动服务器(并绑定端口)ChannelFuture cf = bootstrap.bind(7788).sync();//给cf 注册监听器，监控我们关心的事件cf.addListener(new ChannelFutureListener() {@Overridepublic void operationComplete(ChannelFuture future) throws Exception {if (cf.isSuccess()) {System.out.println("服务已启动,端口号为7788...");} else {System.out.println("服务启动失败...");}}});//对关闭通道进行监听cf.channel().closeFuture().sync();} finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}

NioEventLoopGroup是用来处理I/O操作的多线程事件循环器。Netty 提供了许多不同的EventLoopGroup的实现来处理不同的传输。

上面的服务端应用中，有两个NioEventLoopGroup被使用。第一个叫作bossGroup，用来接收进来的连接。第二个叫作workerGroup，用来处理已经被接收的连接，一旦 bossGroup接收连接，就会把连接的信息注册到workerGroup上。

ServerBootstrap是一个NIO服务的引导启动类。可以在这个服务中直接使用Channel。

  • group方法用于 设置EventLoopGroup。

  • 通过Channel方法，可以指定新连接进来的Channel类型为NioServerSocketChannel类。

  • childHandler用于指定ChannelHandler，也就是前面实现的NettyServerHandler。

  • 可以通过option设置指定的Channel来实现NioServerSocketChannel的配置参数。

  • childOption主要设置SocketChannel的子Channel的选项。

  • bind用于绑定端口启动服务。

客户端管道处理器

public class NettyClientHandler extends ChannelInboundHandlerAdapter {//当通道就绪就会触发该方法@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {System.out.println("client ctx =" + ctx);ctx.writeAndFlush(Unpooled.copiedBuffer("老板，工资什么时候发给我啊？", CharsetUtil.UTF_8));}//当通道有读取事件时，会触发@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {ByteBuf buf = (ByteBuf) msg;System.out.println("服务器回复的消息:" + buf.toString(CharsetUtil.UTF_8));System.out.println("服务器的地址： "+ ctx.channel().remoteAddress());}//处理异常, 一般是需要关闭通道@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {cause.printStackTrace();ctx.close();}
}

客户端主程序

public class NettyClient {public static void main(String[] args) throws Exception {//客户端需要一个事件循环组EventLoopGroup group = new NioEventLoopGroup();try {//创建客户端启动对象//注意客户端使用的不是 ServerBootstrap 而是 BootstrapBootstrap bootstrap = new Bootstrap();//设置相关参数bootstrap.group(group) //设置线程组.channel(NioSocketChannel.class) // 设置客户端通道的实现类(反射).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast(new NettyClientHandler()); //加入自己的处理器}});System.out.println("客户端 ok..");//启动客户端去连接服务器端//关于 ChannelFuture 要分析，涉及到netty的异步模型ChannelFuture channelFuture = bootstrap.connect("127.0.0.1", 7788).sync();//给关闭通道进行监听channelFuture.channel().closeFuture().sync();} finally {group.shutdownGracefully();}}
}

客户端只需要一个NioEventLoopGroup就可以了。

测试运行

分别启动服务器 NettyServer 和客户端 NettyClient程序

服务端控制台输出内容：

.....服务器 is ready...
服务已启动,端口号为7788...
server ctx =ChannelHandlerContext(NettyServerHandler#0, [id: 0xa1b2233c, L:/127.0.0.1:7788 - R:/127.0.0.1:63239])
客户端发送消息是:老板，工资什么时候发给我啊？
客户端地址:/127.0.0.1:63239

客户端控制台输出内容：

客户端 ok..
client ctx =ChannelHandlerContext(NettyClientHandler#0, [id: 0x21d6f98e, L:/127.0.0.1:63239 - R:/127.0.0.1:7788])
服务器回复的消息:公司最近账户没啥钱，再等几天吧！
服务器的地址： /127.0.0.1:7788

至此，一个简单的基于Netty开发的服务端和客户端就完成了。

总结

本篇文章主要讲解了 Netty 的工作原理及简单应用。下节我们来讲解 Netty 的编解码。


http://www.ppmy.cn/news/562669.html

相关文章

Linux系统安装，教你安装一个属于自己的Linux系统

Linux系统安装，教你安装一个属于自己的Linux系统

一、Linux的简介 1.Linux抽象解释 肯定有人和我一样&#xff0c;很早就听说过Linux的这个词&#xff0c;但是又没接触过。然后随手百度一下看着满满的命令惊呆了&#xff0c;不知道从哪里开始学习。这种状况一直维持到我面试的时候&#xff0c;我不怕跟你们说&#xff0c;我拿着…
阅读更多...
Linux系统如何安装？

Linux系统如何安装？

近期有好多用户给小编留言&#xff0c;想知道关于linux系统安装&#xff0c;因为有一些想要使用linux操作系统的小伙伴却不知道怎么安装&#xff0c;那么linux系统应该如何安装呢&#xff1f;接下来小编就给大家带来linux安装系统的详细教程&#xff0c;为大家解答这个问题。 1…
阅读更多...
Linux安装教程（超详细版)

Linux安装教程（超详细版)

1.准备安装需要的工具 1.1centos7的下载 在下载页面 Download (centos.org) 点 CentOS-7-x86_64-DVD-2009.iso进行下载 ​ 点击x86_64 ​ ​ ​ 下载完成之后先不要管他 1.2 虚拟机的下载 VMware-workstation-full-12.5.7.20721 百度网盘上直接下载即可 链接&#…
阅读更多...
如何安装linux系统步骤

如何安装linux系统步骤

一、linux系统步骤 1&#xff1a;首先打开vmvare&#xff0c;然后点击创建虚拟机 2&#xff1a;接着点击典型模式 3&#xff1a; 然后选择稍后安装操作系统 4&#xff1a;选择linux和cent0s 64 位 5&#xff1a;给虚拟机命名&#xff0c;选择虚拟机的位置 6&#xff1a; 设置磁…
阅读更多...
Linux安装教程（超超超级详细）

Linux安装教程（超超超级详细）

在安装linux之前&#xff0c;我们需要安装一台虚拟机&#xff0c;将linux运行在虚拟机上。 VMware下载地址&#xff1a;下载 VMware Workstation Pro | CN Linux镜像下载地址&#xff1a;centos-7-isos-x86_64安装包下载_开源镜像站-阿里云 推荐版本&#xff1a;CentOS-7.0-…
阅读更多...
Redis入门(3)-hash

Redis入门(3)-hash

Redis存储的value也可是Hash类型&#xff0c;hash类型也称为hash表、字典等。hash表就是一个映射表map&#xff0c;也是键值对构成&#xff0c;为了与redis的key进行区分&#xff0c;hash中的key称为field。 1.hset key field value [field1 v1 [field2 v2 …]] 设置 key 指定…
阅读更多...
6、基础篇————渗透测试之渗透测试环境搭建

6、基础篇————渗透测试之渗透测试环境搭建

前言 要想正式开始渗透测试&#xff0c;那么就少不了一个较好的实验环境。 为了避免在本地物理主机上做实验引起电脑病毒或者引起系统的奔溃问题&#xff0c;我们选择使用VMware Workstations这一款软件来进行搭建虚拟环境&#xff0c;并且在其中安装需要使用的操作系统。 准…
阅读更多...
进程名称 → 对应的病毒/***

进程名称 → 对应的病毒/***

.exe → BF Evolution Mbbmanager.exe → 聪明基因 _.exe → Tryit Mdm.exe → Doly 1.6-1.7 Aboutagirl.exe → 初恋情人 Microsoft.exe → 传奇密码使者 Absr.exe → Backdoor.Autoupder M…
阅读更多...
最新文章

Copyright @ 2022~2023