multiserver.java

JAVA在线通讯系统

import java.io.*;
import java.net.*;

class ServeOneJabber extends Thread{
  private Socket socket;
  private BufferedReader in;
  private PrintWriter out;
  
  public ServeOneJabber(Socket s) throws IOException
 { 
   socket=s;
   in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
   out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);
   start();
  } 

 public void run(){
   try{
    while(true)
       { 
       
        while(true)
        {
          try
           {
            String str = in.readLine();
            if (str.equals("END")) break;
            System.out.println("客户机的信息:" + str);
            
           }catch(IOException e){}
         }
          
         try
          {
          BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
          System.out.print("请输入您发送给客户端的信息：");
          String str2=br.readLine();
          out.println(str2);
          out.println("END");
          System.out.println("发送成功！");
          if (str2.equals("bye")) break;
           }catch(IOException e){}  
        }
   }finally
         {
          try{
             socket.close();
             }catch(IOException e){}
            System.out.println("通讯关闭！");
           
         }     
   }
 
}
         
 public class MultiServer{
    public static final int PORT = 8080;
    public static void main(String[] args)throws IOException{
      ServerSocket s=new ServerSocket(PORT);
      
      System.out.println("Server Started"+ s);
      try
      {
      while(true)
       {
         Socket socket=s.accept();        
         System.out.println("Connection accepted: " + socket);
         new ServeOneJabber(socket);
          
       }        
      }finally{ s.close();}
   }	
 }