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" をrecieves言います。私は複数のテストケースでそれを試して、クライアントは常に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

StringのバイトからのDatagramパケットの構築、送信、およびStringの再構築を示すコード例です。

パケットを受信するためのバッファは、最終的に受信されるメッセージよりもはるかに大きく作成されていることに注意してください。これは、バッファよりも大きなメッセージを受信した場合、UDPソケットがメッセージをバッファのサイズに切り詰めるため、必要です。たとえば、クライアントがサーバーにメッセージ "ZYXWV"を送信し、そのメッセージに十分な大きさのバッファを作成した後にを再利用した場合、受信メッセージのバッファーはです。受信メッセージの最初の5文字のみ受け取った。あなたが直接Stringbyte[]にして再度変換することができますので、

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は、ここで使用されます。