testserver.java

自己做的一个QQ聊天系统

package test.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;



public class TestServer{
            public static void main(String[] args) throws Exception {
	                ServerSocket ss = 
		                    new ServerSocket(8888);
	                while(true){
	                     	Socket s = ss.accept();
		                    new ServerThread(s).start();
	                 } 
	              //ss.close();
           }

}
class ServerThread extends Thread{
        Socket s;
        public ServerThread(Socket s){
	            this.s = s;
       }
       public void run(){
	       try {
		           BufferedReader br = 
			              new BufferedReader(
					                 new InputStreamReader(
							                 s.getInputStream()));
		           System.out.println(br.readLine());
		           PrintWriter pw = new PrintWriter(
				   s.getOutputStream());
		           pw.println("hi! [from server]");
		           pw.flush();
		           s.close();
        	} catch (IOException e) {
		        // TODO Auto-generated catch block
		         e.printStackTrace();
	       }
       }
}