1. 复习NIO

在学习Netty之前，先来回顾一下NIO的通信步骤：

①创建ServerSocketChannel，为其配置非阻塞模式。

②绑定监听，配置TCP参数，录入backlog大小等。

③创建一个独立的IO线程，用于轮询多路复用器Selector。

④创建Selector，将之前创建的ServerSocketChannel注册到Selector上，并设置监听标识位SelectionKey.OP_ACCEPT。

⑤启动IO线程，在循环体中执行Selector.select()方法，轮询就绪的通道。

⑥当轮询到处于就绪状态的通道时，需要进行操作位判断，如果是ACCEPT状态，说明是新的客户端接入，则调用accept方法接收新的客户端。

⑦设置新接入客户端的一些参数，如非阻塞，并将其继续注册到Selector上，设置监听标识位等。

⑧如果轮询的通道标识位是READ，则进行读取，构造Buffer对象等。

⑨更细节的问题还有数据没发送完成继续发送的问题......

参考代码如下：

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.text.SimpleDateFormat;import java.util.Date;import java.util.Iterator;import java.util.Vector;public class ChatServer implements Runnable {    //选择器    private Selector selector;    //注册ServerSocketChannel后的选择键    private SelectionKey serverKey;    //标识是否运行    private boolean isRun;    //当前聊天室中的用户名称列表    private Vector
   
     unames;    //时间格式化器    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");    /**     * 构造函数     * @param port 服务端监控的端口号     */    public ChatServer(int port) {        isRun = true;        unames = new Vector
    
     ();        init(port);    }    /**     * 初始化选择器和服务器套接字     *     * @param port 服务端监控的端口号     */    private void init(int port) {        try {            //获得选择器实例            selector = Selector.open();            //获得服务器套接字实例            ServerSocketChannel serverChannel = ServerSocketChannel.open();            //绑定端口号            serverChannel.socket().bind(new InetSocketAddress(port));            //设置为非阻塞            serverChannel.configureBlocking(false);            //将ServerSocketChannel注册到选择器，指定其行为为"等待接受连接"            serverKey = serverChannel.register(selector, SelectionKey.OP_ACCEPT);            printInfo("server starting...");        } catch (IOException e) {            e.printStackTrace();        }    }    @Override    public void run() {        try {            //轮询选择器选择键            while (isRun) {                //选择一组已准备进行IO操作的通道的key，等于1时表示有这样的key                int n = selector.select();                if (n > 0) {                    //从选择器上获取已选择的key的集合并进行迭代                    Iterator
     
       iter = selector.selectedKeys().iterator();                    while (iter.hasNext()) {                        SelectionKey key = iter.next();                        //若此key的通道是等待接受新的套接字连接                        if (key.isAcceptable()) {                            //记住一定要remove这个key，否则之后的新连接将被阻塞无法连接服务器                            iter.remove();                            //获取key对应的通道                            ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel();                            //接受新的连接返回和客户端对等的套接字通道                            SocketChannel channel = serverChannel.accept();                            if (channel == null) {                                continue;                            }                            //设置为非阻塞                            channel.configureBlocking(false);                            //将这个套接字通道注册到选择器，指定其行为为"读"                            channel.register(selector, SelectionKey.OP_READ);                        }                        //若此key的通道的行为是"读"                        if (key.isReadable()) {                            readMsg(key);                        }                        //若次key的通道的行为是"写"                        if (key.isWritable()) {                            writeMsg(key);                        }                    }                }            }        } catch (IOException e) {            e.printStackTrace();        }    }    /**     * 从key对应的套接字通道上读数据     * @param key 选择键     * @throws IOException     */    private void readMsg(SelectionKey key) throws IOException {        //获取此key对应的套接字通道        SocketChannel channel = (SocketChannel) key.channel();        //创建一个大小为1024k的缓存区        ByteBuffer buffer = ByteBuffer.allocate(1024);        StringBuffer sb = new StringBuffer();        //将通道的数据读到缓存区        int count = channel.read(buffer);        if (count > 0) {            //翻转缓存区(将缓存区由写进数据模式变成读出数据模式)            buffer.flip();            //将缓存区的数据转成String            sb.append(new String(buffer.array(), 0, count));        }        String str = sb.toString();        //若消息中有"open_"，表示客户端准备进入聊天界面        //客户端传过来的数据格式是"open_zing"，表示名称为zing的用户请求打开聊天窗体        //用户名称列表有更新，则应将用户名称数据写给每一个已连接的客户端        if (str.indexOf("open_") != -1) {//客户端连接服务器            String name = str.substring(5);            printInfo(name + " online");            unames.add(name);            //获取选择器已选择的key并迭代            Iterator
      
        iter = selector.selectedKeys().iterator();            while (iter.hasNext()) {                SelectionKey selKey = iter.next();                //若不是服务器套接字通道的key，则将数据设置到此key中                //并更新此key感兴趣的动作                if (selKey != serverKey) {                    selKey.attach(unames);                    selKey.interestOps(selKey.interestOps() | SelectionKey.OP_WRITE);                }            }        } else if (str.indexOf("exit_") != -1) {// 客户端发送退出命令            String uname = str.substring(5);            //删除此用户名称            unames.remove(uname);            //将"close"字符串附加到key            key.attach("close");            //更新此key感兴趣的动作            key.interestOps(SelectionKey.OP_WRITE);            //获取选择器上的已选择的key并迭代            //将更新后的名称列表数据附加到每个套接字通道key上,并重设key感兴趣的操作            Iterator
       
         iter = key.selector().selectedKeys().iterator();            while (iter.hasNext()) {                SelectionKey selKey = iter.next();                if (selKey != serverKey && selKey != key) {                    selKey.attach(unames);                    selKey.interestOps(selKey.interestOps() | SelectionKey.OP_WRITE);                }            }            printInfo(uname + " offline");        } else {// 读取客户端聊天消息            String uname = str.substring(0, str.indexOf("^"));            String msg = str.substring(str.indexOf("^") + 1);            printInfo("("+uname+")说：" + msg);            String dateTime = sdf.format(new Date());            String smsg = uname + " " + dateTime + "\n  " + msg + "\n";            Iterator
        
          iter = selector.selectedKeys().iterator(); while (iter.hasNext()) { SelectionKey selKey = iter.next(); if (selKey != serverKey) { selKey.attach(smsg); selKey.interestOps(selKey.interestOps() | SelectionKey.OP_WRITE); } } } } /** * 写数据到key对应的套接字通道 * @param key * @throws IOException */ private void writeMsg(SelectionKey key) throws IOException { SocketChannel channel = (SocketChannel) key.channel(); Object obj = key.attachment(); //这里必要要将key的附加数据设置为空，否则会有问题 key.attach(""); //附加值为"close"，则取消此key，并关闭对应通道 if (obj.toString().equals("close")) { key.cancel(); channel.socket().close(); channel.close(); return; }else { //将数据写到通道 channel.write(ByteBuffer.wrap(obj.toString().getBytes())); } //重设此key兴趣 key.interestOps(SelectionKey.OP_READ); } private void printInfo(String str) { System.out.println("[" + sdf.format(new Date()) + "] -> " + str); } public static void main(String[] args) { ChatServer server = new ChatServer(19999); new Thread(server).start(); }}