NIO
的类库和 API
繁杂,使用麻烦:需要熟练掌握 Selector
、ServerSocketChannel
、SocketChannel
、ByteBuffer
等。Java
多线程编程,因为 NIO
编程涉及到 Reactor
模式,你必须对多线程 和网络编程非常熟悉,才能编写出高质量的 NIO
程序。JDK NIO
的 Bug
:例如臭名昭著的 Epoll Bug
,它会导致 Selector
空轮询,最终导致 CPU100%
。直到 JDK 1.7
版本该问题仍旧存在,没有被根本解决。Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers & clients
Netty
对 JDK
自带的 NIO
的 API
进行了封装,解决了上述问题。
API
阻塞和非阻塞 Socket
;基于灵活且可扩展的事件模型,可以清晰地分离关注点;高度可定制的线程模型 - 单线程,一个或多个线程池。Javadoc
,用户指南和示例;没有其他依赖项,JDK 5
(Netty 3.x
)或 6(Netty 4.x)
就足够了。SSL/TLS
和 StartTLS
支持。Bug
可以被及时修复,同时,更多的新功能会被加入。netty
版本分为 netty3.x
和 netty4.x
、netty5.x
。Netty5
出现重大bug
,已经被官网废弃了,目前推荐使用的是Netty4.x
的稳定版本。netty3.x
netty4.0.x
和 netty4.1.x
。netty
下载I/O
服务模型。Reactor
模式。Reactor
的数量和处理资源池线程的数量不同,有 3 种典型的实现:
Reactor
单线程。Reactor
多线程。Reactor
多线程。Netty
线程模式(Netty
主要基于主从 Reactor
多线程模型做了一定的改进,其中主从 Reactor
多线程模型有多 个 Reactor
)。API
)。IO
模式获取输入的数据。read
操作,造成线程资源浪费。针对传统阻塞 I/O
服务模型的 2 个缺点,解决方案:
I/O
复用模型:多个连接共用一个阻塞对象,应用程序只需要在一个阻塞对象等待,无需阻塞等待所有连 接。当某个连接有新的数据可以处理时,操作系统通知应用程序,线程从阻塞状态返回,开始进行业务处理 Reactor
对应的叫法: 1. 反应器模式 2. 分发者模式(Dispatcher
) 3. 通知者模式(notifier
)。I/O
复用结合线程池,就是 Reactor
模式基本设计思想:
Reactor
模式,通过一个或多个输入同时传递给服务处理器的模式(基于事件驱动)。Reactor
模式也叫Dispatcher
模式。Reactor
模式使用 IO
复用监听事件, 收到事件后,分发给某个线程(进程), 这点就是网络服务器高并发处理关键。Reactor
模式中核心组成:
Reactor:
Reactor
在一个单独的线程中运行,负责监听和分发事件,分发给适当的处理程序来对 IO
事件做出反应。 它就像公司的电话接线员,它接听来自客户的电话并将线路转移到适当的联系人。Handlers:
处理程序执行 I/O
事件要完成的实际事件,类似于客户想要与之交谈的公司中的实际官员。Reactor
通过调度适当的处理程序来响应 I/O
事件,处理程序执行非阻塞操作。Select
是前面 I/O
复用模型介绍的标准网络编程 API
,可以实现应用程序通过一个阻塞对象监听多路连接请求。
Reactor
对象通过 Select
监控客户端请求事件,收到事件后通过 Dispatch
进行分发。
如果是建立连接请求事件,则由 Acceptor
通过 Accept
处理连接请求,然后创建一个 Handler
对象处理连接完成后的后续业务处理。
如果不是建立连接事件,则 Reactor
会分发调用连接对应的 Handler
来响应。
Handler
会完成 Read
→业务处理→Send
的完整业务流程。
结合实例:服务器端用一个线程通过多路复用搞定所有的 IO 操作(包括连接,读、写等),编码简单,清晰明了, 但是如果客户端连接数量较多,将无法支撑,前面的 NIO 案例就属于这种模型。
CPU
的性能。Handler
在处理某个连接上的业务时,整个进程无法处理其他连接事件,很容易导致性能瓶颈。Redis
在业务处理的时间复杂度 O(1)
的情况。Reactor
对象通过 select
监控客户端请求 事件, 收到事件后,通过 dispatch
进行分发。Acceptor
通过accept
处理连接请求, 然后创建一个 Handler
对象处理完成连接后的各种事件。reactor
分发调用连接对应的handler
来处理。handler
只负责响应事件,不做具体的业务处理, 通过 read
读取数据后,会分发给后面的 worker
线程池的某个线程处理业务。worker
线程池会分配独立线程完成真正的业务,并将结果返回给 handler
。handler
收到响应后,通过 send
将结果返回给 client
。cpu
的处理能力。reactor
处理所有的事件的监听和响应,在单线程运行,在高并发场景容易出现性能瓶颈。Reactor
多线程模型中,Reactor
在单线程中运行,高并发场景下容易成为性能瓶颈,可以让 Reactor
在 多线程中运行。Reactor
主线程 MainReactor
对象通过 select
监听连接事件, 收到事件后,通过 Acceptor
处理连接事件。Acceptor
处理连接事件后,MainReactor
将连接分配给 SubReactor
。subreactor
将连接加入到连接队列进行监听,并创建 handler
进行各种事件处理。subreactor
就会调用对应的handler
处理。handler
通过 read
读取数据,分发给后面的 worker
线程处理。worker
线程池分配独立的 worker
线程进行业务处理,并返回结果。handler
收到响应的结果后,再通过send
将结果返回给client
。Reactor
主线程可以对应多个 Reactor
子线程, 即 MainRecator
可以关联多个 SubReactor
。Reactor
主线程只需要把新连接传给子线程,子线程无需返回数据。Nginx
主从 Reactor
多进程模型,Memcached
主从多线程, Netty
主从多线程模型的支持。Reactor
本身依然是同步的。Reactor
实例个数来充分利用 CPU
资源。Reactor
模型本身与具体事件处理逻辑无关,具有很高的复用性。Netty
主要基于主从 Reactors
多线程模型做了一定的改进,其中主从 Reactor
多线程模型有多个 Reactor
。BossGroup
线程维护 Selector
, 只关注 Accecpt
。Accept
事件,获取到对应的SocketChannel
,封装成NIOScoketChannel
并注册到Worker
线程(事件循环), 并进行维护。Worker
线程监听到selector
中通道发生自己感兴趣的事件后,就进行处理(就由handler
),注意handler
已经加入到通道。Netty
抽象出两组线程池 BossGroup
专门负责接收客户端的连接, WorkerGroup
专门负责网络的读写。BossGroup
和 WorkerGroup
类型都是 NioEventLoopGroup
。NioEventLoopGroup
相当于一个事件循环组, 这个组中含有多个事件循环 ,每一个事件循环是 NioEventLoop
。NioEventLoop
表示一个不断循环的执行处理任务的线程, 每个 NioEventLoop
都有一个 selector
, 用于监听绑定在其上的 socket
的网络通讯。NioEventLoopGroup
可以有多个线程, 即可以含有多个 NioEventLoop
。accept
事件。accept
事件 , 与 client
建立连接 , 生成 NioScocketChannel
, 并将其注册到某个 worker NIOEventLoop
上的 selector
。runAllTasks
。Worker NIOEventLoop
循环执行的步骤:
read, write
事件。i/o
事件, 即 read , write
事件,在对应 NioScocketChannel
处理。runAllTasks
。Worker NIOEventLoop
处理业务时,会使用pipeline
(管道), pipeline
中包含了 channel
, 即通过pipeline
可以获取到对应通道, 管道中维护了很多的处理器。Netty
服务器在 6669 端口监听,客户端能发送消息给服务器 "hello, 服务器~"
。
服务器可以回复消息给客户端 "hello, 客户端~"
。
目的:对Netty
线程模型有一个初步认识,便于理解Netty
模型理论。
NettyServer
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();
try {
//创建服务器端的启动对象,配置参数
ServerBootstrap bootstrap = new ServerBootstrap();
//使用链式编程来进行设置
bootstrap.group(bossGroup, workerGroup) //设置两个线程组
.channel(NioServerSocketChannel.class) //使用NioSocketChannel作为服务器的通道实现
.option(ChannelOption.SO_BACKLOG, 128) //设置线程队列得到连接个数
.childOption(ChannelOption.SO_KEEPALIVE, true) //设置保持活动连接状态
.childHandler(new ChannelInitializer<SocketChannel>() {
//创建一个通道测试对象(匿名对象)
//给pipeline设置处理器
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new NettyServerHandler());
}
});
//给我们的workerGroup的EventLoop对应的管道设置处理器
System.out.println(".....服务器 is ready...");
//绑定一个端口并且同步, 生成了一个ChannelFuture对象
//启动服务器(并绑定端口)
ChannelFuture cf = bootstrap.bind(6669).sync();
//对关闭通道进行监听
cf.channel().closeFuture().sync();
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
NettyServerHandler
/**
* 1. 我们自定义一个Handler需要继承netty规定好的某个HandlerAdapter(规范)
* 2. 这时我们自定义一个Handler, 才能称为一个handler
*/
public class NettyServerHandler extends ChannelInboundHandlerAdapter {
/**
* 读取数据实际(这里我们可以读取客户端发送的消息)
* @param ctx 上下文对象, 含有管道pipeline, 通道channel,地址
* @param msg 客户端发送的数据 默认Object
* @throws Exception
*/
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.out.println("服务器读取线程 " + Thread.currentThread().getName());
System.out.println("server ctx =" + ctx);
System.out.println("看看channel和pipeline的关系");
Channel channel = ctx.channel();
ChannelPipeline pipeline = ctx.pipeline(); //本质是一个双向链接, 出站入站
//将msg转成一个ByteBuf
//ByteBuf是Netty提供的,不是NIO的ByteBuffer.
ByteBuf buf = (ByteBuf) msg;
System.out.println("客户端发送消息是:" + buf.toString(CharsetUtil.UTF_8));
System.out.println("客户端地址:" + channel.remoteAddress());
}
//数据读取完毕
@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
//writeAndFlush是write+flush
//将数据写入到缓存,并刷新
//一般讲,我们对这个发送的数据进行编码
ctx.writeAndFlush(Unpooled.copiedBuffer("hello, 客户端~(>^ω^<)喵", CharsetUtil.UTF_8));
}
//处理异常, 一般是需要关闭通道
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
ctx.close();
}
}
NettyClient
public class NettyClient {
public static void main(String[] args) throws InterruptedException {
//客户端需要一个事件循环组
EventLoopGroup group = new NioEventLoopGroup();
try {
//创建客户端启动对象
//注意客户端使用的不是ServerBootstrap而是Bootstrap
Bootstrap bootstrap = new Bootstrap();
//设置相关参数
bootstrap.group(group) //设置线程组
.channel(NioSocketChannel.class) //设置客户端通道的实现类(反射)
.handler(new ChannelInitializer<SocketChannel>() {
@Override
protected 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", 6669).sync(); //给关闭通道进行监听
channelFuture.channel().closeFuture().sync();
}finally {
group.shutdownGracefully();
}
}
}
NettyClientHandler
public class NettyClientHandler extends ChannelInboundHandlerAdapter {
//当通道就绪就会触发该方法
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("client " + ctx);
ctx.writeAndFlush(Unpooled.copiedBuffer("hello, server: (>^ω^<)喵", CharsetUtil.UTF_8));
}
//当通道有读取事件时,会触发
@Override
public 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());
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}
文章浏览阅读5.7k次。随机森林参数记录1、先用默认参数看预测结果 2、然后用gridsearchcv探索n_estimators的最佳值 3、然后确定n_estimators,据此再搜索另外两个参数:再对内部节点再划分所需最小样本数min_samples_split和叶子节点..._randomforestclassifier调参
文章浏览阅读4.9w次,点赞5次,收藏25次。cat /dev/ttyUSB2 &echo -e "AT+CFUN=1,1\r\n" >/dev/ttyUSB2 //重启模块AT+QSIMDET=1,1或AT+QSIMDET=1,0开启 可以设置高电平 或者低电平有效//SIM卡热拔插,同一个电路 肯定不可以设置两种sim卡检测状态 要么高电平有效 要么低电平有效AT+QSIMDET=0 关闭SIM卡热拔..._ec20
文章浏览阅读157次。在这里说明一下:百度百科初始版本不可能那么高大全,都是先做一个相对简单的初始版本,后面逐渐完善。如果你要按自己的意思自定义内容,那么推荐做全球百科,因为它不要求参考资料(但是审核员会校审信息的真实性,所以一定要写真的,不要写假的)。我们主要做项目类百科,含百度百科、搜狗百科、全球百科、抖音百科。如果你有自己的品牌、公司、民营非企业、社会组织、创业项目,并且想提升它的知名度、打造名牌效应,那就做一个百科吧!无论抖音百科、搜狗百科、全球百科抑或是别的什么百科,都无可比较。
文章浏览阅读294次。在Scene View中可以看到球体,但是Game View什么都看不到。最后找到的原因是,我使用的shader是Skybox/Panorama, 需要把Main Camera的Clear Flags设置成Don’t clear,就可以在Unity Editor中看到了正确的内容。但是同样设置为Don’t clear,部署到Quest 2时,又会出现花屏(就像之前电视机那种黑白花屏),我又把Main Camera的Clear Flags设置成为了skybox。把它变成skybox就好了。_gameviwer无法按键
文章浏览阅读4.2w次,点赞18次,收藏57次。从名称上来看,CANTX和CANRX是CAN控制芯片的发送管脚(CANTX)和接收管脚(CANRX)。完整的CAN电路是由CAN控制器和CAN收发器组成的,二者之间一般通过TTL电平的收发信号(CANRX、CANTX)连接,由CAN收发器将CANTX的TTL信号转换为CAN规范差分信号输出、同时接收差分线上的实际信号并转换为TTL信号输出到CANRX管脚上。CAN收发器与CAN控制器的CANT_canh是tx嘛
文章浏览阅读3.4w次,点赞72次,收藏925次。51单片机数字闹钟_51单片机电子时钟
文章浏览阅读635次。题目所在试卷参考答案:2016年湖北省咸宁市中考物理试卷参考答案与试题解析一、选择題(本大题共10小题,每小题2分,共20分)1.某校组织学生参加体育中考.以下记录的部分体检数据中,不合理的是( )A.体温37℃ B.身高 1.60mC.质量4000g D.肺活量 3500ml[考点]长度的估测;温度;质量的估测.[分析]首先对题目中涉及的物理量有个初步的了解,对于选项中的单位,可根据需要进行相..._.在如图所示的电路中,电源电压保持不变.闭合幵关s后,将滑动变阻器滑片p向左移动时
文章浏览阅读1.5w次,点赞19次,收藏43次。若使用R语言调用data <- read.csv("dataset.csv")文件出现了乱码,解决的方法简单整理如下:查看R语言运行环境的区域(locale)设置> Sys.getlocale(category = "LC_ALL")[1] "LC_COLLATE=Chinese (Simplified)_China.936;LC_CTYPE=Chinese (Simplified)_China.936;LC_MONETARY=Chinese (Simplified)_China.93_r语言读取csv文件时横杠符号变成乱码
文章浏览阅读1.9k次。一:填空题:1:Apache若采用prework模式,则是异步阻塞的。2.可启动服务器网络服务的命令:systemctl restart network3.Centos7,关闭防火墙服务的命令是:systemctl stop firewalld4:不知道nginx监听哪个端口,可以这么做:netstat -tnlp | grep nginx或者:在这里插入代码片地址..._运维的测试方法
文章浏览阅读743次。RedHat5.5 linux下Oracle11g软件安装一、配置虚拟机为了创建和配置虚拟机,你需要添加硬件设备如磁盘和cpu,在你开始安装之前,创建一个windows目录作为存放虚拟机的目录目录不一定是E:\盘,找一个自己磁盘空间比较大的硬盘就可以。E:\>mkdir stu1(创建目录)双击桌面上的虚拟机工作站图标以打开虚拟机1.PressCTRL-..._oracleasm-support-2.1.8-1.el5.x86_64.rpm
文章浏览阅读564次。很早之前自己的笔记,想想还是记录到网上吧注册 7611 static int __init 7612 dhd_module_init(void) 7613 { 7614 int err; 7615 int retry = POWERUP_MAX_RETRY; 7616 7617 printk("%s: in\n", __FUNCTION__); 7618 7619 DHD_PERIM_RADIO_I.._博通wifi芯片控制软件
文章浏览阅读355次。从小白入门C语言 黄强老师,国家软件设计师,软件开发工程师,项目经理、产品经..._从小白入门c++黄强