关于java.nio库和网络通信的问题

客户端
////////////////////////
//AsyncClient.java
//   by [email protected]
////////////////////////
import java.nio.channels.SocketChannel;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.Selector;
import java.nio.channels.SelectionKey;import java.io.IOException;
import java.io.BufferedReader;
import java.io.InputStreamReader;class AsyncClient{
 private SocketChannel sc;
 private final int MAX_LENGTH = 1024;
 private ByteBuffer r_buff = ByteBuffer.allocate(MAX_LENGTH);
 private ByteBuffer w_buff = ByteBuffer.allocate(MAX_LENGTH);
 private static String host ;
 private static int port = 8848; public AsyncClient(){
  try {
   InetSocketAddress addr = new InetSocketAddress(host,port);
   //生成一个socketchannel
   sc = SocketChannel.open();   //连接到server
   sc.connect(addr);
   while(!sc.finishConnect())
    ;
   System.out.println("connection has been established!...");   while(true){
    //回射消息
    String echo;
    try{
     System.err.println("Enter msg you'd like to send:  ");
     BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
     //输入回射消息
     echo = br.readLine();     //把回射消息放入w_buff中
     w_buff.clear();
     w_buff.put(echo.getBytes());
     w_buff.flip();
    }catch(IOException ioe){
     System.err.println("sth. is wrong with br.readline() ");
    }    //发送消息
    while(w_buff.hasRemaining())
     sc.write(w_buff);
    w_buff.clear();    //进入接收状态
    Rec();
    //间隔1秒
    Thread.currentThread().sleep(1000);
   }
  }catch(IOException ioe){
   ioe.printStackTrace();
  }
  catch(InterruptedException ie){
   ie.printStackTrace();
  }
 }
////////////
 //读取server端发回的数据，并显示
 public void Rec() throws IOException{
  int count;
  r_buff.clear();
  count=sc.read(r_buff);
  r_buff.flip();
  byte[] temp = new byte[r_buff.limit()];
  r_buff.get(temp);
  System.out.println("reply is " + count +" long, and content is: " + new String(temp));
 } public static void main(String args[]){
  if(args.length < 1){//输入需有主机名或IP地址
   try{
    System.err.println("Enter host name: ");
    BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    host = br.readLine();
   }catch(IOException ioe){
    System.err.println("sth. is wrong with br.readline() ");
   }
  }
  else if(args.length == 1){
   host = args[0];
  }
  else if(args.length > 1){
   host = args[0];
   port = Integer.parseInt(args[1]);
  }  new AsyncClient();
 }
}
服务器端：
////////////////////////
//AsyncServer.java
//   by [email protected]
////////////////////////
import java.nio.channels.SocketChannel;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.ByteBuffer;
import java.nio.channels.SelectableChannel;
import java.nio.channels.spi.SelectorProvider;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.util.Iterator;
import java.util.LinkedList;
import java.io.IOException;
import java.io.*;class AsyncServer implements Runnable{
 private ByteBuffer r_buff = ByteBuffer.allocate(1024);
 private ByteBuffer w_buff = ByteBuffer.allocate(1024);
 private static int port = 8848; public AsyncServer(){
  new Thread(this).start();
 } public void run(){
  try{
   //生成一个侦听端
   ServerSocketChannel ssc = ServerSocketChannel.open();
   //将侦听端设为异步方式
   ssc.configureBlocking(false);
   //生成一个信号监视器
   Selector s = Selector.open();
   //侦听端绑定到一个端口
   ssc.socket().bind(new InetSocketAddress(port));
   //设置侦听端所选的异步信号OP_ACCEPT
   ssc.register(s,SelectionKey.OP_ACCEPT);   System.out.println("echo server has been set up ......");   while(true){
    int n = s.select();
    if (n == 0) {//没有指定的I/O事件发生
     continue;
    }
    Iterator it = s.selectedKeys().iterator();
    while (it.hasNext()) {
     SelectionKey key = (SelectionKey) it.next();
     if (key.isAcceptable()) {//侦听端信号触发
      ServerSocketChannel server = (ServerSocketChannel) key.channel();
      //接受一个新的连接
      SocketChannel sc = server.accept();
      sc.configureBlocking(false);
      //设置该socket的异步信号OP_READ:当socket可读时，     //触发函数DealwithData();
      sc.register(s,SelectionKey.OP_READ);
     }
     if (key.isReadable()) {//某socket可读信号
      DealwithData(key);
     }
     it.remove();
    }
   }
  }
  catch(Exception e){
   e.printStackTrace();
  }
 } public void DealwithData(SelectionKey key) throws IOException{
  int count;
  //由key获取指定socketchannel的引用
  SocketChannel sc = (SocketChannel)key.channel();
  r_buff.clear();
  //读取数据到r_buff
  while((count = sc.read(r_buff))> 0)
   ;
  //确保r_buff可读
  r_buff.flip();  w_buff.clear();
  //将r_buff内容拷入w_buff
  w_buff.put(r_buff);
  w_buff.flip();
  //将数据返回给客户端
  EchoToClient(sc);
  //System.out.println("您已经将内容输入到Redirect.txt文件！");//输入到DOS下。
   FileOutputStream fos=new FileOutputStream("Redirect.txt");
   //BufferedOutputStream bos=new BufferedOutputStream(fos,1024);
   //PrintStream ps=new PrintStream(bos,false);
   //重定向System.out到该文件
//System.setOut(ps);  w_buff.clear();
  r_buff.clear();
 } public void EchoToClient(SocketChannel sc) throws IOException{
  while(w_buff.hasRemaining())
   sc.write(w_buff);
 } public static void main(String args[]){
  if(args.length > 0){
   port = Integer.parseInt(args[0]);
  }
  new AsyncServer();
 }
}
这是一个回送的例子
我的想法是这样的，就是当客户端发送一个数据时在服务器端还能写从通道中写入到服务器的一个文件上，哪个高手麻烦帮忙改下，谢谢了。