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

Question

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

问题：

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

我的意图：

1. 这是一个线程，将循环检查是否有 outMessage，如果有，它将发送消息。
2. 接下来，它会检查流内是否有任何内容，如果有，它会将其发送到我的主要活动中的处理程序。
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");
        }

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

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

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

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

Answer 2

您需要检查是否有可用的数据：

if (InStream.available > 0) {                                                      
   String modifiedSentence = InStream.readLine();
   sendMessageToAllUI(0, MAINACTIVITY_SET_TEXT_STATE, "appendText" , "IN FROM SERVER: " + modifiedSentence); 
}

但老实说，即使这样也并不理想，因为您无法保证会收到 eend-of-line。如果服务器发送了几个字节但从不发送行尾，那么您仍然会永远阻塞。生产套接字代码不应该依赖readLine，而是读入缓冲区并检查该缓冲区的行尾（或您的协议需要的任何标准）。

---

没有仔细阅读，我认为InStream 是InputStream 实例。 InputStream 有 available。 InputStreamReader 有 ready（它又调用 InputStream.available。只要你保留对其中任何一个的引用，你就可以查看是否有数据可供读取。