java - 接收 UDP 数据包 - Java

Question

嗨，我正在尝试使用 UDP 将 1 kb 的数据包从客户端发送到服务器。我可以接收所有数据包，但问题是 while 循环没有退出，所以我使用套接字超时来实现这一点。由于这不适合动态环境，我想替换一些合理的东西。下面是我的服务器端和客户端代码，客户端从 while 循环跟随服务器端。我只想实现 RDT 1.0，其中数据包被分成 1kb 并通过 UDP 套接字发送以在另一端接收。但是在接收所有 1kb 数据包时，我尝试了很多方法来退出 while 循环，最终在接收端设置了套接字超时。另外，我声明了“i”(i<9 知道我的文件大小)以退出循环，以便在超时之前执行其余的编码。有没有一种方法可以更改我的 while 循环，使其适合所有环境(发送N个数据包)。

//Client side
    class Client
{
    public static DatagramSocket sock =null;
    public static FileInputStream in=null;
    public static DatagramPacket[] sendpacket=new DatagramPacket[1024];
public static void main(String[] args) throws Exception
{
    byte[] array = new byte[1024];
    DatagramSocket sock = new DatagramSocket();
    InetAddress ip= InetAddress.getByName("localhost");
    Scanner scanner = new Scanner(System.in);
    System.out.println("Enter a file name: ");
    System.out.flush(); 
    String filename = scanner.nextLine();
    File file = new File(filename);
    in=new FileInputStream(file);
    int length =0,checksum=0,h=1;
    while((length = in.read(array))!=-1)
    {
        sendpacket[h]=new DatagramPacket(array,array.length,ip,1234);
        sock.send(sendpacket[h]);
        checksum+=length;
        System.out.println("Sent packet "+h);
        System.out.println(length);
        System.out.println(checksum);
        h++;
         }
        in.close();

}
}





 //Server side
public class server
{
    public static DatagramPacket[] recvpacket=new DatagramPacket[100];
    public static DatagramSocket sock=null;
    public static FileOutputStream fos=null;
    public static BufferedOutputStream bos=null;
    public static void main(String args[]) 
    {

    try
        {
        try
        {
        sock=new DatagramSocket(1234);//opening a socket
    }
    catch(IOException ex)
    {
    System.out.println(ex);
    }
    sock.setSoTimeout(30000);
    boolean socketalive=true;
    byte[] array=new byte[1024];
    int i=1,checksum=0;
    System.out.println("server is ready to receive packets");
    while(recvpacket!=null)//I need change in this loop 
    {
    recvpacket[i]=new DatagramPacket(array,array.length);
    sock.receive(recvpacket[i]);
    System.out.println("server received packet "+i);
    int length=array.length;
    checksum+=length;
    System.out.println(length);//here i get the size of the buffer so  //checksum is wrong
    System.out.println(checksum);
    fos=new FileOutputStream(new File("profile1.docx"),true);
    fos.write(array);
    for(int j=0; j<1024; j++)
    {
      array[j]=0;
   }
   i++;
    }//while
    System.out.println("server received packet "+i);
    }//try
    catch(IOException e)
    {
    System.out.println(e);
    }
    }//main
    }//class

Answer 1

您可能会遇到一些问题。 UDP 不像 TCP 那样可靠，因此数据包可能会被丢弃，或更糟糕的是可能会乱序。在将数据写入文件之前，您需要将数据存储在本地缓冲区中，或者将其写入文件中的适当位置(可能为缺失的位置留出空间)。

理想情况下，UDP 监听循环应位于其自己的线程中，以便可以运行其他代码。如果您想通过 UDP 实现某种 FTP，那么您需要在开始时发送一个数据包，其中包含有关传输的信息，例如大小、数据包数量、校验和。然后，对于每个数据包，您还需要包含单个数据包的序列号和校验和。最后(或一路上)，服务器需要回复客户端请求丢失/损坏的数据包。我建议最后发送一个“传输完成”数据包。

如果所有数据包均已收到且未损坏，则可以终止循环!

您应该能够找到现有的东西来为您处理所有这些，而不是从头开始编写所有内容，但如果您必须自己编写所有内容，那么您必须复制 TCP 的开销。