package NIOTEST; import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.ServerSocketCh

NIO线程模型 上一篇说的是基于操作系统的IO处理模型,那么这一篇来介绍下服务器端基于IO模型和自身线程的处理方式. 一.传统阻塞IO模型下的线程处理模式 这种处理模型是基于阻塞IO进行的,上一篇讲过,阻塞IO会阻塞每一个IO操作,直到事件就绪,下面来看下阻塞IO下的服务端线程模型: 图1 如上图所示,该线程模型基于阻塞IO模型实现,针对每个请求都需要抽出来一个线程进行处理读入数据.业务处理数据.返回响应结果给客户端,这个过程中读.写操作均会阻塞,且跟业务处理串行执行,该模式下,并发量过大时会大

终于,这两天的考试熬过去了, 兴致冲冲的来整理笔记来, 这篇博客是我近几天的NIO印象笔记汇总,记录了对Selector及Selector的重要参数的理解,对Channel的理解,常见的Channel,对NIO事件驱动的编程模型的理解,NIO与传统IO的对比,NIO的TCP/IP编程的实践. Channel 什么是Channel 这个概念绝对是一级概念,Channel是一个管道,用于连接字节缓冲区和另一端的实体, 这个字节缓冲区就是ByteBuffer, 另一端的实体可以是一个File 或者是

第一章:手动搭建I/O网络通信框架1:Socket和ServerSocket入门实战,实现单聊 第二章:手动搭建I/O网络通信框架2:BIO编程模型实现群聊 在第二章中用BIO编程模型,简单的实现了一个聊天室.但是其最大的问题在解释BIO时就已经说了:ServerSocket接收请求时(accept()方法).InputStream.OutputStream(输入输出流的读和写)都是阻塞的.还有一个问题就是线程池,线程多了,服务器性能耗不起.线程少了,在聊天室这种场景下,让用户等待连接肯定不可取

Selector Selector 允许一个单一的线程来操作多个 Channel. 如果我们的应用程序中使用了多个 Channel, 那么使用 Selector 很方便的实现这样的目的, 但是因为在一个线程中使用了多个 Channel, 因此也会造成了每个 Channel 传输效率的降低.使用 Selector 的图解如下: 为了使用 Selector, 我们首先需要将 Channel 注册到 Selector 中, 随后调用 Selector 的 select()方法, 这个方法会阻塞, 直到

Java网络编程和NIO详解7:浅谈 Linux 中NIO Selector 的实现原理 转自:https://www.jianshu.com/p/2b71ea919d49 本系列文章首发于我的个人博客:https://h2pl.github.io/ 欢迎阅览我的CSDN专栏:Java网络编程和NIO https://blog.csdn.net/column/details/21963.html 部分代码会放在我的的Github:https://github.com/h2pl/ 浅谈 Linux

NIO 编程模型 Doug Lea 在 Scalable IO in Java 的 PPT 中描述了 Reactor 编程模型的思想,大部分 NIO 框架和一些中间件的 NIO 编程都与它一样或是它的变体.本文结合 PPT 按照自己的理解整理而来,最终编写了一个简单的 NIO 回显服务. Reactor 之所以高效是因为采用了分而治之和事件驱动的设计.大部分网络服务像 Web 服务器.分布式对象的通信等大多数具有相同的基本处理流程: 读取请求数据 - read 按协议解析请求 - decode

