传统socket举例--基于io

教程网上多的是,直接上代码..

ServerMain.java

package test.server;

import java.io.IOException;
import java.net.ServerSocket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ServerMain {	
	private ServerSocket ss;
	private ExecutorService pool;
	public ServerMain(int port, int num) throws IOException {
		ss = new ServerSocket(port);
		pool = Executors.newFixedThreadPool(num);
	}
	public void run() {
		System.out.println("listen to port...");
		while(true){
			try {
				pool.execute(new TCPHandler(ss.accept()));
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
	public static void main(String[] args) throws IOException {
		new ServerMain(8888,10).run();
	}
}

TCPHandler

package test.server;

import java.io.IOException;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.concurrent.TimeUnit;

import test.Num;

class TCPHandler implements Runnable {
	Socket client;

	public TCPHandler(Socket client) {
		this.client = client;
	}

	public void run() {
		if (Num.num == 0) {
			Num.start = System.currentTimeMillis();
		}
		OutputStreamWriter osw;
		try {
			osw = new OutputStreamWriter(client.getOutputStream());
			try {
				TimeUnit.SECONDS.sleep(1L); // 休眠1秒
			} catch (InterruptedException e) {
				e.printStackTrace();
			} 
			osw.write("connect to server...");
			osw.flush();
			osw.close();
			Num.add();
			if (Num.num == 99) {
				Num.end = System.currentTimeMillis();
				System.out.println("处理共用时: " + (Num.end - Num.start) / 1000
						+ "秒");
			}
		} catch (IOException e1) {
			e1.printStackTrace();
		}

	}
}

Num.java

package test;

public class Num {
	public static long start;
	public static long end;
	public static int num = 0;
	public static synchronized void add() {
		num ++;
	}
}

ClientMain.java

package test.client;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
public class ClientMain implements Runnable {
	private Socket s = new Socket();
	private SocketAddress sa;
	public ClientMain(String uri ,int port) throws IOException {
		sa = new InetSocketAddress(uri, port);
	}
	public void run() {	
		try {
			s.connect(sa);
			BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
			System.out.println(br.readLine());
			br.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	public static void main(String[] args) {
		int i = 100;
		while(i-- > 0){
			try {
				new Thread(new ClientMain("127.0.0.1", 8888)).start();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

---

注意:性能主要取决于 Executors.newFixedThreadPool(num); num的大小..

src:点击下载