javasocketserver.java

实现聊天服务器的功能

import java.io.*;
import java.net.*;
class JavaSocketServer extends Thread 
{
	
	
	ServerSocket server;
	//=======================================================
	public JavaSocketServer() 
	{
		try 
		{
			server = new ServerSocket(6000);
		}
    catch(IOException e) 
    {
      System.out.println("Cannot create Server");
      System.exit(0);
    }
    
    
    System.out.println("Now socket server will Start");
    this.start();
    
}
  
  //=======================================================
  public void run() 
  {    
    try 
    {
      while (true) 
      {
        Socket client = server.accept();
        Service ss = new Service(client);
      }
    }
    catch(IOException e) 
    {
      System.out.println("Cann't provide service !");
      System.exit(1);
    }
  }
  
//==============================================================
  public static void main(String args[])
  {
    String data;
    BufferedReader KeyInput;
    new JavaSocketServer();    
  }
}



//================================================================
class Service extends Thread 
{
  String data;
  BufferedReader InputS;
  PrintStream OutputS;
  Socket Client;
  public Service(Socket ClientSocket) 
  {
    Client = ClientSocket;
    try 
    {
      InputS = new BufferedReader(new InputStreamReader(Client.getInputStream()));
      OutputS = new PrintStream(Client.getOutputStream());
    }
    catch (IOException e)
    {
      System.out.println("Cannot Connect with Client !");
      return;
    }
    this.start();
  }
  public void run()
  {
    //将当前服务线程打印出来，
    //比较每次一个新的客户端连接上来的时候的线程是否相同
    System.out.println(this);
    try 
    {
      while (true)
      {
        data = InputS.readLine();
        if (data == null) break;
        else 
        {
          OutputS.println(data);
          System.out.println("From Client: " + data);
        }
      }
    }
    catch (IOException e)
    {
      System.out.println("Read Data error");
    }
    try 
    {
      Client.close();
    }
    catch (IOException e)
    {
      System.out.println("Cannot close socket");
    }
  }
}