在java中放置Semaphore问题(placing Semaphore issue in java)

 我实现了一个客户端，它向服务器发送随机数，等待服务器的重放（假设服务器也发送一些随机值）。 客户端在从服务器获得答案之前无法发送另一个请求。 
 
 这是我的代码： 
 
private ObjectOutputStream output;
    private ObjectInputStream input;
    private String message = "";
    private String serverIP;
    private Socket connection;
    private String clientName;
    private String queryNum;
    Semaphore waitForReplay ;

//constructor
    public Client(String host,String clientName){
        serverIP = host;
        waitForReplay = new Semaphore(1, true);
        this.clientName = clientName;
        startRunning();
    }



public void startRunning(){
        try{
            connectToServer();
            setupStreams();
            new Thread(){
                    public void run(){
                        try {
                            whileChatting();
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
        }.start();

            sendMsgToChat();
        }catch(EOFException eofException){
            showMessage("\n Client terminated the connection");
        }catch(IOException ioException){
            ioException.printStackTrace();
        }finally{
            closeConnection();
        }
    }


//connect to server
    private void connectToServer() throws IOException{
        showMessage("Attempting connection... \n");
        connection = new Socket(InetAddress.getByName(serverIP), 6789);
        showMessage("Connection Established! Connected to: " + connection.getInetAddress().getHostName());
    }

    //set up streams
    private void setupStreams() throws IOException{
        output = new ObjectOutputStream(connection.getOutputStream());
        output.flush();
        input = new ObjectInputStream(connection.getInputStream());
        showMessage("\n The streams are now set up! \n");
    }
//receiving msgs
private void whileChatting() throws IOException{
        do{
            try{
                message = (String) input.readObject();
                showMessage("\nClient"+clientName+": got replay " + message+ " for query " +queryNum);

            }catch(ClassNotFoundException classNotFoundException){
                showMessage("Unknown data received!");
            }
            finally{
                waitForReplay.release();
            }
        }while(true);   
    }



//sending msgs
    private void sendMsgToChat(){
        while(true){

            try {
                waitForReplay.acquire();


            } catch (InterruptedException e) {
                e.printStackTrace();
            }
//sends some random num, casting int number from array to string
            sendMessage(queryNum =some random number..);
        }
    }
 
 由于一个我无法找到的原因，waitForRepaly Semaphore不做他的工作，并且在某些情况下客户端连续发送几条消息，而不是等待来自服务器的回复。 你能帮我找到我代码中的错误吗？ 

i've implemented a client side which sends random numbers to the server, wait for a replay from the server (let's say the server also sends some random value). the client can't send another request before he gets an answer from the server.
 
here's my code:
 
private ObjectOutputStream output;
    private ObjectInputStream input;
    private String message = "";
    private String serverIP;
    private Socket connection;
    private String clientName;
    private String queryNum;
    Semaphore waitForReplay ;

//constructor
    public Client(String host,String clientName){
        serverIP = host;
        waitForReplay = new Semaphore(1, true);
        this.clientName = clientName;
        startRunning();
    }



public void startRunning(){
        try{
            connectToServer();
            setupStreams();
            new Thread(){
                    public void run(){
                        try {
                            whileChatting();
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
        }.start();

            sendMsgToChat();
        }catch(EOFException eofException){
            showMessage("\n Client terminated the connection");
        }catch(IOException ioException){
            ioException.printStackTrace();
        }finally{
            closeConnection();
        }
    }


//connect to server
    private void connectToServer() throws IOException{
        showMessage("Attempting connection... \n");
        connection = new Socket(InetAddress.getByName(serverIP), 6789);
        showMessage("Connection Established! Connected to: " + connection.getInetAddress().getHostName());
    }

    //set up streams
    private void setupStreams() throws IOException{
        output = new ObjectOutputStream(connection.getOutputStream());
        output.flush();
        input = new ObjectInputStream(connection.getInputStream());
        showMessage("\n The streams are now set up! \n");
    }
//receiving msgs
private void whileChatting() throws IOException{
        do{
            try{
                message = (String) input.readObject();
                showMessage("\nClient"+clientName+": got replay " + message+ " for query " +queryNum);

            }catch(ClassNotFoundException classNotFoundException){
                showMessage("Unknown data received!");
            }
            finally{
                waitForReplay.release();
            }
        }while(true);   
    }



//sending msgs
    private void sendMsgToChat(){
        while(true){

            try {
                waitForReplay.acquire();


            } catch (InterruptedException e) {
                e.printStackTrace();
            }
//sends some random num, casting int number from array to string
            sendMessage(queryNum =some random number..);
        }
    }
 
for a reason i can't find out, the waitForRepaly Semaphore dont do his job, and there's scenarios where the client sends few messages in a row, and not waiting for reply from the server . can you help me find the bug in my code?

原文：https://stackoverflow.com/questions/37332687