基于socket的Java網(wǎng)絡(luò )編程集粹

if(str.equals(end))

break;

}

client.close();

}

}

}

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

那么下面的問(wèn)題是如何使用線(xiàn)程.首先要做的事情是創(chuàng )建線(xiàn)程并使得其可以和網(wǎng)絡(luò )連線(xiàn)取得聯(lián)系。然后由線(xiàn)程來(lái)執行剛才的操作，要創(chuàng )建線(xiàn)程要么直接繼承Thread要么實(shí)現Runnable接口，要建立和Socket的聯(lián)系只要傳遞引用就可以了.而要執行線(xiàn)程就必須重寫(xiě)run方法，而run方法所做的事情就是剛才單線(xiàn)程版本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();

}

}

}

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

以上的代碼使用的是

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

PrintWriterout=newPrintWriter(client.getOutputStream());

還有一種方法是使用

DataInputStreamisFromClient=newDataInputStream(client.getInputStream());

DataOutputStreamosToClient=newDataOutputStream(client.getOutputStream());

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