java如何实现异步通讯？

下面是java异步通讯的服务器端源码，请问各位谁会客户端的源码？ 谢谢了package com.dmzg.socket.demo;
import java.io.IOException;
import java.net.*;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.SelectableChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.CharacterCodingException;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Set;/**
 * ServerSocketChannel就相当于ServerSocket
 * (ServerSocketChannel封装了ServerSocket),
 * 而SocketChannel就相当于Socket（SocketChannel封装了Socket）。
 * @author Administrator
 *
 */
public class NBlockingServer {
int port = 8000; 
int BUFFERSIZE = 1024; 
Selector selector = null; 
ServerSocketChannel serverChannel = null; 
@SuppressWarnings("unchecked")
HashMap clientChannelMap = null;//用来存放每一个客户连接对应的套接字和通道  public NBlockingServer( int port ) { 
this.clientChannelMap = new HashMap(); 
this.port = port; 
}  public void initialize() throws IOException { 
//初始化，分别实例化一个选择器，一个服务器端可选择通道 
this.selector = Selector.open(); 
this.serverChannel = ServerSocketChannel.open(); 
this.serverChannel.configureBlocking(false); 
InetAddress localhost = InetAddress.getLocalHost(); 
InetSocketAddress isa = new InetSocketAddress(localhost, this.port ); 
this.serverChannel.socket().bind(isa);//将该套接字绑定到服务器某一可用端口 
} 
//结束时释放资源 
public void finalize() throws IOException { 
this.serverChannel.close(); 
this.selector.close(); 
} 
//将读入字节缓冲的信息解码 
public String decode( ByteBuffer byteBuffer ) throws 
CharacterCodingException { 
Charset charset = Charset.forName( "ISO-8859-1" ); 
CharsetDecoder decoder = charset.newDecoder(); 
CharBuffer charBuffer = decoder.decode( byteBuffer ); 
String result = charBuffer.toString(); 
return result; 
} 
//监听端口，当通道准备好时进行相应操作 
public void portListening() throws IOException, InterruptedException { 
//服务器端通道注册OP_ACCEPT事件 
SelectionKey acceptKey =this.serverChannel.register( this.selector, 
SelectionKey.OP_ACCEPT ); 
//当有已注册的事件发生时,select()返回值将大于0 
while (acceptKey.selector().select() > 0 ) { 
System.out.println("event happened");
//取得所有已经准备好的所有选择键 
Set readyKeys = this.selector.selectedKeys(); 
//使用迭代器对选择键进行轮询 
Iterator i = readyKeys.iterator(); 
while (i.hasNext()){
if ( acceptKey.isReadable()  ) {//如果是通道读准备好事件 
System.out.println("Readable"); 
//取得选择键对应的通道和套接字 
SelectableChannel nextReady = 
(SelectableChannel) acceptKey.channel(); 
Socket socket = (Socket) acceptKey.attachment(); 
//处理该事件，处理方法已封装在类ClientChInstance中 
this.readFromChannel( socket.getChannel(), 
(ClientChInstance) 
this.clientChannelMap.get( socket ) ); 
} 
else if ( acceptKey.isWritable() ) {//如果是通道写准备好事件 
System.out.println("writeable"); 
//取得套接字后处理，方法同上 
Socket socket = (Socket) acceptKey.attachment(); 
SocketChannel channel = (SocketChannel) 
socket.getChannel(); 
this.writeToChannel( channel,"This is from server!"); 
} 
} 
}
} 
//对通道的写操作 
public void writeToChannel( SocketChannel channel, String message ) 
throws IOException { 
ByteBuffer buf = ByteBuffer.wrap( message.getBytes() ); 
int nbytes = channel.write( buf ); 
} 
//对通道的读操作 
public void readFromChannel( SocketChannel channel, ClientChInstance clientInstance ) 
throws IOException, InterruptedException { 
ByteBuffer byteBuffer = ByteBuffer.allocate( BUFFERSIZE ); 
int nbytes = channel.read( byteBuffer ); 
byteBuffer.flip(); 
String result = this.decode( byteBuffer ); 
//当客户端发出”@exit”退出命令时，关闭其通道 
if ( result.indexOf( "@exit" ) >= 0 ) { 
channel.close(); 
} 
else { 
clientInstance.append( result.toString() ); 
//读入一行完毕，执行相应操作 
if ( result.indexOf( "\n" ) >= 0 ){ 
System.out.println("client input"+result); 
clientInstance.execute(); 
} 
} 
} 
//该类封装了怎样对客户端的通道进行操作，具体实现可以通过重载execute()方法 
public class ClientChInstance { 
SocketChannel channel; 
StringBuffer buffer=new StringBuffer(); 
public ClientChInstance( SocketChannel channel ) { 
this.channel = channel; 
} 
public void execute() throws IOException { 
String message = "This is response after reading from channel!"; 
writeToChannel( this.channel, message ); 
buffer = new StringBuffer(); 
} 
//当一行没有结束时，将当前字窜置于缓冲尾 
public void append( String values ) { 
buffer.append( values ); 
} 
} 
//主程序 
public static void main( String[] args ) { 
NBlockingServer nbServer = new NBlockingServer(8000); 
try { 
nbServer.initialize(); 
} catch ( Exception e ) { 
e.printStackTrace(); 
System.exit( -1 ); 
} 
try { 
nbServer.portListening(); 
} 
catch ( Exception e ) { 
e.printStackTrace(); 
} 
} 
}