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();
}
}
文章浏览阅读8k次。原文地址:http://www.jb51.net/article/48901.htm如果你使用jQuery类库,那么你可以非常愉悦的使用jquery的data()方法存取data-* 自定义属性,方法允许我们在DOM元素上绑定任意类型的数据,避免了循环引用的内存泄漏风险主要的方法如下:复制代码 代码如下:.data( key, value ).d_jq获取所有自定义属性data的值
文章浏览阅读1.2k次。这本是一篇旧文,但鉴于有读者朋友私信问我相关事宜,又重新见了天日:)从这期开始,Haykey哥以后会以胶片图片方式来展现文章,是为方便Haykey哥日后公司内部培训所用。废话少说,这就带大家看看这期的主题,号码显示类补充业务。首先,以上一期《SS系列之呼叫保持(Call Hold)业务》的开篇连连看为引,号码显示类业务包含CLIP,CLIR,COLP,COLR,O..._oir/clir
文章浏览阅读2k次,点赞3次,收藏14次。笔记作业自用_centos6
文章浏览阅读118次。20145306 张文锦 网络攻防 web基础 20145306 网络攻防 web基础实验内容WebServer:掌握Apache启停配置修改(如监听端口)前端编程:熟悉HTML+JavaScript。了解表单的概念编写不同的HTML网页,放入到A..._date viewer网络攻防web
文章浏览阅读1.5w次,点赞31次,收藏91次。那什么是假唤醒?当一个条件满足时,很多线程都被唤醒了,但是只有其中部分是有用的唤醒,其它的唤醒都是无用功1.比如说买货,如果商品本来没有货物,突然进了一件商品,这是所有的线程都被唤醒了 ,但是只能一个人买,所以其他人都是假唤醒,获取不到对象的锁避免虚假唤醒下面是避免虚假唤醒的示例:package duoxiancheng.bao;/* * 虚假唤醒的解决: * wait要始..._虚假唤醒 java
文章浏览阅读971次,点赞2次,收藏7次。通过getHeather()判断访问的url的父url是否为空,来确定用户是直接输入url访问的,还是程序正常跳转。request.getHeader("REFERER");/*mall*/_javaweb中防止url修改
文章浏览阅读2.4k次。本文给大家介绍了五个经典的漏斗模型,看如何通过漏斗思维去穿透流程化的本质。日常工作中,我们会发现不同行业或者不同岗位上,大致会遵循着一些相同的流程,或长或短,或复杂或简单,而所有的流程基本都会为自身的终极目标负责,比如招聘工作中要为最终员工入职负责,销售工作要为客户买单负责,运营工作中可能要为最后的用户增长负责,而每一项工作本身又是复杂的,此时如果没有一个清晰的链路,我们很难定位问题的源头在哪里?更别谈接下来该如何去推进了?这边有个非常高效的思维方式,叫做漏斗思维,它是一种线性的思考方式,一._漏斗模型
文章浏览阅读329次。Java中可以使用()方法去除转义字符,代码如下:String str = "This is a \\test\\ string";// 输出结果:This is a test string。_java 去除html字符串里的转义字符
文章浏览阅读76次。背景SpringMVC在2.5之前是主配置风格的,2.5之后变成了主注解的风格,由于平时项目中用的还是主配置风格,再者我比较懒,对注解比较不了解,所以这里还是配置风格的。必备知识1、知道一个javaweb应用的结构2、知道Spring IOC是怎么回事正文MVC框架大多是围绕一个核心的servlet来设计,这个核心的servlet提供了请求转发及很多其他便捷搭建web...
文章浏览阅读288次。Bitwarden 和 1Password 是密码管理器,对各种类型和规模的注重安全的组织都有吸引力。 这两种工具都通过改善用户保护所需的预期核心功能提供强大的保护。 我的分析比较了关键功能,并结合了企业、政府机构和非营利组织所需的企业功能和支持._bitwarden 收费版和免费版的区别
文章浏览阅读1w次,点赞15次,收藏56次。第一次写,见谅以下是求迷宫的实现/*第一部分使用递归求解为了数据的简单化,不对路口进行数据结构化,将用一个简单的int类型数组来表示迷宫因为每一个路口的四个方向相对于当前路口的位移都是一样的,这样可以用一个int类型二位数据表示四个方向的相对于当前位置的位移,以顺时针东、南,、西、北储存 *///路口数据结构化//当前路口状态;1表示通顺路口,2表示搜索过的,0表示障碍路口#include..._n阶迷宫c程序递归
文章浏览阅读128次。文章目录1.平滑升级php到7版本2.控制页面字体显示不乱码2.利用pernoca模板实现对 mysqld的监控2.1配置mysql2.2安装percona-zabbix模块2.3导入模块1.平滑升级php到7版本在server1上:1.获取以上安装包2.清除之前版本的php并安装新版本的phprpm -qa | grep phpyum remove `rpm -qa | grep php`yum install * zabbix-web zabbix-web-mysql3.开启zabb_mysql zabbix 监控方案