使用 TCP 连接获取字节数组

Question

我之前使用UDP 发送/接收数据，但我现在想切换到TCP 以避免数据包丢失。

我已经阅读了几个关于TCP 的教程，并注意到TCP 使用InputStream/OutputStream 而不是像UDP 那样使用DatagramPacket。

我们如何从 DataInputStream 中获取 byte[]，类似这样的东西：

byte[] receiveData = new byte[64000];
DatagramPacket receivePacket = new DatagramPacket(receiveData,receiveData.length); 
receiveData=receivePacket.getData();

Answer 1

为了通过套接字（流）实现基于消息的协议，您基本上想提出一些消息格式，然后在连接的任一端读/写。一种非常简单的格式是将消息的长度写为 4 字节 int，然后发送消息字节（然后刷新流）。在接收端，读取一个 4 字节的 int，然后读取 后面的字节数（注意限制读取方法调用，否则可能会意外读取下一条消息的一部分）。

public void writeMessage(DataOutputStream dout, byte[] msg, int msgLen) {
  dout.writeInt(msgLen);
  dout.write(msg, 0, msgLen);
  dout.flush();
}

public byte[] readMessage(DataInputStream din) {
  int msgLen = din.readInt();
  byte[] msg = new byte[msgLen];
  din.readFully(msg);
  return msg;
}

Answer 2

答案分为两部分。处理与您的问题相关的 2 个独立问题。

1。网络事实

TCP 本质上是基于流的。即先发送字节[1000]，然后发送字节[1200]，与发送字节[2200]一次没有区别。实际通过网络发送的很可能是 2 个数据包，第一个是 1400 字节的数据包，第二个是 800，或 1401 和 799，并且每次都可能不同。接收方无法知道发送方实际上先发送了 1000 个字节，然后发送了 1200 个字节。这是网络设计的。 Java 与这个事实无关。而且你不能用它做任何事情。

2。 Java实现

在发送方。首先，您需要OutputStream os = tcpsocket.getOutputStream();。然后，每次都需要os.write(byteArray)。在接收方，您需要InputStream is = tcpsocket.getInputStream();。然后，每次都需要is.read(byteArray)。请注意，在接收方，将返回实际填充了多少byteArray。它可以是介于 1 和byteArray 容量之间的任意数字，与发送者实际发送它的方式无关。

为了减轻任务，您可以在开头使用DataInputStream is = new DataInputStream(tcpsocket.getInputStream());，每次需要阅读时使用is.readFully(byteArray)。这样就可以保证byteArray总是被填满。

但是如果实际长度是可变的，除非您添加一些额外的信息，否则您永远无法知道应该接收多少字节。例如，先发送长度，使用 4 个字节。您将如何实际执行此操作通常与您的实际用例密切相关。这取决于你