public class PlainNio2EchoServer{
	public void serve(int port)throws IOExcetpion{
		System.out.println("listening for connection on port "+port);
		final AsychronousServerSocketChannel serverChannel = AsychronousServerSocketChannel.open();
		InetAddress address = new InetAddress(port);
		serverChannel.bind(address);
		final CountDownLatch latch = new CountDownLatch(1);
		serverChannel.accept(null,
				     new CompletionHandler<AsychronousSocketChannel,Object>(){
							     @Override
								 public void completed(AsychronousSocketChannel channel,Object attachment){
									serverChannel.accept(null,this);
									ByteBuffer buffer = ByteBuffer.allocate(100);
									channel.read(buffer,buffer,new EchoCompletionHandler(channel));
								 }
								 
								 @Override
								 public void failed(Throwable throwable,Object attachment){
									try{
										serverChannel.close();
									}catch(IOExcetpion ex){	
									}finally{
										latch.countDown();
									}
								 }
							});
		try{
			latch.await();
		}catch(InterruptedException ex){
			Thread.currentThread().interrupt();
		}
	}
	
	private final class EchoCompletionHandler implements CompletionHandler<Integer,ByteBuffer>{
		private AsychronousSocketChannel channel;
		
		public EchoCompletionHandler(AsychronousSocketChannel channel){
			this.channel = channel;
		}
		
		@Override
		public void completed(Integer result,ByteBuffer buffer){
			buffer,flip();
			channel.write(buffer,buffer,
				             new CompletionHandler<Integer,ByteBuffer>{
								@Override
								public void completed(Integer result,ByteBuffer buffer){
									if(buffer.hasRemaining()){
										channel.write(buffer,buffer,this);
									}else{
										buffer.compact();
										channel.read(buffer,buffer,EchoCompletionHandler.this);
									}
								}
								
								@Override
								public void failed(Throwable throwable,ByteBuffer attachment){
									try{
										channel.close();
									}catch(IOExcetpion ex){
									}
								}
						  });
		}
		
		@Override
		public void failed(Throwable throwable,ByteBuffer attachment){
			try{
				channel.close();
			}catch(IOExcetpion ex){
			}
		}
	}
}