if(str.equals(end))

break;

}

client.close();

}

}

}

這里僅僅只是加了一個(gè)外層的While循環(huán)，這個(gè)循環(huán)的目的就是當(dāng)一個(gè)客戶進(jìn)來就為它分配一個(gè)Socket直到這個(gè)客戶完成一次和服務(wù)器的交互，這里也就是接受到客戶的End消息.那么現(xiàn)在就實(shí)現(xiàn)了多客戶之間的交互了。但是.問題又來了，這樣做雖然解決了多客戶,可是是排隊(duì)執(zhí)行的。也就是說當(dāng)一個(gè)客戶和服務(wù)器完成一次通訊之后下一個(gè)客戶才可以進(jìn)來和服務(wù)器交互，無法做到同時(shí)服務(wù)，那么要如何才能同時(shí)達(dá)到既能相互之間交流又能同時(shí)交流呢？很顯然這是一個(gè)并行執(zhí)行的問題了。所以線程是最好的解決方案。

那么下面的問題是如何使用線程.首先要做的事情是創(chuàng)建線程并使得其可以和網(wǎng)絡(luò)連線取得聯(lián)系。然后由線程來執(zhí)行剛才的操作，要?jiǎng)?chuàng)建線程要么直接繼承Thread要么實(shí)現(xiàn)Runnable接口，要建立和Socket的聯(lián)系只要傳遞引用就可以了.而要執(zhí)行線程就必須重寫run方法，而run方法所做的事情就是剛才單線程版本main所做的事情，因此我們的程序變成了這樣:

importjava.net.*;

importjava.io.*;

publicclassMultiUserextendsThread{

privateSocketclient;

publicMultiUser(Socketc){

this.client=c;

}

publicvoidrun(){

try{

BufferedReaderin=newBufferedReader(newInputStreamReader(client.getInputStream()));

PrintWriterout=newPrintWriter(client.getOutputStream());

//MutilUserbutcanparallel

while(true){

Stringstr=in.readLine();

System.out.println(str);

out.println(hasreceive....);

out.flush();

if(str.equals(end))

break;

}

client.close();

}catch(IOExceptionex){

}finally{

}

}

publicstaticvoidmain(String[]args)throwsIOException{

ServerSocketserver=newServerSocket(5678);

while(true){

//transferlocationchangeSingleUserorMultiUser

MultiUsermu=newMultiUser(server.accept());

mu.start();

}

}

}

我的類直接從Thread類繼承了下來.并且通過構(gòu)造函數(shù)傳遞引用和客戶Socket建立了聯(lián)系，這樣每個(gè)線程就有了。一個(gè)通訊管道.同樣我們可以填寫run方法，把之前的操作交給線程來完成，這樣多客戶并行的Socket就建立起來了。

以上的代碼使用的是

BufferedReaderin=newBufferedReader(newInputStreamReader(client.getInputStream()));

PrintWriterout=newPrintWriter(client.getOutputStream());

還有一種方法是使用

DataInputStreamisFromClient=newDataInputStream(client.getInputStream());

DataOutputStreamosToClient=newDataOutputStream(client.getOutputStream());

關(guān)于這兩種輸入輸出流的不同，我也只知道前一種對(duì)字符串支持比較好，后面對(duì)于讀取一個(gè)字符串需要處理，但是可以支持很多種類型的輸出。對(duì)于傳遞字符串而言前一種應(yīng)該是很好的選擇了