TCP/IP客户端：从服务器读取多个输入流的最佳方式

Question

我正在创建一个java客户端程序，它向服务器发送一个命令，服务器会发回一个确认和一个响应字符串。

响应以这种方式发回

客户-

服务器-

服务器-

当我尝试读取输入时，我只能读取一个输入流的确认消息

我的客户端程序能够以某种方式读取消息（hacky方法）。要读取输入，我必须使用Bufferedreader读取ack msg。

1. 此缓冲读取器只能读取ack_msg不能读取以下msg
2. 需要DataInputstream代码来读取响应msg。
3. 如果我跳过步骤1，只是使用Datainputstream我不能读取完整的消息。

客户JAVA

try {
            Socket clientSocket = new Socket(SERVER_ADDRESS, TCP_SERVER_PORT);// ip,port

            System.out.println(" client Socket created .. ");
            
            PrintWriter outToServer = new PrintWriter(clientSocket.getOutputStream(), true);

            String ToServer = command;
            outToServer.println(ToServer);

            in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
//          
            // while (!in.ready()) {
            // }
            System.out.println(in.read()); // Read one line and output it

            
            // ===
            byte[] messageByte = new byte[1000];//assuming msg size -need to know eact msg size ?
            boolean end = false;
            String dataString = "";
            int bytesRead = 0;

            try {
                DataInputStream in1 = new DataInputStream(clientSocket.getInputStream());
//
                while (!end) {
                    bytesRead = in1.read(messageByte);
                    dataString += new String(messageByte, 0, bytesRead);
                    if (dataString.length() > 0) {
                        end = true;
                    }
                }
                System.out.println("MESSAGE: " + dataString);
            } catch (Exception e) {
                e.printStackTrace();
            }
            // ===
                
            in.close();             

            clientSocket.close();
            System.out.print("connection closed");

        } catch (Exception e) {
            System.out.print("Whoops! It didn't work!\n");
            e.printStackTrace();
        }

输出

客户端套接字创建...

答复：6

信息：³CO³0Œ

连接已关闭

当我跳过第一步

客户端套接字创建...

留言：-

连接已关闭

如何编写从服务器（msg）读取所有输入的代码

参考了如何在服务器套接字JAVA中读取所有Inputstream

谢啦

Answer 1

InputStream input = null;
OutputStream output = null;

Socket cs = new Socket("LocalHost", 6789);
 input = cs.getInputStream();
output = cs.getOutputStream();
 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(output));

bw.write("Send your String");
bw.flush();

int bytesRead = 0;
byte[] messageByte = new byte[1000];
String dataString = "";

bytesRead = input.read(messageByte);
dataString = new String(messageByte, 0, bytesRead);

Answer 2

您不能在同一个基础套接字上同时使用BufferedReader和DataInputStream。您将丢失BufferedReader中的数据。在套接字的生命周期内，对所有内容使用相同的流或读取器。写入器和输出流也是如此。

Answer 3

这些语句强制在发送至少1个html" target="_blank">字节后立即关闭流。

dataString += new String(messageByte, 0, bytesRead);
if (dataString.length() > 0) {
   end = true;
}

一旦收到ack 6，连接就关闭了。如果忽略ack，响应可能以多个数据包发送，连接将在收到第一个数据包后关闭。

您必须能够确定ack和响应何时结束。

1. 如果你知道应答和应答中有多少个字符，你可以像你提到的问题一样循环。您将需要一个用于ack的循环和一个用于响应的循环
2. 如果不知道字符数，则必须查找特殊字符，如行尾或文件结尾，以了解确认行何时结束以及服务器响应何时结束。在每条消息的结尾处寻找一个特殊字符
3. 第三种可能是等待特定的时间。时间到期后，继续。这在TCP上是不可靠的，因为数据可能会丢失并重新发送。这可能需要比你分配的时间更多的时间来回复。 我同意下面的评论。最初，我犹豫是否要在列表中添加3个。此选项最有可能用于检测通信信道的问题。如果时间到期，那么客户端将放弃一个错误条件，它将不会继续处理，就好像一切正常一样