SocketConfig config=new SocketConfig(true, "10.33.6.178", 8899);
TCPServerProtocol protocol=new DefaultServerProtocol(new AcceptListener(){@Overridepublic void handleEvent(SocketStat socket) {socket.getConfig().getProtocol().addReadListener(new TestRead());}});NSocketService server=new NSocketService(config, protocol);

public void handleEvent(byte[] message,TCPProtocol tcpProtocol) {System.out.println(new String(message,Charset.forName("GBK")));tcpProtocol.sendMessage("hello".getBytes(Charset.forName("GBK")));
}

SocketConfig config=new SocketConfig(true, "10.33.6.178", 8899);config.getProtocol().addReadListener(new ReadListener() {@Overridepublic void handleEvent(byte[] message, TCPProtocol tcpProtocol) {System.out.println("recive from server:"+ new String(message));                }});NSocketClient client=new NSocketClient(config);client.sendMessage("test nsocket".getBytes());

public class DefaultServerProtocol implements TCPServerProtocol{ private LinkedList<AcceptListener> acceptList=new LinkedList<AcceptListener>();       public DefaultServerProtocol(AcceptListener... acceptColl){for(AcceptListener al:acceptColl){this.addAcceptListener(al);}}@Overridepublic SocketStat handleAccept(SelectionKey key) throws IOException {SocketChannel channel=((ServerSocketChannel)key.channel()).accept();  channel.configureBlocking(false);  Socket socket=channel.socket();SocketConfig config=new SocketConfig(false,socket.getInetAddress().getHostAddress(),socket.getPort(),this.createProtocol());        SocketStat stat=new SocketStat(config, key.selector(), channel);System.out.println("远程客户端地址：".concat(socket.getInetAddress().getHostAddress()));notifyAccept(stat);return stat;}@Overridepublic void addAcceptListener(AcceptListener al) {this.acceptList.add(al);       }@Overridepublic void notifyAccept(SocketStat socket) {for(AcceptListener al: acceptList){al.handleEvent(socket);}}/*** * 获取关于TCP 的读取和写入操作协议，可以override 返回自己的实现** @return      * @since  Ver 1.0*/public TCPProtocol createProtocol(){return new DefaultTCPProtocol();}
}

public class DefaultTCPProtocol implements TCPProtocol {       /**读取缓存区*/private ByteBuffer readBuff;        /**待发送消息队列*/protected Queue<ByteBuffer> messageQueue=new LinkedBlockingQueue<ByteBuffer>();/**锁*/private Object lockObje=new Object();/**读取监听*/private LinkedList<ReadListener> readList=new LinkedList<ReadListener>();/**发送监听*/private LinkedList<SendListener> sendList=new LinkedList<SendListener>();public DefaultTCPProtocol(ReadListener... readColl){        readBuff=ByteBuffer.allocate(1024);          for(ReadListener rl : readColl){this.addReadListener(rl);}}   @Overridepublic void handleRead(SelectionKey key) throws IOException {        SocketChannel clientChn=(SocketChannel)key.channel();ByteArrayOutputStream out=new ByteArrayOutputStream();try{   synchronized(this.readBuff){readBuff.clear();int bytesRead=clientChn.read(readBuff);    if(bytesRead==-1){throw new IOException("远程已关闭");}while(bytesRead>0){readBuff.flip();                out.write(readBuff.array(), 0, readBuff.limit());readBuff.clear();bytesRead=clientChn.read(readBuff);}            }                               key.interestOps(SelectionKey.OP_READ);notifyRead(out.toByteArray());}finally{out.close();}}       @Overridepublic  void handleWrite(SelectionKey key) throws IOException {SocketChannel clientChn=(SocketChannel)key.channel();ByteBuffer message=null;while(!messageQueue.isEmpty()){synchronized(lockObje){if(!messageQueue.isEmpty()){message=this.messageQueue.peek();                                        clientChn.write(message);if(message.hasRemaining()){                        break; }                    messageQueue.poll();}                                      }               }        key.interestOps(SelectionKey.OP_READ);}/*** * 发送消息（此时不是真正发送，而是放在一个待发送的队列中）** @param message 信息      * @since  Ver 1.0*/@Overridepublic void sendMessage(byte[] message) {        messageQueue.add(ByteBuffer.wrap(message));this.notifySend(message);}@Overridepublic void addReadListener(ReadListener rl) {        readList.add(rl);        }@Overridepublic void addSendListener(SendListener sl) {sendList.add(sl);}@Overridepublic void removeReadListener(ReadListener rl) {readList.remove(rl);}@Overridepublic void removeSendListener(SendListener rl) {sendList.remove(rl);}private void notifyRead(byte[] message) {               for(ReadListener rl : readList){rl.handleEvent(message,this);}}private void notifySend(byte[] message) {for(SendListener rl : sendList){rl.handleEvent(message);}}}