Java TCP Echo服務器 - 廣播

Question

我有一個簡單的回聲服務器，我想當連接用戶輸入任何東西到服務器，所有其他客戶端和該客戶端將得到消息+「| MOD」。

它現在不會發送給所有的客戶端，但它應該和我只是不知道我的代碼有什麼問題，所以現在它只會發送消息+「| MOD」給發送消息的客戶端，而不是所有其他人也應該如此。

我只是不明白，我有一個循環遍歷所有的客戶，但它仍然不會發送給所有。

SERVER：

package com.murplyx.server; 

import java.io.BufferedReader; 
import java.io.InputStreamReader; 
import java.io.PrintWriter; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.util.ArrayList; 

public class Server { 
    public static ServerSocket server; 
    public static ArrayList<Socket> clients = new ArrayList<Socket>(); 

    public static void broadcast(String message) { 
     try { 
      for (Socket socket : clients) { 
       PrintWriter out = new PrintWriter(socket.getOutputStream(), true); 

       out.println(message); 
      } 
     } catch(Exception e) { 
      e.printStackTrace(); 
     } 
    } 

    public static void main(String args[]) { 
     try { 
      server = new ServerSocket(9000); 

      while (true) { 
       clients.add(server.accept()); 

       for (Socket socket : clients) { 
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); 

        String line = in.readLine(); 

        if (line != null) { 
         broadcast(line + " | MOD"); 
        } 
       } 
      } 
     } catch(Exception e) { 
      e.printStackTrace(); 
     } 
    } 
} 

客戶：

package com.murplyx.client; 

import java.io.BufferedReader; 
import java.io.InputStreamReader; 
import java.io.PrintWriter; 
import java.net.Socket; 

public class Client { 
    public static void main(String args[]) { 
     try { 
      while (true) { 
       Socket socket = new Socket("localhost", 9000); 

       BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
       PrintWriter out = new PrintWriter(socket.getOutputStream(), true); 

       BufferedReader input = new BufferedReader(new InputStreamReader(System.in)); 

       out.println(input.readLine()); 

       System.out.println(in.readLine()); 

       socket.close(); 
      } 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 
} 

請幫助。

非常感謝。

Answer 1

你有一個問題是每個客戶都會反覆做無限次的read stdin, write socket, read socket, write stdout, ...。

當你廣播所有其他客戶端仍然通常坐在read stdin階段，所以他們不知道有什麼東西在等待在套接字上讀取。他們仍在等待用戶輸入內容。

最簡單的選擇之一是在每個客戶端啓動兩個線程 - 一個只處理read stdin, write socket, ...，另一個處理read socket, write stdout。

[另一個（可能更復雜）選項我們在同一時間使用Java NIO的調查既插座和標準輸入可用輸入。

第二個問題是，你在服務器中調用accept阻塞，然後從每個套接字依次讀取。您可能在一個線程中使用accept，並且每個客戶端都有另一個線程只從客戶端讀取，並重播給其他線程。 NIO也可以是一個很好的選擇 - 您可以輪詢讀取任何任何客戶端。

Answer 2

我不能完全肯定的ArrayList如何與插座玩，所以我肯定會回去使用普通陣列爲它（看到這裏的編輯的代碼Java EchoTCPServer - Send to all clients）

有些事情，我看到，我覺得能到被修復：

客戶端上：

- 停止關閉While循環中的套接字。在while循環外面關閉它（當客戶端完成服務器時）。另外，在Loop外部聲明套接字。

注意在這個：當客戶端套接字連接到服務器時，它會自動給出一個設備端口，因此兩個不同的設備將永遠不會有相同的IP連接到服務器。 TCP連接由2個端口，服務器套接字和客戶端套接字組成，套接字由[deviceip：port，serverip：port]（iirc）表示。

- 另外，在客戶端，每次移動while循環時都不需要聲明新的讀取器。把這一切放在外面。 while循環中唯一的東西應該是你的readline + print語句。

-readLine是一種阻塞方法。 （以防萬一你不知道這意味着什麼，這意味着readLine會讓你的程序停留在那裏，直到它實際讀取一行爲止，爲了避免這種情況，你可以使用if語句和.ready()函數結合。功能檢查，看看是否有什麼要「讀」，因此，如果沒有輸入，它不會被上「的readLine」卡住

在服務器：

樣我前面說的，我會改回到使用正常的陣列

- 您的服務器仍然會卡住.accept（）。因此，您將永遠不能讀取來自客戶端的輸入，除了在每次連接之後都進行一次輸入之外，您可以使用線程反而聽，它仍然會工作。

如：（此代碼去與那是在我附鏈接代碼（也是你的問題），把它放在你的服務器的while循環之前）

// create a tcp listener thread to deal with listening to clients 
Thread listenerThread = new Thread() { 
    public void run() { 
     String clientSentence; 

     while (true) { 
      //loop through each connected socket  
      for (int i = 0; i <= intLastSocket; i++) { 
       Socket z = clientSocket[i]; 
       //make sure the socket is not null or closed (can't do anything 
       //with closed or null sockets   
       if ((z != null) && (!z.isClosed())) { 
        try { 
         // Deal with TCP input here 
         BufferedReader input = new BufferedReader(new 
          InputStreamReader(z.getInputStream())); 
         // read in a line but only if there is one 
         if (input.ready()) { 
          clientSentence = input.readLine(); 
         } 
        } catch (IOException x) { 
         printTCP("IOException caught when reading in: " 
           + x.toString()); 
        } 
        if (clientSentence != null) { 
         System.out.println("Received from client: " 
           + clientSentence); 
         //send this message to the client 
         outputStream[i].println(clientSentence + " | MOD"); 
        } 

        // clear the input 
        clientSentence = null; 
       } 
      } 
     } 
    } 
}; 
listenerThread.start();