線程，插座和流

Question

在我的節目，我希望將一些信息發送到另一臺計算機上的插座。第一個套接字發送一些文本拋出服務器，當第二個套接字接收到這個信息時，它向第一個套接字發送一個答案。問題是另一個線程收到答案，我得到的唯一東西是死鎖。 這是服務器側：

else if(msgArray[0].compareTo("game_request") == 0){ 
       if(userMap.containsKey(msgArray[1])){ 
        Socket socketPlayerTwo = userMap.get(msgArray[1]); 
        otherPlayer = msgArray[1]; 
        sendResult(socketPlayerTwo, "game_offer?"+username); 
        Boolean willPlay =Boolean.valueOf(recieveRequest(socketPlayerTwo).split("?")[1]); 
        if(willPlay) 
         playingUser.put(username,msgArray[1]); 
        sendResult(socket, "game_accept?"+willPlay); 

       } 
      } 

這是客戶端：

private void showGameRequest(String usernameOther) { 
     try{ 
      int status = GameWindow.getInstance().showNotification("Game Offer","The user " + usernameOther + " offers you a game!\nDo you agree?",SWT.ICON_QUESTION|SWT.YES|SWT.NO); 
      if (status == SWT.YES){ 
       otherPlayer = usernameOther; 
       sendRequest("send_message_to_user?user="+usernameOther+"&value=true"); 
       GameWindow.getInstance().getDisplay().asyncExec(new Runnable() { 

        @Override 
        public void run() { 
         GameWindow.getInstance().startNewGame(); 

        } 
       }); 
      } 
      else 
       sendRequest("send_message_to_user?user="+usernameOther+"&value=false"); 
      } 
     catch (IOException exc){ 

     } 
    } 

---

這裏是sendRequest方法：

private void sendResult(Socket socket,String request) throws IOException{ 
    DataOutputStream writer = new DataOutputStream(socket.getOutputStream()); 
    writer.writeUTF(request); 
    writer.flush(); 
} 

客戶端套接字中所創建的類服務器

while (true) { 
     try { 
      Socket socket = serverSocket.accept(); 
      new GameThread(socket,databaseManager); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } 

，它被放在HashMap中，當用戶通過登錄級別：

if(msgArray[0].compareTo("user_info") == 0){ 
       Integer flagUser = -1; 
       String[] userInfo = {msgArray[1].substring(msgArray[1].indexOf("=") + 1, msgArray[1].indexOf("&")),msgArray[1].substring(msgArray[1].lastIndexOf("=")+ 1, msgArray[1].indexOf(";"))}; 
       Boolean status = databaseManager.checkUser(userInfo[0], userInfo[1]); 
       if(status){ 
        if(!userMap.containsKey(userInfo[0])){ 
         userMap.put(userInfo[0], socket); 
         username = userInfo[0]; 
         flagUser = 0; 
        } 
        else 
         flagUser = 1; 
       } 
       sendResult(socket, "user_info_status?"+flagUser.toString()+""); 
      } 

我的事情我知道了什麼是死鎖的原因，但我解決不了。當第一個用戶將信息發送給另一個用戶時，他等待響應。當然其他用戶發送一個響應，但這個響應是來自其他線程的句柄。所以死鎖是來自阻塞線程的讀取方法。我怎樣才能從一個套接字發送信息到另一個沒有死鎖？

public GameThread(Socket socket, DatabaseManager databaseManager) { 
    this.socket = socket; 
    this.databaseManager = databaseManager; 
    parser = new RequestParser(); 
    authorizationControl = new AuthorizationControl(databaseManager); 
    communication = new SocketCommunication(socket); 
    start(); 
} 

Answer 1

你能告訴我們更多你的代碼嗎？

sendResult(socketPlayerTwo, "game_offer?"+username); 
recieveRequest(socketPlayerTwo); 
sendRequest("send_message_to_user?user="+usernameOther+"&value=true"); 

初學者。 由小我看到你有你使用它們其中的順序有問題來看。據我可以告訴你有一個inputSteram.readObject（）方法阻塞某處等待來自另一端的消息。