以下代码只兼容Java 7及以上版本，对于一些关键地方请看注释说明。
公共类：
package com.stevex.app.nio;
?
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.charset.CharacterCodingException;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.nio.charset.CharsetEncoder;
?
public class CharsetHelper {
? ? private static final String UTF_8 = "UTF-8";
? ? private static CharsetEncoder encoder = Charset.forName(UTF_8).newEncoder();
? ? private static CharsetDecoder decoder = Charset.forName(UTF_8).newDecoder();
? ?
? ? public static ByteBuffer encode(CharBuffer in) throws CharacterCodingException{
? ? ? ? return encoder.encode(in);
? ? }
?
? ? public static CharBuffer decode(ByteBuffer in) throws CharacterCodingException{
? ? ? ? return decoder.decode(in);
? ? }
}
服务器代码：
package com.stevex.app.nio;
?
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.ClosedChannelException;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
?
public class XiaoNa {
? ? private ByteBuffer readBuffer;
? ? private Selector selector;
? ?
? ? public static void main(String[] args){
? ? ? ? XiaoNa xiaona = new XiaoNa();
? ? ? ? xiaona.init();
? ? ? ? xiaona.listen();
? ? }
? ?
? ? private void init(){
? ? ? ? readBuffer = ByteBuffer.allocate(1024);
? ? ? ? ServerSocketChannel servSocketChannel;
? ? ? ?
? ? ? ? try {
? ? ? ? ? ? servSocketChannel = ServerSocketChannel.open();
? ? ? ? ? ? servSocketChannel.configureBlocking(false);
? ? ? ? ? ? //绑定端口
? ? ? ? ? ? servSocketChannel.socket().bind(new InetSocketAddress(8383));
? ? ? ? ? ?
? ? ? ? ? ? selector = Selector.open();
? ? ? ? ? ? servSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }? ? ?
? ? }
?
? ? private void listen() {
? ? ? ? while(true){
? ? ? ? ? ? try{
? ? ? ? ? ? ? ? selector.select();? ? ? ? ? ? ?
? ? ? ? ? ? ? ? Iterator ite = selector.selectedKeys().iterator();
? ? ? ? ? ? ? ?
? ? ? ? ? ? ? ? while(ite.hasNext()){
? ? ? ? ? ? ? ? ? ? SelectionKey key = (SelectionKey) ite.next();? ? ? ? ? ? ? ? ?
? ? ? ? ? ? ? ? ? ? ite.remove();//确保不重复处理
? ? ? ? ? ? ? ? ? ?
? ? ? ? ? ? ? ? ? ? handleKey(key);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? catch(Throwable t){
? ? ? ? ? ? ? ? t.printStackTrace();
? ? ? ? ? ? }? ? ? ? ? ? ? ? ? ? ? ? ?
? ? ? ? }? ? ? ? ? ? ?
? ? }
?
? ? private void handleKey(SelectionKey key)
? ? ? ? ? ? throws IOException, ClosedChannelException {
? ? ? ? SocketChannel channel = null;
? ? ? ?
? ? ? ? try{
? ? ? ? ? ? if(key.isAcceptable()){
? ? ? ? ? ? ? ? ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel();
? ? ? ? ? ? ? ? channel = serverChannel.accept();//接受连接请求
? ? ? ? ? ? ? ? channel.configureBlocking(false);
? ? ? ? ? ? ? ? channel.register(selector, SelectionKey.OP_READ);
? ? ? ? ? ? }
? ? ? ? ? ? else if(key.isReadable()){
? ? ? ? ? ? ? ? channel = (SocketChannel) key.channel();
? ? ? ? ? ? ? ? readBuffer.clear();
? ? ? ? ? ? ? ? /*当客户端channel关闭后，会不断收到read事件，但没有消息，即read方法返回-1
? ? ? ? ? ? ? ? * 所以这时服务器端也需要关闭channel，避免无限无效的处理*/? ? ? ? ? ? ?
? ? ? ? ? ? ? ? int count = channel.read(readBuffer);
? ? ? ? ? ? ? ?
? ? ? ? ? ? ? ? if(count > 0){
? ? ? ? ? ? ? ? ? ? //一定需要调用flip函数，否则读取错误数据
? ? ? ? ? ? ? ? ? ? readBuffer.flip();
? ? ? ? ? ? ? ? ? ? /*使用CharBuffer配合取出正确的数据
? ? ? ? ? ? ? ? ? ? String question = new String(readBuffer.array());?
? ? ? ? ? ? ? ? ? ? 可能会出错，因为前面readBuffer.clear();并未真正清理数据
? ? ? ? ? ? ? ? ? ? 只是重置缓冲区的position,