从源码角度解析Netty的React模式是如何工作的

Netty 支持多种实现方式,比如nio,epoll 等,本文以nio的实现方式进行讲解。

1.EventLoop :

事件循环看,简单来说就是一个死循环监听事件,如果事件来了,处理掉。通常做法就是开启一个独立线程,一直循环。

伪代码:

while (queue.waitForMessage()) {
queue.processNextMessage();
}

2.EventLoopGroup:

一组(多个)事件循环。

3.bossGroup 和 workGroup

EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();

server端bossGroup 是负责 NioServerSocketChannel 处理客户端连接请求的,一个应用程序如果只开了一个端口(严格来说就是没有多个ServerBootstrap公用一个
bossGroup),那么 bossGroup 只需要一个eventLoop 就行了,如果配置大于1也没关系(因为用不到,eventLoop也不会启动)
ServerSocketChannel 创建好后,就绑定到网络端口就开始监听,如果有新的客户端连接进来,那么accept()后就会产生 SocketChannel,一个连接对应一个 SocketChannel

伪代码:

ServerSocketChannel ssc = ServerSocketChannel.open();
...SocketChannel socketChannel = ssc.accept();

为了提高服务器性能,所有有的 SocketChannel 的相关操作都是在workGroup中完成的,所以 workGroup 里面需要配置适当多个 EnventLoop.

4.源码层面讲解 一个  ServerSocketChannel  只需要一个  EventLoop.

->bind(100).sync();  绑定端口

-->AbstractBootstrap.doBind  具体绑定动作

---->AbstractBootstrap.initAndRegister     config().group().register(channel);   将 serverChannel注册到bossGroup 的某个eventLoop中

------>MultithreadEventLoopGroup.register    next().register(channel);     next() 方法负责从group 中挑选一个eventLoop ,具体是由 chooser.next()实现;

通俗来讲就是,创建一个serverChannel绑定端口,初始化端口的过程中是从bossGroup中挑选一个 eventLoop,将channel注册到eventLoop中,eventLoop中nio selector,完成channel的注册。

注册的核心代码是:

如果当前线程就是在enventLoop ,调用register 方法就是直接执行register0,否则向线程(池)提交一个任务(eventLoop.execute()),这就是Reactor模式的核心实现逻辑,通过任务完成线程调配。

提交任务时候会干什么呢?

以上完整过程具体来讲就是,main线程开启(创建)一个serverChannel,创建过程中会从bossGroup 中选择一个eventLoop 给该channel, 同时给eventLoop  提交第一个任务(注册),同时会启动eventLoop ,

eventLoop 线程会扫描执行自己任务池里面的任务,其实第一个任务就是注册(将serverChannel注册到selector上),同时也会在自己线程中开始事件循环(接受客户端的连接)。

NioEventLoop 一直在干两件事:a.处理selector 上的 io 事件;  b.其他其他线程提交过来的task。

5.上面讲了bossGroup 干的事情,下面将一下workGroup 是如何工作的,其实和bossGroup 一样,因为他们公用的是同一套代码逻辑,

不同点是每一个 SocketChannel (ServerSocketChannel.accept) 初始化时候,都会从workGroup里面选择一个 eventLoop.

ServerBootstrapAcceptor 核心代码:

ServerChannel channelRead 实际上是产生的一个连接,就是一个child channel ,然后从childGroup.rigister 的意思和上面serverChannel的一样,完成注册,其实也是通过提交任务实现的,只不过这里提交的是scheduledTask,这里注册挑选的child eventLoop 可能是已经启动了的(一个eventLoop负责多个child channel 的监听)

这样就实现了bossGroup负责连接, childGroup负责连接后的具体IO读写操作, 一个ServerBootstrap 只有一个enventLoop,childGroup 需要有多个(性能方面的需要)。



原文地址:https://www.cnblogs.com/kevin7234/p/10662449.html

时间: 2024-10-07 08:38:05

从源码角度解析Netty的React模式是如何工作的的相关文章

Android AsyncTask 从源码角度解析其原理和用法

AsyncTask简介: 众所周知知道,Android UI是线程不安全的,如果要想在子线程中更新UI操作,必须使用Android的异步消息处理机制.当然我们自己可以实现一个Handler+Message消息处理机制来在子线程中更新UI操作.有时候觉得自己写这个异步消息处理机制很麻烦有木有??不过庆幸的是,Android 给我们实现了这么一套异步消息处理机制,我们直接拿来用就是了,从而 AsyncTask就诞生了.AsyncTask用于Android的异步消息 处理机制,来实现子线程和UI线程间

MySQL半一致性读原理解析-从源码角度解析

