上海 食品网站设计,WordPress最强大的主题,女生做网站主题有哪些,开发一个网站的步骤在JDK1.4以前#xff0c;I/O输入输出处理#xff0c;我们把它称为旧I/O处理#xff0c;在JDK1.4开始#xff0c;java提供了一系列改进的输入/输出新特性#xff0c;这些功能被称为新I/O(NEW I/O)#xff0c;新添了许多用于处理输入/输出的类#xff0c;这些类都被放在ja…在JDK1.4以前I/O输入输出处理我们把它称为旧I/O处理在JDK1.4开始java提供了一系列改进的输入/输出新特性这些功能被称为新I/O(NEW I/O)新添了许多用于处理输入/输出的类这些类都被放在java.nio包及子包下并且对原java.io包中的很多类以NIO为基础进行了改写新添了满足新I/O的功能。Java NIO和IO的主要区别IONIO面向流面向缓冲阻塞IO非阻塞IO无选择器面向缓冲(Buffer)在整个Java的心I/O中所以操作都是以缓冲区进行的使操作的性能大大提高。操作在Buffer中存在一系列的状态变量这状态变量随着写入或读取都可能会被概念在缓冲区开元使用是三个值表示缓冲区的状态。position表示下个缓冲区读取或写入的操作指针没向缓冲区中华写入数据的时候 此指针就会改变指针永远放在写入的最后一个元素之后。即如果写入了4个位置的数据则posotion会指向第5个位置。Limit表示还有多少数据可以存储或读取positionlimitcapacity表示缓冲区的最大容量limitcapacity,此值在分配缓冲区时被设置。一般不改变。创建缓冲区importjava.nio.IntBuffer ;public classIntBufferDemo{public static voidmain(String args[]){IntBuffer buf IntBuffer.allocate(10) ; //准备出10个大小的缓冲区System.out.print(1、写入数据之前的position、limit和capacity) ;System.out.println(position buf.position() limit buf.limit() capacty buf.capacity()) ;int temp[] {5,7,9} ;//定义一个int数组buf.put(3) ; //设置一个数据buf.put(temp) ; //此时已经存放了四个记录System.out.print(2、写入数据之后的position、limit和capacity) ;System.out.println(position buf.position() limit buf.limit() capacty buf.capacity()) ;buf.flip() ;//重设缓冲区//postion 0 ,limit 原本positionSystem.out.print(3、准备输出数据时的position、limit和capacity) ;System.out.println(position buf.position() limit buf.limit() capacty buf.capacity()) ;System.out.print(缓冲区中的内容) ;while(buf.hasRemaining()){int x buf.get() ;System.out.print(x 、) ;}}}如果创建了缓冲区则JVM可直接对其执行本机的IO操作importjava.nio.ByteBuffer ;public classByteBufferDemo{public static voidmain(String args[]){ByteBuffer buf ByteBuffer.allocateDirect(10) ; //准备出10个大小的缓冲区byte temp[] {1,3,5,7,9} ; //设置内容buf.put(temp) ; //设置一组内容buf.flip() ;System.out.print(主缓冲区中的内容) ;while(buf.hasRemaining()){int x buf.get() ;System.out.print(x 、) ;}}}通道(Channel)Java NIO的非阻塞模式使一个线程从某通道发送请求读取数据但是它仅能得到目前可用的数据如果目前没有数据可用时就什么都不会获取。而不是保持线程阻塞所以直至数据变的可以读取之前该线程可以继续做其他的事情。 非阻塞写也是如此。一个线程请求写入一些数据到某通道但不需要等待它完全写入这个线程同时可以去做别的事情。 线程通常将非阻塞IO的空闲时间用于在其它通道上执行IO操作所以一个单独的线程现在可以管理多个输入和输出通道(channel)。Java NIO的通道类似流但又有些不同既可以从通道中读取数据又可以写数据到通道。但流的读写通常是单向的。通道可以异步地读写。通道中的数据总是要先读到一个Buffer或者总是要从一个Buffer中写入。正如上面所说从通道读取数据到缓冲区从缓冲区写入数据到通道。Channel的实现这些是Java NIO中最重要的通道的实现FileChannelDatagramChannelSocketChannelServerSocketChannelFileChannel 从文件中读写数据。DatagramChannel 能通过UDP读写网络中的数据。SocketChannel 能通过TCP读写网络中的数据。ServerSocketChannel可以监听新进来的TCP连接像Web服务器那样。对每一个新进来的连接都会创建一个SocketChannel。通过通道可以完成双向的输入和输出操作。在通道还有一种方式称为内存映射几种读入的方式的比较RandomAccessFile 较慢FileInputStream 较慢缓冲读取 速度较快内存映射 速度最快FileChannel内存映射实例importjava.nio.ByteBuffer ;importjava.nio.MappedByteBuffer ;importjava.nio.channels.FileChannel ;importjava.io.File ;importjava.io.FileOutputStream ;importjava.io.FileInputStream ;public classFileChannelDemo03{public static void main(String args[]) throwsException{File file new File(d: File.separator oumyye.txt) ;FileInputStream input null;input newFileInputStream(file) ;FileChannel fin null ; //定义输入的通道fin input.getChannel() ; //得到输入的通道MappedByteBuffer mbb null;mbb fin.map(FileChannel.MapMode.READ_ONLY,0,file.length()) ;byte data[] new byte[(int)file.length()] ; //开辟空间接收内容int foot 0;while(mbb.hasRemaining()){data[foot] mbb.get() ; //读取数据}System.out.println(new String(data)) ; //输出内容fin.close() ;input.close() ;}}操作以上代码的时候执行的是写入操作则可能是非常危险的因为仅仅只是改变数组中的单个元素这种简单的操作就可能直接修改磁盘上的文件因为修改数据与数据保存在磁盘上是一样的。选择器(Selectors)Selector(选择器)是Java NIO中能够检测一到多个NIO通道并能够知晓通道是否为诸如读写事件做好准备的组件。这样一个单独的线程可以管理多个channel从而管理多个网络连接。为什么使用Selector?仅用单个线程来处理多个Channels的好处是只需要更少的线程来处理通道。事实上可以只用一个线程处理所有的通道。对于操作系统来说线程之间上下文切换的开销很大而且每个线程都要占用系统的一些资源(如内存)。因此使用的线程越少越好。但是需要记住现代的操作系统和CPU在多任务方面表现的越来越好所以多线程的开销随着时间的推移变得越来越小了。实际上如果一个CPU有多个内核不使用多任务可能是在浪费CPU能力。不管怎么说关于那种设计的讨论应该放在另一篇不同的文章中。在这里只要知道使用Selector能够处理多个通道就足够了。要点使用Selector可以构建一个非阻塞的网络服务。在新IO实现网络程序需要依靠ServerSocketChannel类与SocketChannelSelector实例下面使用Selector完成一个简单的服务器的操作服务器可以同时在多个端口进行监听此服务器的主要功能是返回当前时间。importjava.net.InetSocketAddress ;importjava.net.ServerSocket ;importjava.util.Set ;importjava.util.Iterator ;importjava.util.Date ;importjava.nio.channels.ServerSocketChannel ;importjava.nio.ByteBuffer ;importjava.nio.channels.SocketChannel ;importjava.nio.channels.Selector ;importjava.nio.channels.SelectionKey ;public classDateServer{public static void main(String args[]) throwsException {int ports[] {8000,8001,8002,8003,8005,8006} ; //表示五个监听端口Selector selector Selector.open() ; //通过open()方法找到Selectorfor(int i0;iServerSocketChannel initSer null;initSer ServerSocketChannel.open() ; //打开服务器的通道initSer.configureBlocking(false) ; //服务器配置为非阻塞ServerSocket initSock initSer.socket() ;InetSocketAddress address null;address new InetSocketAddress(ports[i]) ; //实例化绑定地址initSock.bind(address) ; //进行服务的绑定initSer.register(selector,SelectionKey.OP_ACCEPT) ; //等待连接System.out.println(服务器运行在 ports[i] 端口监听。) ;}//要接收全部生成的key并通过连接进行判断是否获取客户端的输出int keysAdd 0;while((keysAddselector.select())0){ //选择一组键并且相应的通道已经准备就绪Set selectedKeys selector.selectedKeys() ;//取出全部生成的keyIterator iter selectedKeys.iterator() ;while(iter.hasNext()){SelectionKey key iter.next() ; //取出每一个keyif(key.isAcceptable()){ServerSocketChannel server(ServerSocketChannel)key.channel() ;SocketChannel client server.accept() ; //接收新连接client.configureBlocking(false) ;//配置为非阻塞ByteBuffer outBuf ByteBuffer.allocateDirect(1024) ; // outBuf.put((当前的时间为 new Date()).getBytes()) ; //向缓冲区中设置内容outBuf.flip() ;client.write(outBuf) ;//输出内容client.close() ; //关闭}}selectedKeys.clear() ;//清楚全部的key}}}服务器完成之后可以使用Telnet命令完成这样就完成了一个一部的操作服务器。
