基于socket的Java網絡編程集粹

if(str.equals(end))

break;

}

client.close();

}

}

}

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

那么下面的問題是如何使用線程.首先要做的事情是創建線程并使得其可以和網絡連線取得聯系。然后由線程來執行剛才的操作，要創建線程要么直接繼承Thread要么實現Runnable接口，要建立和Socket的聯系只要傳遞引用就可以了.而要執行線程就必須重寫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類繼承了下來.并且通過構造函數傳遞引用和客戶Socket建立了聯系，這樣每個線程就有了。一個通訊管道.同樣我們可以填寫run方法，把之前的操作交給線程來完成，這樣多客戶并行的Socket就建立起來了。

以上的代碼使用的是

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

PrintWriterout=newPrintWriter(client.getOutputStream());

還有一種方法是使用

DataInputStreamisFromClient=newDataInputStream(client.getInputStream());

DataOutputStreamosToClient=newDataOutputStream(client.getOutputStream());

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