threadechoserver.java

200多个自己编的java程序,大家可以学一下.

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

public class ThreadEchoServer{
	private Socket incoming;
	private int counter;

	/**
	 * Method main
	 *
	 *
	 * @param args
	 *
	 */
	public static void main(String[] args) {
		// TODO: Add your code here
		
		int i=1;
		try{
			ServerSocket s=new ServerSocket(8189);
			for(;;)
			{
				Socket incoming=s.accept();
				System.out.println("Spawning"+i);
		        new ThreadedEchoHandler(incoming,i).start();
			
				
				i++;
			}
		}catch(Exception e)
		{
			System.out.println(e);
		}
	
	}
	
	
	
	
	class ThreadedEchoHandler extends Thread{
	/**
	 * Method ThreadEchoHandler
	 *
	 *
	 */
	public ThreadedEchoHandler(Socket i,int c) {
		
		// TODO: Add your code here
		incoming=i;
		counter=c;
	}
	public void run(){
		try{
			BufferedReader in=new BufferedReader(new InputStreamReader(incoming.getInputStream()));
		    PrintWriter out=new PrintWriter(incoming.getOutputStream(),true);
		    out.println("Hello,Enter BYE to exit");
		    boolean done=false;
		    while(!done)
		    {
		    	String str=in.readLine();
		    	if(str==null)
		    	done=true;
		    	else{
		    		out.println("Echo("+counter+"):"+str);
		    		if(str.trim().equals("BYE"))
		    		done=true;
		    		
		    }
			
		}
	     incoming.close();
	     }catch(Exception e)
	     {
	     	System.out.println(e);
	     }
		
	}
	}
	
	
	
}