004-核心技术-netty概述、传统IO、Reactor线程模型

摘要:
c、 核心由1)Reactors组成,它们在一个单独的线程中运行,负责监视事件并将其分发给适当的处理程序,以对IO事件做出反应。反应器通过调度执行非阻塞操作的适当处理程序来响应IO事件。
一、概述

1.1、原生NIO存在的问题

  1)NIO的类库和API复杂,使用麻烦,需要熟练掌握Selector,ServerSocketChannel、SocketChannel、ByteBuffer等。

  2)需要具备其他的额外技能,需要熟悉Java多线程编程,因为NIO涉及到Reactor模式,必须熟悉多线程和网络编程,才能写出高质量的NIO程序

  3)开发工作量和难度比较大,如,客户端面临断连重连、网络闪断,半包读写、失败缓存、网络拥塞和异常流的处理等

  4)JDK NIO的bug,如Epoll Bug,他会导致Selector空轮询,最终导致CPU100%,直到jdk1.7版本该问题仍存在,没有根本解决。

1.2、Netty介绍

1.2.1、官网介绍

  官网地址:https://netty.io/

  官网含义:Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers & clients.

  004-核心技术-netty概述、传统IO、Reactor线程模型第1张

  1)开源框架,异步的、基于事件驱动的网络应用程序框架,用以快速开发高性能、高可靠的网络IO程序。

  2)简化现有NIO开发流程

  3)使用广泛,如大数据、游戏、通信,如ElasticSearch、Dubbo等。

1.2.2、优点

1)对JDK自带的NIO进行了封装,解决上述bug

2)设计优雅:适用于各种传输类型统一API阻塞和非阻塞Socket;基于灵活且可扩展的事件模型,可以清晰地分离关注点;高度可定制的线程模型-单线程,一个或多个线程池。

3)适用方便,无其他依赖项,JDK5(3.x)或6(netty 4.x)

4)高性能、吞吐量更高;延迟更低、减少资源消耗;最小化不必要的内存复制

5)安全;完整的sslTLS和StartTLS支持

1.2.3、版本

netty3.X 比较旧;netty5.x废弃;netty4.x推荐适用,适用maven引入

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.65.Final</version>
</dependency>
二、Netty线程模型

2.1、 线程模型介绍

不同线程模型,对程序的性能影响很大,目前从存在的线程模型有:传统阻塞IO模型和Reactor模式;

Reactor模式

根据Reactor的数量和处理资源池线程的数量不同,有3种典型的实现:单Reactor单线程、单Reactor多线程、主从Reactor多线程

Netty线程模式:主要基于主从Reactor多线程模型做了一定改进,其中主从Reactor多线程模型有多个Reactor。

参看书籍:Scalable IO in java

2.1.1、传统IO阻塞服务模型

1)工作原理图

004-核心技术-netty概述、传统IO、Reactor线程模型第2张

2)模型特点

a、采用阻塞IO模式获取输入

b、每个连接都需要独立的线程完成数据的输入,业务处理、数据返回

3)问题分析

a、当并发数很大,就会创建大量的线程、占用很大系统资源

b、连接创建后,如果当前线程这哪是没有数据可读,该线程就会阻塞在read操作,造成线程资源浪费;

2.1.2、Reactor模式

Reactor常用叫法:反应器模式;2分发者模式(DIspatcher)3通知这模式(notifier)

a、针对传统IO服务模型的2个缺点,解决方案:

1)基于IO复用模型,多个连接共用一个阻塞对象,应用程序只需要在一个阻塞对象等待,无需阻塞等待所有连接。当某个连接有新的数据可以处理时,操作系统通知应用程序,线程从阻塞状态返回,开始进行业务处理

2)基于线程池服用线程资源,不必再为每个连接创建线程,将连接完成后的业务处理任务分配给线程进行处理,一个线程可以处理多个连接的业务。

b、设计思想:IO复用结合线程池

004-核心技术-netty概述、传统IO、Reactor线程模型第3张

说明:Reactor模式,通过一个或多个输入同时传递给服务处理器的模式(基于事件驱动)

2)服务器端程序处理传入的多个请求,并将它们同步分派到相应的处理线程,因此Reactor模式也叫Dispatcher模式

3)Reactor模式号私用IO复用监听事件,收到事件后,分发给某个线程,这点就是网络服务器高并发处理关键。

c、核心组成

1)Reactor,在一个单独的线程中运行,负责监听和分发事件,分发给适当的处理程序来对IO事件作出反应。

2)Handlers,处理程序执行IO事件要完成的实际事件。Reactor通过调度适当的处理程序来相应IO事件,处理程序执行非阻塞操作。

d、Reactor优点

1)响应快,不必为单个同步时间所阻塞,虽然Reactor本身依然是同步的;2)可以最大程度的避免复杂的多线程及同步问题,并且避免了多线程/进程的切换开销

3)扩展性号,可以方便的通过增加Reactor实例个数来充分利用CPU资源;4)复用性好,Reactor模型本身与具体事件处理逻辑无关,具有很高的复用性

2.1.2.1、单Reactor单线程【不常用,原Redis使用】

  004-核心技术-netty概述、传统IO、Reactor线程模型第4张

上节的NIO原生API的群聊即是此种模式

方案说明:1)Select就是前面IO复用模型介绍的标准网络编程API,可以实现应用程序通过一个阻塞对象监听多路连接请求。

