实战java高并发程序设计-课程配套课件8.nio和

实战Java高并发程序设计讲师博客

DATAGURU专业数据分析 课程详 实战Java高并发程序设计讲师博客

DATAGURU专业数据分析 Dataguru（炼数成金）是专业数据分析，提供教育，，内容，社区，向式关于逆向式网络的详情，请看我们的培训 实战Java高并发程序设计讲师博客

DATAGURU专业数据分析什么是网络为什么需要了解NIO和实战Java高并发程序设计讲师博客

DATAGURU专业数据分析NIO是NewI/O的简称，与旧式的基于流的I/O方法相对，从名字看，它表示新的一套JavaI/O准。它是在Java1.4中被纳入到JDK中的，并具有以下特性 实战Java高并发程序设计讲师博客

DATAGURU专业数据分析Buffer&&缓冲缓冲实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析FileInputStreamFileInputStreamfin=newFileInputStream(newFileChannelByteBufferByteBuffer实战Java高并发程序设计讲师博客

DATAGURU专业数据分析

publicstaticvoidnioCopyFile(Stringresource,StringthrowsIOExceptionFileInputStreamfis=newFileInputStream(resource);FileOutputStreamfos=newFileOutputStream(destination);FileChannelreadChannel=fis.getChannel();FileChannelwriteChannel=fos.getChannel();ByteBufferbuffer=ByteBuffer.allocate(1024);while(true){intlen=readChannel.read(buffer);if(len==-1){ 完

//读文件通//写文件通//读入数据缓//读入数//写入文}

}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析Buffer中有3个重要的参数：位置（position）、容量（capactiy）和上限实战Java高并发程序设计讲师博客

DATAGURU专业数据分析ByteBufferb=ByteBuffer.allocate(15); System.out.println("limit="+b.limit()+"capacity="+b.capacity()+"position="+b.position());for(inti=0;i<10;i++){ } for(int}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicfinalBufferpublicfinalBufferpublicfinalBuffer实战Java高并发程序设计讲师博客

DATAGURU专业数据分析文件映射到RandomAccessFileraf=newRandomAccessFile("C:\\mapfile.txt",FileChannelfc=MappedByteBuffermbb=fc.map(FileChannel.MapMode.READ_WRITE,0,} 实战Java高并发程序设计讲师博客

DATAGURU专业数据分析多线程网络服务器的一般实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicpublicstaticvoidmain(Stringargs[]){ServerSocketechoServer=null;SocketclientSocket=null;tryechoServer=new}catch(IOExceptione)}while(true)tryclientSocket=echoServer.accept();tp.execute(newHandleMsg(clientSocket));}catch(IOExceptione)}}}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析staticclassHandleMsgimplementspublicvoidrun(){try{is=newBufferedReader(new StringinputLine=while((inputLine=is.readLine())!=null){}long}catch(IOExceptione)}}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析EchoServer的客publicstaticvoidmain(String[]args)throwsIOExceptionSocketclient=null;PrintWriterwriter=null;BufferedReaderreader=null;try{client=newwriter=newPrintWriter(client.getOutputStream(),true); reader=newBufferedReader(newInputStreamReader(client.getInputStream()));System.out.println("fromserver:"+reader.readLine());}}finally}}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析准备 解实战Java高并发程序设计讲师博客

DATAGURU专业数据分析privatestaticExecutorServiceprivatestaticfinalintpublicstaticclassEchoClientimplementsRunnable{publicvoidrun(){tryclient=newwriter=newPrintWriter(client.getOutputStream(),true);实战Java高并发程序设计讲师博客

DATAGURU专业数据分析服务器输出如实战Java高并发程序设计讲师博客

DATAGURU专业数据分析把数据准备好了再通Channel有点类似于流，一个Channel可以和文件或者 实战Java高并发程序设计讲师博客

DATAGURU专业数据分析参考总结 实战Java高并发程序设计讲师博客

DATAGURU专业数据分析读完了再通不会加快IO，只是在读完后进使用回调函数，进行业务处实战Java高并发程序设计讲师博客

DATAGURU专业数据分析serverserver=AsynchronousServerSocketChannel.open().bind(new <A>voidaccept(A CompletionHandler<AsynchronousSocketChannel,?super实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析server.accept(null,newCompletionHandler<AsynchronousSocketChannel,Object>()finalByteBufferbuffer=publicvoidcompleted(AsynchronousSocketChannelresult,Object ent)try{result.read(buffer).get(100,}catch(InterruptedException|ExecutionExceptione){}catch(TimeoutExcept