import java.net.*;
import java.io.*;

public class TCPClient{
  public static void main(String[] args) throws Exception{
    Socket s = new Socket("192.168.24.177",5566); //創(chuàng)建一個(gè)Socket對象，連接IP地址為192.168.24.177的服務(wù)器的5566端口
    DataOutputStream dos = new DataOutputStream(s.getOutputStream()); //獲取Socket對象的輸出流，并且在外邊包一層DataOutputStream管道，方便輸出數(shù)據(jù)
    dos.writeUTF("客戶端消息"); //DataOutputStream對象的writeUTF()方法可以輸出數(shù)據(jù)，并且支持中文
    dos.flush(); //確保所有數(shù)據(jù)都已經(jīng)輸出
    dos.close(); //關(guān)閉輸出流
    s.close(); //關(guān)閉Socket連接
  }
}
  

以上代碼利用Socket對象和ServerSocket對象進(jìn)行簡單的網(wǎng)絡(luò)交互，即客戶端通過DataOutputStream對象的writeUTF()方法向服務(wù)器發(fā)送消息，服務(wù)器利用DataInputStream對象的readUTF()方法讀出數(shù)據(jù)。

看上去挺好，但ServerSocket對象的accept()方法是阻塞的方法，它會(huì)一直等待，直到有客戶端連接。

同理，DataInputStream對象的readUTF()方法也是阻塞的方法，它也會(huì)一直等待，直到客戶端調(diào)用writeUTF()方法。

因此，假如某個(gè)客戶端成功連接服務(wù)器，但是遲遲不調(diào)用writeUTF()方法發(fā)送數(shù)據(jù)，服務(wù)器就要一直等待，直到客戶端調(diào)用writeUTF()方法為止，此期間整個(gè)服務(wù)器是阻塞的，無法再接受其他客戶端連接，顯然這不符合實(shí)際情況。

要解決這個(gè)問題，當(dāng)然要用多線程。

如果每個(gè)客戶端都獨(dú)有一個(gè)線程，讓readUTF()方法阻塞客戶端獨(dú)有的線程，而不去阻塞服務(wù)器主線程，這樣服務(wù)器就可以同時(shí)接受多個(gè)客戶端連接，而不用考慮客戶端何時(shí)調(diào)用writeUTF()方法發(fā)送數(shù)據(jù)。代碼如下：

服務(wù)器(TCPServer.java)：

    import java.net.*;
import java.io.*;

public class TCPServer{
  public static void main(String[] args) throws Exception{
    ServerSocket ss = new ServerSocket(5566); //創(chuàng)建一個(gè)Socket服務(wù)器，監(jiān)聽5566端口
    int i=0;
    //利用死循環(huán)不停的監(jiān)聽端口
    while(true){
      Socket s = ss.accept();//利用Socket服務(wù)器的accept()方法獲取客戶端Socket對象。
      i++;
      System.out.println("第" + i +"個(gè)客戶端成功連接！");
      Client c = new Client(i,s); //創(chuàng)建客戶端處理線程對象
      Thread t =new Thread(c); //創(chuàng)建客戶端處理線程
      t.start(); //啟動(dòng)線程
    }
  }

}

//客戶端處理線程類(實(shí)現(xiàn)Runnable接口)
class Client implements Runnable{
  int clientIndex = 0; //保存客戶端id
  Socket s = null; //保存客戶端Socket對象
  
  Client(int i,Socket s){
    clientIndex = i;
    this.s = s;
  }
  
  public void run(){
    //打印出客戶端數(shù)據(jù)
    try{
      DataInputStream dis = new DataInputStream(s.getInputStream());
      System.out.println("第" + clientIndex + "個(gè)客戶端發(fā)出消息：" + dis.readUTF());
      dis.close();
      s.close();
    }
    catch(Exception e)
    {}
  }
}
  

客戶端(TCPClient.java)：

    import java.net.*;
import java.io.*;

public class TCPClient{
  public static void main(String[] args) throws Exception{
    Socket s = new Socket("192.168.24.177",5566); //創(chuàng)建一個(gè)Socket對象，連接IP地址為192.168.24.177的服務(wù)器的5566端口
    DataOutputStream dos = new DataOutputStream(s.getOutputStream()); //獲取Socket對象的輸出流，并且在外邊包一層DataOutputStream管道，方便輸出數(shù)據(jù)
    Thread.sleep((int)(Math.random()*3000)); //讓客戶端不定時(shí)向服務(wù)器發(fā)送消息
    dos.writeUTF("客戶端消息"); //DataOutputStream對象的writeUTF()方法可以輸出數(shù)據(jù)，并且支持中文
    dos.flush(); //確保所有數(shù)據(jù)都已經(jīng)輸出
    dos.close(); //關(guān)閉輸出流
    s.close(); //關(guān)閉Socket連接
  }
}
  

運(yùn)行結(jié)果如下(參考結(jié)果，不一定相同！)：

明顯看出第2、3、4客戶端都沒有向服務(wù)器端發(fā)出消息，但都成功連接，而且第2、3、4客戶端向服務(wù)器發(fā)出消息也沒有順序。

通過多線程，實(shí)現(xiàn)了多個(gè)客戶端同時(shí)連接服務(wù)器，并且服務(wù)器能實(shí)時(shí)處理多個(gè)客戶端發(fā)出的消息。

以上僅僅是作為初學(xué)者的一些想法，僅供參考！

簡單模擬多線程Socket通信(java)