2)Reactor对象通过Select监控客户端请求事件,收到事件后通过DIspatch进行分发

3)如果是建立连接请求事件,则由Acceptor通过Accept处理连接请求,然后创建一个Handler对象处理连接完成后的后续业务处理

4)如果不是建立连接事件,则Reactor会分发调用连接对应的Handler来响应

5)Handler会完成Read→业务处理→Send的完整业务流程

优缺点:优点:1)模型简单,没有多线程,进程通信、竞争的问题,全部都在一个线程中完成

缺点1)性能问题,只有一个线程,无法完全发挥多核CPU的性能。Handler在处理某个连接上的业务时,整个进程无法处理其他连接事件,很容易导致性能瓶颈

缺点2)可靠性问题,线程意外终止,或者进入死循环,会导致整个系统通信模块不可用,不能接收和处理外部消息,造成节点故障。

使用场景:客户端的数量有限,业务处理非常快速,比如Redis在业务处理的时间复杂度O(1)的情况。

2.1.2.2、单Reactor多线程

工作原理图:

  004-核心技术-netty概述、传统IO、Reactor线程模型第5张

说明:1)Reactor对象通过Select监控客户端请求事件,收到事件后,通过dispatch进行分发

2)如果建立连接请求,则由Acceptor通过accept处理连接请求,然后创建一个Handler对象处理完连接后的各种事件

3)如果不是连接请求,则由reactor分发调用连接对应的handler来处理

4)handler只负责响应事件,不做具体的业务处理,通过read读取数据后,会分发给后面的worker线程池的某个线程处理业务

5)wocker线程池会分配独立线程完成真正的业务,并将结果返回给handler

6)handler收到相应后,通过send将结果返回给client

b、优缺点

优点:可以充分利用多核CPU的处理能力

缺点:多线程数据共享和访问比较复杂,reactor处理所有的事件的监听和响应,在单线程运行,在高并发场景容易出现性能瓶颈

2.1.2.3、主从Reactor多线程

针对单Reactor多线程模型中,在单线程运行,在高并发场景容易出现性能瓶颈,可以让Reactor在多线程中运行

工作原理图

004-核心技术-netty概述、传统IO、Reactor线程模型第6张

优缺点:优点:父线程与子线程的数据交互简单职责明确,父线程只需要接收新链接,子线程完成后续的业务处理;

缺点:编程复杂度较高

应用:Nginx主从Reactor多进程模型,Memcached主从多线程模式,Netty主从多线程模式

免责声明:文章转载自《004-核心技术-netty概述、传统IO、Reactor线程模型》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇uni-app——uni-ui的使用【C语言】双人格斗小游戏(源码)下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

5个Android开发中比较常见的内存泄漏问题及解决办法

在Android开发中,内存泄漏是比较常见的问题,有过一些Android编程经历的童鞋应该都遇到过,但为什么会出现内存泄漏呢?内存泄漏又有什么影响呢? 在Android程序开发中,当一个对象已经不需要再使用了,本该被回收时,而另外一个正在使用的对象持有它的引用从而导致它不能被回收,这就导致本该被回收的对象不能被回收而停留在堆内存中,内存泄漏就产生了。 内存...

vue中的watch监听数据变化以及watch中各属性详解

1、watch使用的几种方法(1)通过watch监听data数据的变化,数据发生变化时,就会打印当前的值 watch: { data(val, newval) { console.log(val) console.log(newval) } } (2)通过watch监听docData数据的变化...

HBase的Write Ahead Log (WAL) —— 整体架构、线程模型

解决的问题 HBase的Write Ahead Log (WAL)提供了一种高并发、持久化的日志保存与回放机制。每一个业务数据的写入操作(PUT / DELETE)执行前,都会记账在WAL中。 如果出现HBase服务器宕机,则可以从WAL中回放执行之前没有完成的操作。 本文主要探讨HBase的WAL机制,如何从线程模型、消息机制的层面上,解决这些问题: 1...

《Linux 应用编程》—第13章 Linux 多线程编程

目录 1 多线程概述 1.1 什么是线程 1.2 线程与进程的关系 1.3 为什么使用多线程 2 POSIX Threads 概述 3 线程管理 3.1 线程ID 3.2 创建与终止 1. 创建线程 2. 终止线程 3. 线程范例1 3.3 连接与分离 1. 线程分离 2. 线程连接 3. 线程范例2 3.4 线程属性 属性对象...

python多进程那点事儿【multiprocessing库】

      前言:项目中有个需求需要对产品的日志处理,按照产品中日志的某些字段,对日志进行再次划分。比如产品的日志中含有字段id,tag=1,现在需要把tag是基数的放到一个文件中,tag是偶数的放入一个文件中。这就涉及到多个文件的读写操作,一个文件一个文件读取写入那时间太久了,公司配备的单机,跑了半个多小时,光标还是一直在闪闪闪【你懂得】。没办法了,还是...

Java多线程-线程的调度(休眠)

Java线程调度是Java多线程的核心,只有良好的调度,才能充分发挥系统的性能,提高程序的执行效率。这里要明确的一点,不管程序员怎么编写调度,只能最大限度的影响线程执行的次序,而不能做到精准控制。线程休眠的目的是使线程让出CPU的最简单的做法之一,线程休眠时候,会将CPU资源交给其他线程,以便能轮换执行,当休眠一定时间后,线程会苏醒,进入准备状态等待执行。...