serverthread.java

JAVA实现的网络服务器文件同步

package com.msd;

import java.net.ServerSocket;
import java.net.Socket;

public class ServerThread implements Runnable {

   private ServerSocket server = null;
   private String clientAddr = null;

   public ServerThread(ServerSocket _server,String _clientAddr) {
       this.server = _server;
	   this.clientAddr = _clientAddr;
   }

   public void run() {
       try {
           while(true) {
               Socket socket = null;
               try {
                   socket = server.accept();
                   String acceptAddress = (socket.getInetAddress()).getHostAddress();
                   if(acceptAddress.equals(clientAddr)) {
                      (SocketList.getInstance()).addList(socket);
                   } else {
                      Log.logger.info("*****Error***** : have other server[" + acceptAddress +"] accept !");
                      try {
                          socket.close();
                          socket = null;
                      } catch(Exception e) { }
                   }
               } catch (Exception e1) { 
                   if(socket != null) {
                      try {
                          socket.close();
                          socket = null;
                      } catch(Exception e2) { }
                   }
               }
           }
	   } catch(Exception e) {
           Log.logger.error("ServerThread run Exception:" + e);
		   (ServerThreadFactory.getInstance()).ExceptionServerOut();
	   }  
   }

}