卡在 inStream.readline() 上的 Android TCP 应用程序

Question

这是 this question 的延续因为它回答了我的原始问题，但没有解决错误。

问题:

• 如何修复卡在这一行的代码 inStream.readline()

我的 Intent :

1. 这是一个循环检查是否有 outMessage 的线程，如果有，它将发送消息。
2. 接下来它将检查流中是否有任何内容，如果有，它将发送到我的主要 Activity 中的处理程序。
3. 最后，它会休眠 1 秒，然后再次检查。
4. 这应该允许我多次读/写而无需关闭和打开套接字。

问题:

• 它的读写更好了，但仍然不能正常工作

现在发生了什么:

• 如果 outMessage 是用一个值初始化的，在与服务器建立连接时，套接字:
  1. 写入并刷新值(服务器接收并响应)
  2. 更新 outMessage 的值(为 null 或“x”，具体取决于我对其进行硬编码的方式)
  3. 读取并显示来自服务器的响应信息
  4. 重新进入下一个循环
  5. 如果我将 outMessage 设置为 null，它会跳过 if 语句正确然后挂起；否则，如果我将 outMessage 设置为一个字符串(比如说“x”)，它会遍历整个 if 语句，然后挂起。
     • 它挂起 的代码是 inStream.readline() 调用之一(我目前有一个已注释掉)。

附加信息: - 连接后，我可以在“发送”框中输入，提交(更新 outMessage 值)，然后断开连接。重新连接后，它将读取值并再次执行序列，直到卡在同一行上。

自引用问题以来的变化:- 使 outMessage 和 connectionStatus 都“不稳定”- 在必要的地方添加了行尾定界符。

代码:

        public void run() { 
            while (connectionStatus != TCP_SOCKET_STATUS_CONNECTED) {
                try {
                    Thread.sleep(500);  
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            while (connectionStatus == TCP_SOCKET_STATUS_CONNECTED) {
                try {   
                    if (outMessage != null){                                            
                        OutStream.writeBytes(outMessage + "\n");                    
                        OutStream.flush();                                          
                        sendMessageToAllUI(0, MAINACTIVITY_SET_TEXT_STATE, "appendText" , "OUT TO SERVER: " + outMessage);
                        outMessage = "x";                                           
                    }                                                           
                    Thread.sleep(100);
 //             if (InStream.readLine().length() > 0) {                             
                        String modifiedSentence = InStream.readLine();              
                        sendMessageToAllUI(0, MAINACTIVITY_SET_TEXT_STATE, "appendText" , "IN FROM SERVER: " + modifiedSentence);
//                  }                                                   
                    Thread.sleep(1000);
                } catch (IOException e) {                               
                    connectionLost();
                    break;
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }                               
        }

制作套接字的线程:

public void run() {
        setName("AttemptConnectionThread");
        connectionStatus = TCP_SOCKET_STATUS_CONNECTING;
        try {
            SocketAddress sockaddr = new InetSocketAddress(serverIP, port);
            tempSocketClient = new Socket(); // Create an unbound socket

            // This method will block no more than timeoutMs. If the timeout occurs, SocketTimeoutException is thrown.
            tempSocketClient.connect(sockaddr, timeoutMs);
            OutStream = new DataOutputStream(tempSocketClient.getOutputStream());
            InStream = new BufferedReader(new InputStreamReader(tempSocketClient.getInputStream()));
            socketClient = tempSocketClient;
            socketClient.setTcpNoDelay(true);
            connected(); 
        } catch (UnknownHostException e) {
            connectionFailed();
        } catch (SocketTimeoutException e) {
            connectionFailed();
        } catch (IOException e) {
            // Close the socket
            try {
                tempSocketClient.close();
            } catch (IOException e2) {
            }
            connectionFailed();
            return;
        }
    } 

服务器:

public static void main(String[] args) throws IOException {
    String clientSentence;
    String capitalizedSentence;
    try {
        ServerSocket welcomeSocket = new ServerSocket(8888);
        SERVERIP = getLocalIpAddress();
        System.out.println("Connected and waiting for client input!\n Listening on IP: " + SERVERIP +"\n\n");
        Socket connectionSocket = welcomeSocket.accept();
        BufferedReader inFromClient = new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
        DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream());
        while(true)
        {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            clientSentence = inFromClient.readLine();
            System.out.println("clientSentance == " + clientSentence);
            String ip = connectionSocket.getInetAddress().toString().substring(1);
            if(clientSentence != null)
            {
                System.out.println("In from client ("+ip+")("+ System.currentTimeMillis() +"): "+clientSentence);
                capitalizedSentence = clientSentence.toUpperCase() + '\n';
                outToClient.writeBytes(capitalizedSentence + '\n');
                System.out.println("Out to client ("+ip+"): "+capitalizedSentence);
            }
        }
    } catch (IOException e) {
        //if server is already running, it will not open new port but instead re-print the open ports information
         SERVERIP = getLocalIpAddress();
         System.out.println("Connected and waiting for client input!\n");
         System.out.println("Listening on IP: " + SERVERIP +"\n\n");

    }
}

提前致谢!

编辑:

• 更新后添加服务器代码
• 我试着为套接字设置 SoTimout，但后来又取消了

Answer 1

您的服务器经过专门设计，可以从客户端接收一行并返回一行。看代码:

    while (true) {
        Socket connectionSocket = welcomeSocket.accept();
        BufferedReader inFromClient = new BufferedReader(
                new InputStreamReader(connectionSocket.getInputStream()));
        DataOutputStream outToClient = new DataOutputStream(
                connectionSocket.getOutputStream());

        clientSentence = inFromClient.readLine();
        String ip = connectionSocket.getInetAddress().toString()
                .substring(1);
        System.out.println("In from client (" + ip + "): "
                + clientSentence);
        if (clientSentence != null) {
            capitalizedSentence = clientSentence.toUpperCase() + '\n';
            System.out.println("Out to client (" + ip + "): "
                    + capitalizedSentence);
            outToClient.writeBytes(capitalizedSentence + "\n");
        }

请注意，在循环内它接受一个新连接，准确读取一行，然后准确写入一行。它不会关闭连接。它并没有理智地结束谈话。它只是停止读取。

与此服务器一起工作的客户端必须连接、发送一行、读回一行，然后客户端必须关闭连接。你的客户不会那样做。为什么？因为你不知道那是你必须要做的。为什么？因为您没有设计……没有计划。

这就是您的具体问题。但是，请让我敦促您向后退一步巨大并彻底改变您的方法。在您编写一行代码之前，请在字节级别实际设计和指定一个协议(protocol)。协议(protocol)应该说明发送什么数据、消息如何定界、谁在何时发送、谁关闭连接等等。

否则，无法调试您的代码。查看上面的服务器代码，是否正确？好吧，谁知道呢。因为不清楚它应该做什么。当您编写客户端时，您假设服务器以一种方式运行。这个假设有效吗？服务器坏了吗？谁知道呢，因为没有关于服务器应该做什么的规范。