java - DataOutputStream:循环中的dos.write()，Receiver只接收到一个数据包

Question

我的 TCP 连接有问题。我通过 TCP 套接字连接通过智能手机将数据(一个简单的字符串)发送到平板电脑。连接工作正常并且数据按预期传输。但是，当我执行循环并在每次迭代中触发 dos.write() 时，只有一个包到达平板电脑数据接收器。我做错了什么？

这是我的连接的发送部分。它遍历列表并将每个数据写入 DataOutputStream。

for(int i = 0; i <= logList.length - 1; ++i){
    String backupPayload = invertLogStringToJson(logList[i]);

    dos = new DataOutputStream(s.getOutputStream());

    dos.writeUTF(backupPayload);
    dos.flush();
    dos.close();

在平板电脑上，我通过以下代码 fragment 接收数据:

@Override
public void run() {
    try {

        while(true){
            mySocket = ss.accept();
            dis = new DataInputStream(mySocket.getInputStream());
            message = dis.readUTF();

            handler.post(() -> {
                bufferIntentSendCode.putExtra("data", message);
                ctx.sendBroadcast(bufferIntentSendCode);
            });
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}

正如我所说，当我仅发送一个数据包时，连接工作正常。但如果我想在循环内发送多个包裹，则只有第一个包裹会到达目的地。

有人可以帮助我吗？ :)

Answer 1

在 DataOutputStream 上调用 close() 将关闭其关联的 OutputStream，而关闭套接字的 OutputStream 将关闭该套接字的 OutputStream。 socket 。这是有记录的行为。

但是，这应该没问题，因为您的接收器代码无论如何都只期望接收 1 个字符串。每个 TCP 连接仅调用一次 dis.readUTF()。

如果您想在单个连接中发送多个字符串，请不要在发送端调用 dos.close() (至少在所有字符串都已发送之前)，并且不要在接收端循环调用 dis.readUTF() ，直到接收到所有字符串。

dos = new DataOutputStream(s.getOutputStream());

for(int i = 0; i < logList.length; ++i){
    String backupPayload = invertLogStringToJson(logList[i]);
    dos.writeUTF(backupPayload);
}
dos.flush();

dos.close();

@Override
public void run() {
    try {
        while (true) {
            mySocket = ss.accept();
            dis = new DataInputStream(mySocket.getInputStream());

            try {
                while (true) {
                    message = dis.readUTF();
                    handler.post(() -> {
                        bufferIntentSendCode.putExtra("data", message);
                        ctx.sendBroadcast(bufferIntentSendCode);
                    });
                }
            } catch (IOException e) {
            }

            dis.close();
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

或者，在发送实际字符串之前发送列表长度，然后在读取字符串之前读取长度:

dos = new DataOutputStream(s.getOutputStream());

// maybe other things first...

dos.writeInt(logList.length);
for(int i = 0; i < logList.length; ++i){
    String backupPayload = invertLogStringToJson(logList[i]);
    dos.writeUTF(backupPayload);
}
dos.flush();

// maybe other things next...

dos.close();

@Override
public void run() {
    try {
        while (true) {
            mySocket = ss.accept();
            dis = new DataInputStream(mySocket.getInputStream());

            try {
                // maybe other things first...

                int length = dis.readInt();
                for (int i = 0; i < length; ++i) {
                    message = dis.readUTF();
                    handler.post(() -> {
                        bufferIntentSendCode.putExtra("data", message);
                        ctx.sendBroadcast(bufferIntentSendCode);
                    });
                }

                // maybe other things next...

            } catch (IOException e) {
            }

            dis.close();
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}