Java:无法在套接字插入后写入套接字。readLine（）

Question

我转向你，在这件事上我一直把头撞在墙上。

我正在做一个小的socket编程，我可以看到当我把它放出来。println（“…”）while循环之前的代码行（in.readLine（））它工作正常，但我需要它位于循环内部。

说清楚一点，我没有看到任何错误。我只是看不到此应用程序的客户端显示文本。它看起来好像在工作，但事实并非如此。此外，我也不控制该应用程序的客户端，它由通过TCP连接到此套接字侦听器应用程序的设备处理。是否有可能在读取数据后立即切断连接？

public class ConnectionHandlerTCP implements Runnable
{
        private final Socket clientSocket;

        ConnectionHandlerTCP(Socket socket)
        {
                clientSocket = socket;
        }

        public void run()
        {
                int uniqueId = 0;
                try (
                        BufferedReader in = new BufferedReader( new InputStreamReader(clientSocket.getInputStream()));
                        PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
                ){
                        String inputLine;

                        // This Line WORKS, I see it appear on the other side of the connection.
                        Log.debug("Sending now A");
                        out.println("text to send here");

                        while ((inputLine = in.readLine()) != null)
                        {
                                // This Line DOES NOT WORK, I do not see it on the other side of the connection.
                                //Log.debug("Sending now B");
                                //out.println("text to send here");

                                // ... bunch of commented out code here
                        }

                        in.close();
                        out.close();
                        clientSocket.close();
                } catch (IOException e) {
                        Log.error("Exception caught when trying to read input.", e.getMessage());
                } catch (Exception e) {
                        Log.error("Exception caught when trying to parse data.", e.getMessage());
                }
        }
}

任何帮助都将不胜感激。如果有帮助，这里是主要的课程。

import java.net.*;
import java.io.*;

public class SocketListenerTCP 
{
    public static void main(String[] args) throws IOException {

        if (args.length != 1) {
            System.exit(1);
        }

        int portNumber = Integer.parseInt(args[0]);

        while(true)
        {
            try ( 
                ServerSocket serverSocket = new ServerSocket(portNumber);
            ) {

                Socket clientSocket = serverSocket.accept();

                new Thread(new ConnectionHandlerTCP(clientSocket)).start();

            } catch (IOException e) {
                Log.error("Exception caught", e.getMessage());
            }
        }
    }
}

我把它简化了一点，完全去掉了循环，但仍然不能正常工作。

                inputLine = in.readLine();
                Log.debug(inputLine);  

                Log.debug("Sending now");
                out.println("text to send here");

Answer 1

读取套接字连接的输入流是线程阻塞。您不能在同一个线程中同时读写。将打印机移动到另一个线程中，你应该没问题。

Answer 2

我想我终于找到了问题的症结所在。首先解释我最初的问题。我现在确信，我连接的设备在20秒左右没有读/写任何活动后会与我的服务器应用程序断开连接。所以readline（）将等待20秒后返回它所拥有的一切，此时不允许写回设备。然而，如果我一次只读取一个字符（通过read（）），它工作得很好，允许我读取整个消息，并在read（）循环的最后一个字符读取迭代中等待最后的“-1”通过，发出有效负载结束的信号。在这段时间（读取第一个字符和等待最后一个字符）之间，我解析有效负载并向设备发送任何我想要的内容。它收到的大部分信息。

我的第二个问题是，有时输出流似乎断开了连接，不再让我发送任何消息。在最初的代码中，我让类实现了“Runnable”。这是个错误。我到处都看到使用Runnable是实现这一点的首选方法，但我注意到OutputStream在这种情况下很少工作，我转而扩展了Thread类，它几乎100%的时间都能工作。我认为一个线程过度写入另一个线程的输出流，然后下一个线程做同样的事情，然后每个线程都无法通过输出流进行通信。

在网上查看了其他一些示例之后，我假设如果我想使用Runnable，我可以使用某种方式，但必须重构应用程序中的其他一些项。在我回到那条路上之前，我得多读点书。

无论如何，它目前似乎运行平稳，现在很少失败。我仍然很想知道为什么它有时仍然失败，所以我会在时间允许的情况下继续研究。

我仍然有点困惑，有一位评论者说我不能在同一条线上读写。。。这似乎是完全错误的，只要在向设备写入之前先读一个I read（）（而不是readLine（）），读写似乎就可以正常工作。

Answer 3

里面的代码

while（（inputLine=in.readLine（））！=空）

很可能没有运行，因为中存在。readLine一直在等待客户端的输入。

客户端程序/套接字需要让它处于PrintWriter和println状态，这样你的while循环就可以读取并响应它（假设这就是你想要实现的）。