Java UDP发送/接收小例子不起作用

Question

我编写了一个小型 UDP 客户端，它将数据包发送到某个本地地址，另一个小型 UDP 客户端将接收它们并在控制台上打印其包含的内容。他们目前没有工作，我不知道为什么。

这是发送代码:

import java.io.*;
import java.net.*;

class ClienteUDPtx {

  static final String HOST = "192.168.1.201";
  static final int PUERTO=20001;

  /**
    UDP Client which will send some UDP packets
    to local network address 192.168.1.201 on port 20001
  */
  public ClienteUDPtx( ) {
    try{
      int i = 0; 

      String[] ip_parts = HOST.split("."); 
      byte[] ip_num = {0, 0, 0, 0}; 
      for (String string : ip_parts) { 
         ip_num[i++] = Byte.valueOf(string); 
      } 

      InetAddress ip = InetAddress.getByAddress(ip_num); 
          DatagramSocket skCliente = new DatagramSocket(PUERTO, ip);
      DatagramPacket packet;
      File testFile = new File("test.txt");
      BufferedReader input =  new BufferedReader(new FileReader(testFile));
      String line;

      while((line=input.readLine())!=null) {
        System.out.println("Sending: " + line);
    byte message[] = line.getBytes();
    packet = new DatagramPacket(message, message.length, ip, PUERTO); 
        skCliente.send(packet);
    Thread.currentThread().sleep(1000);
      }
      line = "END";
      System.out.println("Sending: " + line);
      byte message[] = line.getBytes();
      packet = new DatagramPacket(message, message.length, ip, PUERTO); 
      skCliente.send(packet);

      input.close();
      skCliente.close();
    } catch( Exception e ) {
      System.out.println( e.getMessage() );
    }
  }


  public static void main( String[] arg ) {
    new ClienteUDPtx();
  }

}

这是接收代码:

import java.io.*;
import java.net.*;

class ClienteUDPrx {

  static final String HOST = "192.168.1.101";
  static final int PUERTO=20001;

  /**
    UDP Client which will listen for incoming UDP packets
    from local network address 192.168.1.101 on port 20001
    and will print its content on console
  */

  public ClienteUDPrx( ) {
    try{
      int i = 0; 

      String[] ip_parts = HOST.split("."); 
      byte[] ip_num = {0, 0, 0, 0}; 
      for (String string : ip_parts) { 
         ip_num[i++] = Byte.valueOf(string); 
      } 

      InetAddress ip = InetAddress.getByAddress(ip_num); 
      DatagramSocket skCliente = new DatagramSocket(PUERTO, ip);
      byte[] buffer = new byte[2048];
      DatagramPacket packet = new DatagramPacket(buffer, buffer.length);


      while(true){
        // Wait to receive a datagram
        skCliente.receive(packet);
        String lineaLeida = new String(buffer, 0, packet.getLength());
        System.out.println(packet.getAddress().getHostName() + ": "+ lineaLeida);
        if(lineaLeida.equals("END")) break; 
      }
      skCliente.close();
      System.out.println( "Transmission ended" );
    } catch( Exception e ) {
      System.out.println( e.getMessage() );
    }
  }


  public static void main( String[] arg ) {
    new ClienteUDPrx();
  }

}

有什么想法吗？

Answer 1

这里有一些错误。

第一个是创建 InetAddress。您可以这样做，而不是尝试分离出字节并从数组中重新创建它:

InetAddress.getByName(HOST);

它刚才失败了，因为当您拆分 HOST 时，您将其拆分为正则表达式并使用“.”。它具有特殊含义，因此实际上并不是根据“.”分割字符串。性格。

实际上将其拆分为“.”你会这样做:

HOST.split("\\.")

但是你的字节解析失败，因为字节的范围是 -128 到 +127(而不是 0 到 255)。

无论如何，这可能让您感到困惑是因为您的打印错误。

这一行:

System.out.println( e.getMessage() );

正在打印异常错误(在本例中只是“0”-“ArrayIndexOutOfBoundsException:0”)。

相反，你应该这样做:

e.printStackTrace();

获取有关问题所在的更多信息。

除了这些之外，我看不到任何明显的问题。

我还要指出，UDP 确实检查消息的完整性。它不保证传送或传送顺序，因此您可能会丢失数据包或有时使它们失去顺序，但它确实有一个校验和，其中包括消息的 header +有效负载。