1. 思路

• 首先顶霞，我們通過(guò)一個(gè)時(shí)序圖來(lái)看下如何創(chuàng)建一個(gè)NIO服務(wù)端并啟動(dòng)監(jiān)聽(tīng)，接收多個(gè)客戶(hù)端的連接办铡，進(jìn)行消息的異步讀寫(xiě)凌蔬。

0909010.png

public class NioServer
{

public static void main(String[] args)
{
    ServerSocketChannel channel = null;
    Selector selector = null;

    try
    {
        InetSocketAddress address = new InetSocketAddress(8400);
        channel = ServerSocketChannel.open();
        channel.configureBlocking(false);
        channel.socket().bind(address);

        selector = Selector.open();
        channel.register(selector, SelectionKey.OP_ACCEPT);
    } catch (IOException ex)
    {
        System.out.println("Couldn't setup server socket");
        System.out.println(ex.getMessage());
        System.exit(1);
    }

    ListenerThread listener = new ListenerThread(selector);
    listener.start();
}

}

class ListenerThread extends Thread
{
private Selector selector = null;

public ListenerThread(Selector selector)
{
    this.selector = selector;
}

public void run()
{
    while (true)
    {

        try
        {
            while (this.selector.select() > 0)
            {
                Set<SelectionKey> keys = this.selector.selectedKeys();
                Iterator<SelectionKey> iterator = keys.iterator();
                while (iterator.hasNext())
                {
                    SelectionKey key = iterator.next();

                    if (key.isAcceptable())
                    {
                        System.out.println("Accepting connection!");
                        ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel();
                        SocketChannel channel = serverChannel.accept();
                        channel.configureBlocking(false);
                        channel.register(this.selector, SelectionKey.OP_READ);
                    } else if (key.isReadable())
                    {
                        System.out.println("Accpting command!");
                        SocketChannel channel = (SocketChannel) key.channel();
                        ByteBuffer _buffer = ByteBuffer.allocate(256);
                        channel.read(_buffer);
                        _buffer.flip();
                        Charset charset = Charset.forName("UTF-8");
                        CharsetDecoder decoder = charset.newDecoder();
                        CharBuffer charBuffer = decoder.decode(_buffer);
                        System.out.println(charBuffer.toString());
                        channel.register(this.selector, SelectionKey.OP_WRITE);
                    } else if (key.isWritable())
                    {
                        System.out.println("Sending response!");
                        SocketChannel channel = (SocketChannel) key.channel();
                        channel.write(ByteBuffer.wrap(new String("Hello World\n").getBytes()));
                        channel.register(this.selector, SelectionKey.OP_READ);
                    }
                    iterator.remove();
                }
            }
        } catch (IOException ex)
        {
            System.out.println("Error in poll loop");
            System.out.println(ex.getMessage());
            System.exit(1);
        }
    }
}

}

QQ截圖20160704031026.png

• 在window下，通過(guò)telnet 127.0.0.1 8400 即可測(cè)試程序的運(yùn)行過(guò)程與結(jié)果衫嵌。