1. Name: Anna  
2. Age: 25  
3. Email: anna@mailserver.com  
4. Phone: 1234567890  

1. InputStream input = … ; // get the InputStream from the client socket  
2. BufferedReader reader = new BufferedReader(new InputStreamReader(input));  
3.   
4. String nameLine   = reader.readLine();  
5. String ageLine    = reader.readLine();  
6. String emailLine  = reader.readLine();  
7. String phoneLine  = reader.readLine();  

1. ByteBuffer buffer = ByteBuffer.allocate(48);  
2.   
3. int bytesRead = inChannel.read(buffer);  

1. ByteBuffer buffer = ByteBuffer.allocate(48);  
2. int bytesRead = inChannel.read(buffer);  
3. while(! bufferFull(bytesRead) ) {  
4. bytesRead = inChannel.read(buffer);  
5. }  

1. RandomAccessFile aFile = new RandomAccessFile("data/nio-data.txt", "rw");  
2. FileChannel inChannel = aFile.getChannel();  
3.   
4. ByteBuffer buf = ByteBuffer.allocate(48);  
5.   
6. int bytesRead = inChannel.read(buf);  
7. while (bytesRead != -1) {  
8.   
9. System.out.println("Read " + bytesRead);  
10. buf.flip();  
11.   
12. while(buf.hasRemaining()){  
13. System.out.print((char) buf.get());  
14. }  
15.   
16. buf.clear();  
17. bytesRead = inChannel.read(buf);  
18. }  
19. aFile.close();  

1. RandomAccessFile aFile = new RandomAccessFile("data/nio-data.txt", "rw");  
2. FileChannel inChannel = aFile.getChannel();  
3.   
4. //create buffer with capacity of 48 bytes  
5. ByteBuffer buf = ByteBuffer.allocate(48);  
6.   
7. int bytesRead = inChannel.read(buf); //read into buffer.  
8. while (bytesRead != -1) {  
9.   
10.   buf.flip();  //make buffer ready for read  
11.   
12.   while(buf.hasRemaining()){  
13.       System.out.print((char) buf.get()); // read 1 byte at a time  
14.   }  
15.   
16.   buf.clear(); //make buffer ready for writing  
17.   bytesRead = inChannel.read(buf);  
18. }  
19. aFile.close();  

1. ByteBuffer buf = ByteBuffer.allocate(48);  

1. CharBuffer buf = CharBuffer.allocate(1024);  

1. int bytesRead = inChannel.read(buf); //read into buffer.  

1. buf.put(127);  

1. //read from buffer into channel.  
2. int bytesWritten = inChannel.write(buf);  

1. byte aByte = buf.get();  

1. buffer.mark();  
2.   
3. //call buffer.get() a couple of times, e.g. during parsing.  
4.   
5. buffer.reset();  //set position back to mark.  

1. ByteBuffer header = ByteBuffer.allocate(128);  
2. ByteBuffer body   = ByteBuffer.allocate(1024);  
3.   
4. ByteBuffer[] bufferArray = { header, body };  
5.   
6. channel.read(bufferArray);  

1. ByteBuffer header = ByteBuffer.allocate(128);  
2. ByteBuffer body   = ByteBuffer.allocate(1024);  
3.   
4. //write data into buffers  
5.   
6. ByteBuffer[] bufferArray = { header, body };  
7.   
8. channel.write(bufferArray);  

1. RandomAccessFile fromFile = new RandomAccessFile("fromFile.txt", "rw");  
2. FileChannel      fromChannel = fromFile.getChannel();  
3.   
4. RandomAccessFile toFile = new RandomAccessFile("toFile.txt", "rw");  
5. FileChannel      toChannel = toFile.getChannel();  
6.   
7. long position = 0;  
8. long count = fromChannel.size();  
9.   
10. toChannel.transferFrom(position, count, fromChannel);  