出处:Java NIO Selector 1.1. Selector入门 1.1.1. Selector的和Channel的关系 Java NIO的核心组件包括: (1)Channel(通道) (2)Buffer(缓冲区) (3)Selector(选择器) 其中Channel和Buffer比较好理解 ,联系也比较密切,他们的关系简单来说就是:数据总是从通道中读到buffer缓冲区内,或者从buffer写入到通道中. 选择器和他们的关系又是什么? 选择器(Selector) 是 Channel(通

之前的文章已经把 Java 中 NIO 的 Buffer.Channel 讲解完了,不太了解的可以先回过头去看看.这篇文章我们就来聊聊 Selector -- 选择器. 首先 Selector 是用来干嘛的呢?不熟悉这个概念的话我们其实可以这么理解: selector 把它当作 SQL 中的 select 语句,在 SQL 中无非就是筛选出符合条件的结果集合.而 NIO 中的 Selector 用途类似,只不过它选择出来的是有就绪 IO 事件的 Channel. IO 事件代表了 Channel

一直不明白pipe是如何唤醒selector的,所以又去看了jdk的源码(openjdk下载),整理了如下: 以Java nio自带demo : OperationServer.java   OperationClient.java(见附件) 其中server端的核心代码: public void initSelector() { try { selector = SelectorProvider.provider().openSelector(); this.serverChannel1 =

I/O模型 在开始NIO的学习之前,先对I/O的模型有一个理解,这对NIO的学习是绝对有好处的.我画一张图,简单表示一下数据从外部磁盘向运行中进程的内存区域移动的过程: 这张图片明显忽略了很多细节,只涉及了基本操作,下面分析一下这张图. 用户空间和内核空间 一个计算机通常有一定大小的内存空间,如一台计算机有4GB的地址空间,但是程序并不能完全使用这些地址空间,因为这些地址空间是被划分为用户空间和内核空间的.程序只能使用用户空间的内存,这里所说的使用是指程序能够申请的内存空间,并不是真正访问的地址

Doug Lea 在 Scalable IO in Java 的 PPT 中描述了 Reactor 编程模型的思想,大部分 NIO 框架和一些中间件的 NIO 编程都与它一样或是它的变体.本文结合 PPT 按照自己的理解整理而来,最终编写了一个简单的 NIO 回显服务. Reactor 之所以高效是因为采用了分而治之和事件驱动的设计.大部分网络服务像 Web 服务器.分布式对象的通信等大多数具有相同的基本处理流程: 读取请求数据 - read 按协议解析请求 - decode 业务处理 - pr

Selector是Java NIO中的一个组件,用于检查一个或多个NIO Channel的状态是否处于可读.可写.如此可以实现单线程管理多个channels,也就是可以管理多个网络链接. 为什么使用Selector(Why Use a Selector?) 用单线程处理多个channels的好处是我需要更少的线程来处理channel.实际上,你甚至可以用一个线程来处理所有的channels.从操作系统的角度来看,切换线程开销是比较昂贵的,并且每个线程都需要占用系统资源,因此暂用线程越少越好. 需

1. 背景 SelectableChannel对象的多路复用器. 可以通过调用Selector.open()方法创建Selector对象.Selector.open()方法会利用系统默认的SelectorProvider创建Selector对象.也可以通过自定义SelectorProvider对象的openSelector方法创建Selector.Selector会一直处于打开状态,直到调用它的close方法. SelectionKey对象表示每一个注册到Selector的SelectorCha

1.Reactor单线程模型 传统的javaNIO通信的线程模型.该线程模型仅有一个I/O线程处理所有的I/O操作,如下图:   单线程模型的Reactor 所有的客户端都连接到一个I/O线程负责的Acceptor上,连接成功后,由Reactor里的Dispatch将接收的ByteBuffer分发到指定的Handler上处理,进行解码,业务处理,编码及发送给客户端等过程.整个过程I/O线程都是异步非阻塞方式实现. I/O线程完成的工作: 1)服务端NIO线程用于监听客户端连接 2)客户端NIO线

能力有限,仅仅是自己看源码的一些笔记. 主要介绍 可选通道 和 选择器 选择键(SelectableChannel  和 Selector SelectionKey) 选择器(Selector) 选择器类管理着一个被注册的通道集合的信息和它们的就绪状态.通道是和选择器一起被注册的,并且使用选择器来更新通道的就绪状态.当这么做的时候,可以选择将被激发的线程挂起,直到有就绪的的通道. 可选通道 selectableChannel可以被注册到Selector对象上,一个通道可以被注册到多个选择器上,但

为什么使用Selector? 仅用单个线程来处理多个Channels的好处是,只需要更少的线程来处理通道.事实上,可以只用一个线程处理所有的通道.对于操作系统来说,线程之间上下文切换的开销很大,而且每个线程都要占用系统的一些资源(如内存).因此,使用的线程越少越好. 但是,需要记住,现代的操作系统和CPU在多任务方面表现的越来越好,所以多线程的开销随着时间的推移,变得越来越小了.实际上,如果一个CPU有多个内核,不使用多任务可能是在浪费CPU能力.不管怎么说,关于那种设计的讨论应该放在另一篇不同

These four events are represented by the four SelectionKey constants: SelectionKey.OP_CONNECT SelectionKey.OP_ACCEPT SelectionKey.OP_READ SelectionKey.OP_WRITE Notice the second parameter of the register() method. This is an "interest set", mean

1.服务器端: import selectors import socket sel = selectors.DefaultSelector() #生成一个select对象 def accept(sock, mask): #有新链接进来 conn, addr = sock.accept() # Should be ready print('accepted', conn, 'from', addr) conn.setblocking(False) #设置为非阻塞模式 sel.register(c

先来看看我们的server端: 创建一个serversocket,进行监听,每来一个客户端,就启动一个新启动为其服务: private void createListenSocket() { //如果创建监听socket的时候发生异常,将会隔WAIT_TIME毫秒重试,直到成功 while (true){ try { serverSocket = new ServerSocket(LISTEN_PORT); Log.info(创建监听socket成功,正在监听...); break; } cat

Reactor两种多线程模型的实现 注:本篇文章例子基于上一篇进行:Java NIO学习与记录(七): Reactor单线程模型的实现 紧接着上篇Reactor单线程模型的例子来,假设Handler的read那里的处理方式延迟5s,当做是业务性能瓶颈,改变下原来的Handler,让其read方法在处理时延迟5s: private void read() throws IOException { if (selectionKey.isValid()) { System.out.println("服