Java UDP数据包仅包含5个数据包

Question

以下代码用于通过以下formart“address，porttNum”中的简单字符串发送。

下面是客户端：

ByteArrayInputStream bin = new ByteArrayInputStream(packet.getData()); 
DataInputStream dis = new DataInputStream(bin); 

try { 
      System.out.println("Data in packet: " + dis.readLine()); 
     } catch (IOException e1) { 
      // TODO Auto-generated catch block 
      e1.printStackTrace(); 
     } 

下面是服务器端：

byte[] sbuf = data.getBytes(); 
     // sbuf = output.getBytes(); 
     packet = new DatagramPacket(sbuf, 
       sbuf.length, packet.getAddress(), packet.getPort()); 
try { 
      socket = new DatagramSocket(); 
      socket.send(packet); 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 

说服务器发送 “ABCDEFGHI”，客户端只临危 “ABCDE”。我已经尝试了多个测试用例，客户端总是收到5个字节。任何人都可以指出我搞砸了吗？

编辑： 对于调试目的，我甚至增加了以下内容：

try { 
      System.out.println("Data in packet: " + dis.readLine()); 
     } catch (IOException e1) { 
      // TODO Auto-generated catch block 
      e1.printStackTrace(); 
     } 

其输出端仍然没有得到它正确的数据。

编辑2： 我改变了客户端于以下内容：

String data = new String(packet.getData(), StandardCharsets.UTF_8); 
     System.out.println("Data in packet: " + data); 

这没有什么区别。

Answer 1

下面是一些示例代码，显示了从字符串的字节构造数据报包，发送它以及重构字符串。

请注意，接收数据包的缓冲区被创建得比最终收到的消息大得多。这是必要的，因为如果接收到大于缓冲区的消息，UDP套接字会将消息截断为缓冲区的大小。例如，如果客户端向服务器发送了消息“ZYXWV”，并且仅创建了足够大的缓冲区，并且重复使用了传入消息的缓冲区，则只有传入消息的前5个字符是接收。

public class DataGram { 

    public static void main(String[] args) throws SocketException { 
     new Thread(new Client()).start(); 
     new Thread(new Server()).start(); 
    } 

    static class Client implements Runnable { 
     DatagramSocket socket; 

     Client() throws SocketException { 
      socket = new DatagramSocket(1234); 
     } 

     @Override 
     public void run() { 
      byte[] buf = new byte[1024]; 
      DatagramPacket packet = new DatagramPacket(buf, buf.length); 
      try { 
       try { 
        socket.receive(packet); 
        String msg = new String(packet.getData()); 
        System.out.println(msg); 
       } finally { 
        socket.close(); 
       } 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 

    static class Server implements Runnable { 

     @Override 
     public void run() { 
      SocketAddress address = new InetSocketAddress("localhost", 1234); 
      try (DatagramSocket socket = new DatagramSocket()) { 
       String msg = "abcdefghi"; 
       byte[] buf = msg.getBytes(); 
       DatagramPacket packet = new DatagramPacket(buf, buf.length, address); 
       socket.send(packet); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 
} 

没有DataInputStream类或ByteArrayInputStream的用在这里，因为你可以直接将String到byte[]，然后再返回。