線(xiàn)程組式模
每客戶(hù)一線(xiàn)程的模式增加了服務(wù)端的負(fù)荷，那么我們可以簡(jiǎn)單的重用服務(wù)端處理線(xiàn)程。
服務(wù)端重用一定的線(xiàn)程來(lái)處理客戶(hù)端請(qǐng)求，客戶(hù)端請(qǐng)求被放置到一個(gè)池中供并發(fā)線(xiàn)程取出處理
package com.lei.socket.test;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
public class PooledClientServer {
//啟動(dòng)服務(wù)端監(jiān)聽(tīng)
public void start(){
try{
setUpHandlers();
ServerSocket server = new ServerSocket(port);
Socket client = null;
while(runFlag){
client = server.accept();
System.out.println("accept client " + client.getInetAddress().getHostAddress());
ClientHandle.handleClient(client);
}
server.close();
}catch(IOException e){
System.out.println("start error");
}
}
//創(chuàng)建處理線(xiàn)程組
public void setUpHandlers() {
for (int i = 0; i < threadNum; i++) {
ClientHandle ch = new ClientHandle();
new Thread(ch, "Handler " + i).start();
}
}
public static void main(String[] args){
PooledClientServer s = new PooledClientServer();
s.start();
}
private int port = 3000;
//并發(fā)處理線(xiàn)程數(shù)
private int threadNum = 3;
private boolean runFlag = true;
}
//處理類(lèi)
class ClientHandle implements Runnable{
public static void handleClient(Socket client) {
synchronized (pool) {
pool.add(client);
pool.notifyAll();
}
}
//處理客戶(hù)端
private void handleClient(){
try{
BufferedReader inReader = new BufferedReader(new InputStreamReader(client.getInputStream()));
BufferedWriter outWriter = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
while(true){
outWriter.write("please input String->");
outWriter.flush();
String str = inReader.readLine();
if(str.equalsIgnoreCase("quit")){
outWriter.write("quit ok");
client.close();
break;
}
else{
outWriter.write("reulst is :" + new StringBuffer(str).reverse().toString());
outWriter.write("\r\n");
}
}
}catch(IOException e){
System.out.println("Handle client error");
}
}
public void run(){
while (true) {
synchronized (pool) {
while (pool.isEmpty()) {
try {
pool.wait();
} catch (InterruptedException e) {
e.printStackTrace();
return;
}
}
client = (Socket) pool.remove(0);
}
handleClient();
}
}
private Socket client;
private static ArrayList pool = new ArrayList();
}