Java套接字客戶端/服務器對一次只能發送一條消息

Question

客戶端和服務器之間可以進行成功的對話。但是，這隻有在客戶端和服務器之間發送一條消息的情況下。

實施例（工程）：

Client: Hello 
Server: helloo 
Client: what time is it 
Server: Let me get that for you 

實施例（不工作）：

Client: Hello 
Server: helloo 
Server: *How are you today* 
Server: *test message* 
Client: Yes 

星號之間的消息不在客戶端，直到所述客戶端發送呈現2個消息。根據我的理解，它似乎像一個網絡消息系統一樣工作，其中服務器發送的消息數量必須等於客戶端發送的消息數n + -1，以顯示所有消息。

客戶端代碼：

try { 
      Socket client_socket= new Socket(hostname,port_number); 
      PrintWriter output = new PrintWriter(client_socket.getOutputStream(),true); 
      BufferedReader input = new BufferedReader(new InputStreamReader(client_socket.getInputStream())); 
      BufferedReader stdIn=new BufferedReader(new InputStreamReader(System.in)); 

      String fromUser,fromServer; 
      while ((fromServer=input.readLine())!=null) { 
       System.out.println("Server: "+fromServer); 
       if (fromServer.equals("Quit")) { 
        break; 
       } 
       fromUser=stdIn.readLine(); 
       if (fromUser!=null) { 
        System.out.println("Client: "+fromUser); 
        output.println(fromUser); 
       } 

      } 

     } 

服務器端代碼：

try { 
      ServerSocket server_socket=new ServerSocket(port_number); 
      Socket client_socket= server_socket.accept(); 
      PrintWriter output = new PrintWriter(client_socket.getOutputStream(),true); 
      BufferedReader input = new BufferedReader(new InputStreamReader(client_socket.getInputStream())); 
      BufferedReader stdIn=new BufferedReader(new InputStreamReader(System.in)); 
      output.println("Established"); 
      String fromUser, fromServer; 
      while ((fromUser=input.readLine())!=null) { 
       System.out.println("Client: "+fromUser); 
       if (fromUser.equals("Quit")) { 
        break; 
       } 
       fromServer=stdIn.readLine(); 
       if (fromServer!=null) { 
        System.out.println("Server: "+fromServer); 
        output.println(fromServer); 
       } 
      } 

     } 

看代碼，我可以明白爲什麼會發生這種事，它是因爲While循環之後的SOP初始化停止等待1行輸入的代碼，然後等待發送自己的句子，然後再接收另一個。我試圖將這些放在if語句中，但是這完全沒有任何交流。

我似乎無法弄清楚如何解決這個問題。

如果這需要線程，有沒有另一種方式？ （我不太熟悉線程）

Answer 1

根據程序的性質，我建議你使用更多的線程來處理消息。

讓我們先從服務器： 如果服務器有多個客戶端，比它很可能是明智的，每一個客戶區分與一個線程，例如：

  ServerSocket ss; 

      try { 
       ss = new ServerSocket(portIn); 
       while (true) { 
        Socket s = ss.accept(); 
        // Option 1: runnable class 
        new Thread(new CustomRunnableClass(s)).start(); 
       } 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 

或者，如果你不想你的「會話管理器」是一個自定義運行的類，你可以用下面的

new Thread(new Runnable() { 
    @Override 
    public void run() { 
     new SomeClass().runThisClass(); 
    } 
} 

在客戶端更換線路new Thread(new CustomRunnableClass(s)).start();我建議偵聽新消息從插座任何類將是分銷商通過一個新的線程nguished：

private void startListening() { 
    new Thread(new Runnable() { 
     @Override 
     public void run() { 
      for(;;) { 
       String msg = dis.readUTF(); 
       System.out.println(" ----- Recieved New Message -----\n" + msg); 
       for (IMessageListener listener : listeners) { 
        try { 
         listener.onMessageRecieved(msg); 
        } catch (Exception e) { 

        } 
       } 
      } 
     } 
    }).start(); 
} 

這種方式，客戶端偵聽客戶端接收到的任何消息和運行方法來處理他們在接收，以及在此期間沒有被掛起。

希望這有幫助。

Answer 2

您需要非阻塞套接字，如果輸入緩衝區中沒有數據，閱讀器函數應該中間返回。

http://www.java2s.com/Tutorials/Java/Java_Network/0070__Java_Network_Non-Blocking_Socket.htm