1. RandomAccessFile fromFile = new RandomAccessFile("fromFile.txt", "rw");  
2. FileChannel      fromChannel = fromFile.getChannel();  
3.   
4. RandomAccessFile toFile = new RandomAccessFile("toFile.txt", "rw");  
5. FileChannel      toChannel = toFile.getChannel();  
6.   
7. long position = 0;  
8. long count = fromChannel.size();  
9.   
10. fromChannel.transferTo(position, count, toChannel);  

1. Selector selector = Selector.open();  

1. channel.configureBlocking(false);  
2. SelectionKey key = channel.register(selector,  
3.     Selectionkey.OP_READ);  

1. int interestSet = SelectionKey.OP_READ | SelectionKey.OP_WRITE;  

1. int interestSet = selectionKey.interestOps();  
2.   
3. boolean isInterestedInAccept  = (interestSet & SelectionKey.OP_ACCEPT) == SelectionKey.OP_ACCEPT；  
4. boolean isInterestedInConnect = interestSet & SelectionKey.OP_CONNECT;  
5. boolean isInterestedInRead    = interestSet & SelectionKey.OP_READ;  
6. boolean isInterestedInWrite   = interestSet & SelectionKey.OP_WRITE;  

1. selectionKey.isAcceptable();  
2. selectionKey.isConnectable();  
3. selectionKey.isReadable();  
4. selectionKey.isWritable();  

1. Channel  channel  = selectionKey.channel();  
2. Selector selector = selectionKey.selector();  

1. selectionKey.attach(theObject);  
2. Object attachedObj = selectionKey.attachment();  

1. SelectionKey key = channel.register(selector, SelectionKey.OP_READ, theObject);  

1. Set selectedKeys = selector.selectedKeys();  

1. Set selectedKeys = selector.selectedKeys();  
2. Iterator keyIterator = selectedKeys.iterator();  
3. while(keyIterator.hasNext()) {  
4.     SelectionKey key = keyIterator.next();  
5.     if(key.isAcceptable()) {  
6.         // a connection was accepted by a ServerSocketChannel.  
7.     } else if (key.isConnectable()) {  
8.         // a connection was established with a remote server.  
9.     } else if (key.isReadable()) {  
10.         // a channel is ready for reading  
11.     } else if (key.isWritable()) {  
12.         // a channel is ready for writing  
13.     }  
14.     keyIterator.<tuihighlight class="tuihighlight"><a href=http://www.mamicode.com/"javascript:;" style="display:inline;float:none;position:inherit;cursor:pointer;color:#7962D5;text-decoration:underline;" onclick="return false;">remove</a></tuihighlight>();  
15. }  

1. Selector selector = Selector.open();  
2. channel.configureBlocking(false);  
3. SelectionKey key = channel.register(selector, SelectionKey.OP_READ);  
4. while(true) {  
5.   int readyChannels = selector.select();  
6.   if(readyChannels == 0) continue;  
7.   Set selectedKeys = selector.selectedKeys();  
8.   Iterator keyIterator = selectedKeys.iterator();  
9.   while(keyIterator.hasNext()) {  
10.     SelectionKey key = keyIterator.next();  
11.     if(key.isAcceptable()) {  
12.         // a connection was accepted by a ServerSocketChannel.  
13.     } else if (key.isConnectable()) {  
14.         // a connection was established with a remote server.  
15.     } else if (key.isReadable()) {  
16.         // a channel is ready for reading  
17.     } else if (key.isWritable()) {  
18.         // a channel is ready for writing  
19.     }  
20.     keyIterator.<tuihighlight class="tuihighlight"><a href=http://www.mamicode.com/"javascript:;" style="display:inline;float:none;position:inherit;cursor:pointer;color:#7962D5;text-decoration:underline;" onclick="return false;">remove</a></tuihighlight>();  
21.   }  
22. }  

1. RandomAccessFile aFile = new RandomAccessFile("data/nio-data.txt", "rw");  
2. FileChannel inChannel = aFile.getChannel();  

1. ByteBuffer buf = ByteBuffer.allocate(48);  
2. int bytesRead = inChannel.read(buf);  

