无法在android中获得TCP响应

Question

代码应该作为客户端连接到 TCP 服务器，发送命令并接收响应。

代码连接并发送命令，但在“socket.getInputStream()”处超时，即使连接的服务器收到命令并应该响应（使用 PC 上的 TCP 客户端程序检查） .

这是任务的代码：

public class MyClientTask extends AsyncTask<Void, Void, Void> {

    String dstAddress;
    int dstPort;
    String command;
    String response = "";

    MyClientTask(String addr, int port, String cmd){
        dstAddress = addr;
        dstPort = port;
        command = cmd;
    }

    @Override
    protected Void doInBackground(Void... arg0) {

        Socket socket = null;
        InputStream inputStream;

        try {
            socket = new Socket();
            socket.connect(new InetSocketAddress(dstAddress, dstPort),2000);
            ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(1024);
            byte[] buffer = new byte[1024];
            int bytesRead;

            PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
            out.println(command);

            inputStream = socket.getInputStream();
            socket.setSoTimeout(20000);
            while ((bytesRead = inputStream.read(buffer)) != -1){
                byteArrayOutputStream.write(buffer, 0, bytesRead);
                response += byteArrayOutputStream.toString("UTF-8");
            }

        }catch (UnknownHostException e){
            e.printStackTrace();
            response = "UnknownHostException: " + e.toString();
        } catch (IOException e) {
            e.printStackTrace();
            response = "IOException: " + e.toString();
        } catch (Throwable e) {
            e.printStackTrace();
            response = "Throwable: " + e.toString();
        }finally{
            if(socket != null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return null;
    }

    @Override
    protected void onPostExecute(Void result) {
        textResponse.setText(response);
        super.onPostExecute(result);
    }

}//MyClientTask

Answer 1

您正在阅读响应，直到流结束。在对等方关闭连接之前不会发生流结束。你有一个读取超时：ergo，可能，他没有关闭连接。否则你的超时时间太短了。两秒不算多。

您需要一种正确的方式来阅读响应，或者在收到的部分进行处理。