這是基於前面一篇文章的一個簡單擴充套件，當然這不是最好的實現

服務端如果要想接收多個客戶端連線，必須死迴圈去接收新的客戶端的連線請求，一個完整的客戶端服務端socket連線通過一個執行緒來維護

package com.tree.demo.socket;

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

class ThreadServerSocket implements Runnable {

	private Socket server;
	
	public ThreadServerSocket(Socket i) {
		// TODO Auto-generated constructor stub
		server = i;
	}
	
	@Override
	public void run() {
		// TODO Auto-generated method stub
		try {
			InputStream in = server.getInputStream();
			OutputStream out = server.getOutputStream();
			Scanner sc = new Scanner(in);
			PrintWriter pw = new PrintWriter(out,true/*autoFlush*/);
			pw.println("Hello ! Enter BYE to Exit.");
			while(sc.hasNextLine()) {
				String line = sc.nextLine();
				pw.println("Echo:"+line);
				if(line.trim().equals("BYE")) {
					break;
				}
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			try {
				server.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
	}
	
}

public class MulServerSocketDemo {

	private static final int PORT = 1234;
	
	//private static final int BUFFER_SIZE = 1024;
	
	public static void main(String[] args) throws IOException {
		// TODO Auto-generated method stub
		int counter = 1;
		ServerSocket ss = new ServerSocket(PORT);
		while(true) {
			Socket s = ss.accept();
			System.out.println("第 "+(counter++)+" 個連線");
			Thread t = new Thread(new ThreadServerSocket(s));
			t.start();
		}
	}

}
 

同時開了6個連線，當然也可以通過JAVA來是實現：

服務端：

package com.tree.demo.socket;

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

class ThreadServerSocket implements Runnable {

	private Socket server;
	
	private int BUFFER_SIZE = 1024;
	
	public ThreadServerSocket(Socket i) {
		// TODO Auto-generated constructor stub
		server = i;
	}
	
	@Override
	public void run() {
		// TODO Auto-generated method stub
		try {
			InputStream in = server.getInputStream();
			OutputStream out = server.getOutputStream();
			byte[] recData = null;
			while(true) {
				recData = new byte[BUFFER_SIZE];
				int r = in.read(recData);
				//int r = in.read(recData);
				if(r>-1) {
					String data = new String(recData);
					if(data.trim().equals("over")) {
						server.close();
						break;
					}
					System.out.println("讀取到客戶端傳送的來資料："+data);
					out.write("這是服務端發給客戶端的資料：".getBytes());
					out.write(recData);
				}else {
					System.out.println("資料讀取完畢！");
					server.close();
					break;
					//ss.close();
				}
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			try {
				server.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
	}
	
}

public class MulServerSocketDemo {

	private static final int PORT = 1234;
	
	//private static final int BUFFER_SIZE = 1024;
	
	public static void main(String[] args) throws IOException {
		// TODO Auto-generated method stub
		int counter = 1;
		ServerSocket ss = new ServerSocket(PORT);
		while(true) {
			Socket s = ss.accept();
			System.out.println("第 "+(counter++)+" 個連線");
			Thread t = new Thread(new ThreadServerSocket(s));
			t.start();
		}
	}

}
 

package socket;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.Socket;

class ThreadClientSocket implements Runnable {

	private static final String HOST = "192.168.8.17";

	private static final int PORT = 1234;
	
	private Socket client;

	public ThreadClientSocket() {
		client = new Socket();
		try {
			client.connect(new InetSocketAddress(HOST, PORT), 500);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	@Override
	public void run() {
		// TODO Auto-generated method stub
		try {
			OutputStream out = client.getOutputStream();
			int counter = 0;
			while (true) {
				System.out.println("Thread-->"+Thread.currentThread().getName());
				out.write("Heart Beat !".getBytes());
				System.out.println(client + "================" + (counter++));
				try {
					Thread.sleep(2000);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}

public class MulClientSocketDemo {


	public static void main(String[] args) throws IOException {
		// TODO Auto-generated method stub
		int counter = 4;
		while((counter--)>0) {
			new Thread(new ThreadClientSocket()).start();;
		}
		// client.setTcpNoDelay(true);
	}

}
 

該實現仍然有很多不足，更好的實現可通過通道來實現，未完待續..........