Java NIO 网络编程基础

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
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.Iterator;
import java.util.Set;

public class MyServer {
    public static void main(String args[]) throws Exception  
    {  
        MyServer server = new MyServer(8080);  
        server.listen();  
    }  
  
    // 接受和发送数据缓冲区  
    private ByteBuffer send = ByteBuffer.allocate(1024);  
    private ByteBuffer receive = ByteBuffer.allocate(1024);  
  
    public int port = 0;  
  
    ServerSocketChannel ssc = null;  
  
    Selector selector = null;  
  
    public MyServer(int port) throws Exception  
    {  
        // 打开服务器套接字通道  
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();  
        // 服务器配置为非阻塞  
        serverSocketChannel.configureBlocking(false);  
        // 检索与此通道关联的服务器套接字  
        ServerSocket serverSocket = serverSocketChannel.socket();  
        // 套接字的地址端口绑定
        serverSocket.bind(new InetSocketAddress(port));  
        // 通过open()方法找到Selector  
        selector = Selector.open();  
  
        // 注册到selector，等待连接  
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);  
        System.out.println("Server Start----8888:");  
          
        // 向发送缓冲区加入数据  
        send.put("data come from server".getBytes());  
    }  
  
    // 监听  
    private void listen() throws IOException  
    {  
        while (true)  
        {  
            // 等待一个连接，可能会返回多个key
            int count=selector.select();
            System.out.println("count="+count);
            // 返回此选择器的已选择键集。  
            Set<SelectionKey> selectionKeys = selector.selectedKeys();  
            Iterator<SelectionKey> iterator = selectionKeys.iterator();  
            while (iterator.hasNext())  
            {  
                SelectionKey selectionKey = iterator.next();  
  
                // 这里记得手动的把他remove掉，不然selector中的selectedKeys集合不会自动去除  
                iterator.remove();  
                handle(selectionKey);  
            }  
        }  
    }  
  
    // 处理请求  
    private void handle(SelectionKey selectionKey) throws IOException  
    {  
  
        ServerSocketChannel server = null;  
        SocketChannel client = null;  
        String receiveText;  
        String sendText;  
        int count = 0;  
  
        // 测试此键的通道是否已准备好接受新的套接字连接。  
        if (selectionKey.isAcceptable())  
        {  
            System.out.println("selectionKey.isAcceptable()");
            // 返回为之创建此键的通道。  
            server = (ServerSocketChannel) selectionKey.channel();  
  
            // 此方法返回的套接字通道（如果有）将处于阻塞模式。  
            client = server.accept();  
            // 配置为非阻塞  
            client.configureBlocking(false);  
            // 注册到selector，等待连接  
            client.register(selector, SelectionKey.OP_READ  
                    | SelectionKey.OP_WRITE);  
        }  
        else  
            if (selectionKey.isReadable())  
            {  
                System.out.println("selectionKey.isReadable()");
                // 返回为之创建此键的通道。  
                client = (SocketChannel) selectionKey.channel();  
                // 将缓冲区清空以备下次读取  
                receive.clear();  
                // 读取服务器发送来的数据到缓冲区中  
                client.read(receive);  
  
//                System.out.println(new String(receive.array()));  
                  
                selectionKey.interestOps(SelectionKey.OP_WRITE);  
            }  
            else  
                if (selectionKey.isWritable())  
                {  
                    System.out.println("selectionKey.isWritable()");
                    // 将缓冲区清空以备下次写入  
                    send.flip();  
                    // 返回为之创建此键的通道。  
                    client = (SocketChannel) selectionKey.channel();  
  
                    // 输出到通道  
                    client.write(send);  
                      
//                    selectionKey.interestOps(SelectionKey.OP_READ);  
                }  
    } 
}