1. String newData = "New String to write to file..." + System.currentTimeMillis();  
2.   
3. ByteBuffer buf = ByteBuffer.allocate(48);  
4. buf.clear();  
5. buf.put(newData.getBytes());  
6.   
7. buf.flip();  
8.   
9. while(buf.hasRemaining()) {  
10.     channel.write(buf);  
11. }  

1. channel.close();  

1. long pos = channel.position();  
2. channel.position(pos +123);  

1. long fileSize = channel.size();  

1. channel.truncate(1024);  

1. channel.force(true);  

1. SocketChannel socketChannel = SocketChannel.open();  
2. socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));  

1. socketChannel.close();  

1. ByteBuffer buf = ByteBuffer.allocate(48);  
2. int bytesRead = socketChannel.read(buf);  

1. String newData = "New String to write to file..." + System.currentTimeMillis();  
2.   
3. ByteBuffer buf = ByteBuffer.allocate(48);  
4. buf.clear();  
5. buf.put(newData.getBytes());  
6.   
7. buf.flip();  
8.   
9. while(buf.hasRemaining()) {  
10.     channel.write(buf);  
11. }  

1. socketChannel.configureBlocking(false);  
2. socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));  
3.   
4. while(! socketChannel.finishConnect() ){  
5.     //wait, or do something else...  
6. }  

1. ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();  
2.   
3. serverSocketChannel.socket().bind(new InetSocketAddress(9999));  
4.   
5. while(true){  
6.     SocketChannel socketChannel =  
7.             serverSocketChannel.accept();  
8.   
9.     //do something with socketChannel...  
10. }  

1. ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();  

1. serverSocketChannel.close();  

1. while(true){  
2.     SocketChannel socketChannel =  
3.             serverSocketChannel.accept();  
4.   
5.     //do something with socketChannel...  
6. }  

1. ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();  
2.   
3. serverSocketChannel.socket().bind(new InetSocketAddress(9999));  
4. serverSocketChannel.configureBlocking(false);  
5.   
6. while(true){  
7.     SocketChannel socketChannel =  
8.             serverSocketChannel.accept();  
9.   
10.     if(socketChannel != null){  
11.         //do something with socketChannel...  
12.     }  
13. }  

1. DatagramChannel channel = DatagramChannel.open();  
2. channel.socket().bind(new InetSocketAddress(9999));  

1. ByteBuffer buf = ByteBuffer.allocate(48);  
2. buf.clear();  
3. channel.receive(buf);  

1. String newData = "New String to write to file..." + System.currentTimeMillis();  
2.   
3. ByteBuffer buf = ByteBuffer.allocate(48);  
4. buf.clear();  
5. buf.put(newData.getBytes());  
6. buf.flip();  
7.   
8. int bytesSent = channel.send(buf, new InetSocketAddress("jenkov.com", 80));  

1. channel.connect(new InetSocketAddress("jenkov.com", 80));  

1. int bytesRead = channel.read(buf);  
2. int bytesWritten = channel.write(but);  

1. Pipe pipe = Pipe.open();  

1. Pipe.SinkChannel sinkChannel = pipe.sink();  

1. String newData = "New String to write to file..." + System.currentTimeMillis();  
2. ByteBuffer buf = ByteBuffer.allocate(48);  
3. buf.clear();  
4. buf.put(newData.getBytes());  
5.   
6. buf.flip();  
7.   
8. while(buf.hasRemaining()) {  
9.     <b>sinkChannel.write(buf);</b>  
10. }  

1. Pipe.SourceChannel sourceChannel = pipe.source();  

1. ByteBuffer buf = ByteBuffer.allocate(48);  
2.   
3. int bytesRead = inChannel.read(buf);  

71 楼 莫欺少年穷Java 2016-04-13 13:32

  

70 楼 Nabulio 2016-04-11 15:38

将的太详细了

69 楼 imcrazyforyou 2016-04-01 12:47