java nio 笔记

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Date;
import java.util.Iterator;
import java.util.Scanner;
import java.util.Set;

import org.junit.Test;

/*一、使用 NIO 完成网络通信的三个核心：
* 
* 1. 通道（Channel）：负责连接
* 		
* 	   java.nio.channels.Channel 接口：
* 			|--SelectableChannel(注意没有FileChannel) 
* 				|--SocketChannel
* 				|--ServerSocketChannel
* 				|--DatagramChannel
* 
* 				|--Pipe.SinkChannel
* 				|--Pipe.SourceChannel
* 
* 2. 缓冲区（Buffer）：负责数据的存取
* 
* 3. 选择器（Selector）：是 SelectableChannel 的多路复用器。用于监控 SelectableChannel 的 IO 状况
* 为了与选择器一起使用，SelectableChannel类的实例必须首先通过 register 方法进行注册。此方法返回一个表示该通道
* 已向选择器注册的新 SelectionKey 对象。
* 重点：工作原理
* 1.通过 SelectionKey 对象来表示可选择通道到选择器的注册。选择器维护了三种选择键集
键集 ===》：包含的键表示当前通道到此选择器的注册。此集合由 keys 方法返回。
已选择键集====》： 是这样一种键的集合，即在前一次选择操作期间，检测每个键的通道
是否已经至少为该键的相关操作集所标识的一个操作准备就绪。此集合由 selectedKeys 方法返回。
已选择键集始终是键集的一个子集。
已取消键集====》： 是已被取消但其通道尚未注销的键的集合。不可直接访问此集合。已取消键集始终是键集的一个子集。
*	关于remove（）：通过选择操作将键添加到已选择键集中。可通过调用已选择键集的 remove 方法，或者通过调用从该键集获得
*	的 iterator 的 remove 方法直接移除某个键。通过任何其他方式从不会将键从已选择键集中移除；特别是，
*	它们不会因为影响选择操作而被移除。不能将键直接添加到已选择键集中。 
*
*
* 
* 
* 
* 
* 
* 
*/
public class TestNonBlockingNIO {

	// 聊天室小案例

	// 客户端
	@Test
	public void testCliet() {
		SocketChannel sChannel = null;
		Scanner scanner = null;
		// 1.获取通道
		try {
			sChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 9898));
			// 2.切换非阻塞模式
			sChannel.configureBlocking(false);

			// 3.分配指定大小的缓冲区
			ByteBuffer buf = ByteBuffer.allocate(1024);
			// 4.发送数据给服务端
			scanner = new Scanner(System.in);
			while (scanner.hasNext()) {
				String str = new Date().toString() + "\n" + scanner.next();
				buf.put(str.getBytes());
				buf.flip();
				sChannel.write(buf);
				buf.clear();
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			if (sChannel != null) {
				try {
					sChannel.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			scanner.close();
		}
	}

	// 服务端
	/*
	 * 异常没有try——catch
	 */
	@Test
	public void testServer() throws IOException {
		// 1.获取通道
		ServerSocketChannel ssChannel = ServerSocketChannel.open();
		// 2.切换成非阻塞模式
		ssChannel.configureBlocking(false);
		// 3.绑定链接
		ssChannel.bind(new InetSocketAddress(9898));
		// 4.打开选择器
		Selector sel = Selector.open();
		// 5.将通道注册到选择器中（当开启多个客户端时，相对应服务端会在选择器中形成“键集”）
		ssChannel.register(sel, SelectionKey.OP_ACCEPT);
		// 6.轮询选择器，取出准备就绪的 “键”
		while (sel.select() > 0) {// 已准备就绪“键”的数量
			Set
 
   selectedKeys = sel.selectedKeys();// 得到“准备就绪”事件的“已选择键集”
			// 7.将这些“已选择键集”遍历，对每个键进行操作
			Iterator
  
    iterator = selectedKeys.iterator(); while (iterator.hasNext()) { SelectionKey selectionKey = iterator.next(); // 8.判断“准备就绪”的事件，是什么事件 if (selectionKey.isAcceptable()) { // 9.如果该事件是“接收就绪”，则可以获得客户端链接通道 SocketChannel sChannel = ssChannel.accept(); // 10.将新通道设置成非阻塞状态 sChannel.configureBlocking(false); // 11.将新通道注册到选择器上 sChannel.register(sel, SelectionKey.OP_READ); } else if (selectionKey.isReadable()) { // 12.如果就绪事件是“读就绪”状态，则就获取该selectionkey对应的通道 SocketChannel sChannel = (SocketChannel) selectionKey.channel(); // 13.读取通道里的数据 ByteBuffer buf = ByteBuffer.allocate(1024); int len = 0; while ((len = sChannel.read(buf)) > 0) {//为什么这里>-1 程序会出错 buf.flip(); System.out.println(new String(buf.array(), 0, len)); buf.clear(); } } } // 14.取消“已选择集” iterator.remove(); } } }