1.什么是半一致性读 A type of read operation used for UPDATE statements, that is a combination of read committed and consistent read. When an UPDATE statement examines a row that is already locked, InnoDB returns the latest committed version to MySQL so that

Snackbar新版Toast 从源码角度完全解析

我们将会从一下几个角度了解Snackbar. 1.什么是Snackbar 2.如何使用Snackbar 3.有哪些常用的API 4.从源码角度分析其实现 5.总结 1.什么是Snackbar Snackbar是一个轻量级的用户操作反馈工具,类似于Toast,但是比Toast更美观和实用,当你操作它的时候,Snackbar会置顶显示一个一定时间的简要的信息在屏幕的底部,并且它还可以添加事件. 2.如何使用Snackbar Snackbar .make(parentLayout, R.string.

JAVA框架底层源码剖析系列Spring,Mybatis,Springboot,Netty源码深度解析

<Spring源码深度解析>从核心实现和企业应用两个方面,由浅入深.由易到难地对Spring源码展开了系统的讲解,包括Spring的设计理念和整体架构.容器的基本实现.默认标签的解析.自定义标签的解析.bean的加载.容器的功能扩展.AOP.数据库连接JDBC.整合MyBatis.事务.SpringMVC.远程服务.Spring消息服务等内容. <Spring源码深度解析>不仅介绍了使用Spring框架开发项目必须掌握的核心概念,还指导读者如何使用Spring框架编写企业级应用,并

《Android源码设计模式解析》读书笔记——Android中你应该知道的设计模式

断断续续的,<Android源码设计模式解析>也看了一遍,书中提到了很多的设计模式,但是有部分在开发中见到的几率很小,所以掌握不了也没有太大影响. 我觉得这本书的最大价值有两点,一个是从设计模式的角度去理解Android源码,结合着日常开发中的常用类,对设计模式的理解会更加的深刻:另外一个好处就是了解常用模式,再看其他人写的代码的时候,更容易理解代码思路.下面是我的读书笔记和一些思考,设计模式只整理我认为重要的部分. 建造者模式 建造者模式最明显的标志就是Build类,而在Android中最常

Retrofit源码设计模式解析(上)

Retrofit通过注解的方法标记HTTP请求参数,支持常用HTTP方法,统一返回值解析,支持异步/同步的请求方式,将HTTP请求对象化,参数化.真正执行网络访问的是Okhttp,Okhttp支持HTTP&HTTP2,因此,使用Retrofit可以支持REST.HTTPS及SPDY. 行业内分析Retrofit的使用方法的文章已经比较丰富,这里不再赘述,如想了解这部分内容,请参考如下链接. <用 Retrofit 2 简化 HTTP 请求> <Retrofit 源码解析>

Android布局性能优化—从源码角度看ViewStub延迟加载技术

在项目中,难免会遇到这种需求,在程序运行时需要动态根据条件来决定显示哪个View或某个布局,最通常的想法就是把需要动态显示的View都先写在布局中,然后把它们的可见性设为View.GONE,最后在代码中通过控制View.VISIABLE动态的更改它的可见性.这样的做法的优点是逻辑简单而且控制起来比较灵活.但是它的缺点就是,耗费资源,虽然把View的初始可见View.GONE但是在Inflate布局的时候View仍然会被Inflate,也就是说仍然会创建对象,会被实例化,会被设置属性.也就是说,会

向Spring大佬低头——大量源码流出解析

优秀的源码中有着多年沉积下来的精华,这些精华是非常值得我们学习的.放弃阅读源码,你将失去一个和大师学习的机会. 用Spring框架做了几年的开发,只停留在会用的阶段上,然而Spring的设计思想和原理确实一个巨大的宝库.大部分人仅仅知道怎么去配,或着加上什么属性就能达到什么效果,这些东西都可以通过查文档,查google来解决.关键是在怎么理解它,把它的思想变为自己的东西.这几天没有学习(装逼),感觉心里甚是空虚,索×××了下一直很好奇的Spring大佬,毕竟写代码天天都在用. 前方高能,非战斗人

SpringCache源码深度解析

缓存是我们常用的一种优化系统的方案. 无论是前端缓存还是应用层缓存或者数据库缓存,其本质都是将查询过的数据缓存下来,下次再次查询该数据的时候如果数据没有过期,则直接返回缓存中该数据即可,不再执行查询操作. SpringCache是我们常用的一种应用层缓存方案,其一般应用在方法上,下面我们先来看下具体的使用方式,然后再从源码角度分析其实现方案 1.SpringCache的使用 1)maven引入依赖 cache功能相关代码都在spring-context中,一般使用Spring的项目中都有该包,所