multijabberserver.java

java 通讯程序

import java.io.*;
import java.net.*;
class ServerOneJabber extends Thread {
	private Socket socket;
	private BufferedReader in;
    private PrintWriter out;
    private String UserAddress;
    private int UserPort;
    public ServerOneJabber(Socket s) throws IOException {
    	socket=s;
    	in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    	out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
        UserAddress=socket.getInetAddress().toString();
        UserPort=socket.getPort();
    	start();
    }
    public void run() {
    	try{
    		while(true)	{
    			String str=in.readLine();
    			if(str.equals("END")) break;
    			System.out.println(UserAddress+": "+UserPort+"\n"+str);
    		}
    		System.out.println("Closing");
    	}catch(IOException e) {}
    	 finally {
    	 	try {
    	 		socket.close();
    	 	}catch(IOException e) {}
    	 }	
   }
}
public class MultiJabberServer {
  public static final int PORT = 8080;
  public static void main(String[] args) 
      throws IOException {
    ServerSocket s = new ServerSocket(PORT);
    System.out.println("Started: " + s);
    try {
      while(true) {
      Socket socket= s.accept();
      try {
      	new ServerOneJabber(socket);
      }catch(IOException e) {
      	socket.close();
      }
    }
  }finally {
      s.close();
    }
}
}