从套接字输入流读取导致AndroidUI冻结-ReadingfromsocketinputstreamscausingandroidUItofreeze

I'm trying to write this program which updates itself on the current status of a variable. How I intended it to work is by having a timed task to constantly send the string "update" to the server. The server will recognize the string and will send the necessary values for the variable on the android device. However, I am facing some problems. The string "update" is sending without error but when the corresponding value from the server is sent back, the program does not seem to be able to read the reply. Here is the code:

我正在尝试编写这个程序,它自动更新变量的当前状态。我打算如何工作是通过定时任务不断向服务器发送字符串“update”。服务器将识别该字符串,并将在Android设备上发送变量的必要值。但是,我遇到了一些问题。字符串“update”发送时没有错误,但是当发回服务器的相应值时,程序似乎无法读取回复。这是代码:

            //Open socket and initialize data streams
    try {
        socket = new Socket(serverIpAddress, applicationport);
        //in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        //in = new DataInputStream(socket.getInputStream());
        out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
                socket.getOutputStream())), true);
    } catch (UnknownHostException ex) {
        // TODO Auto-generated catch block
        ex.printStackTrace();
        ShowDialog("Login Error" + ex.getMessage());
    } catch (IOException ex) {
        // TODO Auto-generated catch block
        ex.printStackTrace();
        ShowDialog("Login Error" + ex.getMessage());
    }

    //Create new daemon timer
    updateData = new Timer(true);
    updateData.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            out.println("update");
            UpdateMethod();
            }//run
        }, 1000, 10000);//schedule the delays start/interval here



};

private void UpdateMethod() {
    //This method is called directly by the timer
    //and runs in the same thread as the timer.
    //It calls the method that will work with the UI
    //through the runOnUiThread method.
    this.runOnUiThread(Timer_Tick);
};//timermethod

private Runnable Timer_Tick = new Runnable() {
    public void run() {
        try {
            //in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //String getx1 = null;
            //getx1 = in.readLine();
            //if (getx1 != null) {
                //float updatex1 = Float.parseFloat(getx1);
                //get_x1 = getx1;
                //}
            in = new DataInputStream(socket.getInputStream());
            /*try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }*/
            x1display = (TextView) findViewById(R.id.x1display);
            x1display.setText(in.readUTF());

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        finally {
            if (in != null){
                try {
                    in.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
};

As you can see, I have tried experimenting with both DataInputStream and BufferedReader as well but to no avail.

正如您所看到的,我也尝试过使用DataInputStream和BufferedReader,但无济于事。

Edit: It seems that trying to read from the input stream is causing my UI to freeze up. I have no idea what is wrong as my code seems to be without errors..

编辑:似乎尝试从输入流中读取导致我的UI冻结。我不知道出了什么问题,因为我的代码似乎没有错误。

Any help or advice would be greatly appreciated!

任何帮助或建议将不胜感激!

Thank you!

2 个解决方案

//Open socket and initialize data streams
try {
    socket = new Socket(serverIpAddress, applicationport);
    in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
            socket.getOutputStream())), true);
} catch (UnknownHostException ex) {
    ex.printStackTrace();
    ShowDialog("Login Error" + ex.getMessage());
} catch (IOException ex) {
    ex.printStackTrace();
    ShowDialog("Login Error" + ex.getMessage());
}

//Create new daemon timer
updateData = new Timer(true);
updateData.scheduleAtFixedRate(new TimerTask() {
    @Override
    public void run() {
        out.println("update");
        runOnUiThread(new Runnable() {
            @Override
            public void run() {
                try {
                    x1display = (TextView) findViewById(R.id.x1display);
                    x1display.setText(in.readUTF());
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });
        try {
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }}, 1000, 10000);//schedule the delays start/interval here