java Socket编程多线程实现为多个客户端服务

 为多个客户端服务

1.服务器端

package Socket;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class ThreadedEchoServer {
	
	public static void main(String args[]){
		int i = 1;
		try {
			ServerSocket s = new ServerSocket(8189);
			
			while(true)
			{
				Socket incoming = s.accept();
				System.out.println("number "+i );
				Runnable r = new ThreadedEchoHandler(incoming);
				Thread t = new Thread(r);
				t.start();
				i++;
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

2.客户端

package Socket;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class ThreadedEchoHandler implements Runnable {

	Socket incoming ;
	
	public ThreadedEchoHandler(Socket incoming) {
		this.incoming = incoming;
	}

	public void run() {
		try {
			try {
				InputStream inStream = incoming.getInputStream();
				OutputStream outStream = incoming.getOutputStream();
				Scanner in = new Scanner(inStream);
				PrintWriter out = new PrintWriter(outStream, true/*autoFlush*/);
				out.println("Hello! Enter BYE to exit.");
				//echo Client input
				boolean done = false;
				while (!done && in.hasNext()) {
					String line = in.next();
					out.println("Echo: " + line);
					if (line.trim().equals("BYE"))
						done = true;
				}
			} finally{
				incoming.close();
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}