Как создать простое серверное клиентское приложение, использующее RUDP в Java?

Question

Я работал над простым приложением для передачи файлов между двумя компьютерами с использованием UDP, но это оказалось с потерями и ненадежностью, поэтому при поиске в Интернете я нашел этот проект под названием Simple Reliable UDP, но у них нет документации или любой пример кода. Так что если кто-нибудь сможет мне помочь с этим кодом, я буду благодарен, потому что я новичок в Java. Я начал с написания простого серверного клиентского приложения, но у меня уже есть исключение привязки адресов. Чтобы было понятно, я хочу использовать только UDP-соединения, поэтому я пытаюсь реализовать ReliableServerSocket а также ReliableSocket,

  package stackru;

  import java.io.BufferedReader;
  import java.io.IOException;
  import java.io.InputStreamReader;
  import java.util.logging.Level;
  import java.util.logging.Logger;
  import net.rudp.ReliableServerSocket;
  import net.rudp.ReliableSocket;

  /**
  *
  * @author Nika
  */
  public class udpServer implements Runnable{
  ReliableServerSocket rss;
  ///ocket rs;
  ReliableSocket rs;
  public udpServer() throws IOException {
  rss= new ReliableServerSocket(9876);
  }
  public void run(){
  while (true){
    try {
        rs=(ReliableSocket)rss.accept();
        System.out.println("Connection Accepted");
        System.out.println(""+rs.getInetAddress());
        BufferedReader  inReader = new BufferedReader (new InputStreamReader (rs.getInputStream()));
    //BufferedWriter  outReader = new BufferedWriter (new OutputStreamWriter (rs.getOutputStream()));

        String str= ""+inReader.readLine();

        if(str.contains("UPLOAD")){
            System.out.println("Client wants to upload file");
        }else if(str.contains("D1")){
            System.out.println("Client wants to download file");
       }



    } catch (IOException ex) {
        Logger.getLogger(udpServer.class.getName()).log(Level.SEVERE, null, ex);
    }

  }

  }

      public static void main(String args[]) throws Exception  
   {
      System.out.println("UDP Server Executed");
     Thread t= new Thread( new udpServer());
             t.start();
   }


 }

Код клиента здесь

      package stackru;

      import java.io.BufferedWriter;
      import java.io.IOException;
      import java.io.OutputStreamWriter;
      import net.rudp.ReliableSocket;

      /**
      *
      * @author Nika
      */
     public class UdpFileClient {

     BufferedWriter outReader;
     ReliableSocket server;

    public UdpFileClient(boolean b1, boolean b2) throws IOException {

    if (b1) {
        server = new ReliableSocket("127.0.0.1", 9876);

        outReader = new BufferedWriter(new OutputStreamWriter(server.getOutputStream()));
        outReader.write("D1");
        System.out.println("Download Req Sent From Client");
        server.close();
        outReader.flush();
        outReader.close();
    }

    if (b2) {
        server = new ReliableSocket("127.0.0.1", 9876);
        outReader = new BufferedWriter(new OutputStreamWriter(server.getOutputStream()));
        outReader.write("UPLOAD");
        System.out.println("Upload Req Sent From Client");
        server.close();
        outReader.flush();
        outReader.close();
    }

}

public static void main(String args[]) throws Exception {
    System.out.println("UDP CLient Executed");
    new UdpFileClient(true, true);
}

}

Я уже знаю, что могу использовать TCP/IP, но это своего рода требование для проекта использовать UDP. Если вам пригодится любой другой способ отправки файлов без потерь с использованием UDP с хорошей скоростью.

Заранее спасибо!!

Answer 1

Я попробовал RUDP и обнаружил, что я не печатал свой вывод, я знаю, что это глупая ошибка.

UDP Клиентский пакет UDPClient;

  import java.io.IOException;
  import java.io.InputStream;
  import java.net.InetSocketAddress;
  import net.rudp.ReliableSocket;

  /**
  *
  * @author Nika
  */
  public class UDPtestc {
  ReliableSocket server;
   public UDPtestc() throws IOException {
     server = new ReliableSocket();
            server.connect(new InetSocketAddress("127.0.0.1", 9876));
    byte[] buffer = new byte[1024];
    int count,progress=0;
    InputStream in = server.getInputStream();
    while((count=in.read(buffer)) >0){
    progress+=count;
    System.out.println(""+progress);
    }
    server.close();            
    }

    public static void main(String[] args) throws IOException {
    new UDPtestc();
    }

    }

UDPserver

  package UDPServer;

  import java.io.FileInputStream; 
  import java.io.IOException;
  import java.io.OutputStream;
  import java.io.RandomAccessFile;
  import java.net.Socket;
  import java.util.logging.Level;
  import java.util.logging.Logger;
  import net.rudp.ReliableServerSocket;
  import net.rudp.ReliableSocket;

  /**
  *
  * @author Nika
  */
  public class UDPtests implements Runnable {

  ReliableServerSocket rss;
  ReliableSocket rs;
  String file;

  FileInputStream bin;

  public UDPtests() throws IOException {
    rss = new ReliableServerSocket(9876);
    Thread serverthread = new Thread(this);
    serverthread.start();

   }

   public void run() {
    while (true) {
        try {
            rs =  (ReliableSocket)rss.accept();
            System.out.println("Connection Accepted");
            System.out.println("" + rs.getRemoteSocketAddress());

              file = "";
        Long size=0L;
             file += "10MB.txt";
                size+=10*1024*1024;

        RandomAccessFile r1= new RandomAccessFile(file,"rw");
        r1.setLength(size);
        byte[] sendData = new byte[1024];

        OutputStream os = rs.getOutputStream();
        //FileOutputStream wr = new FileOutputStream(new File(file));
        bin= new FileInputStream(file);
        int bytesReceived = 0;
        int progress = 0;
        while ((bytesReceived = bin.read(sendData)) > 0) {
            /* Write to the file */
            os.write(sendData, 0, bytesReceived);
            progress += bytesReceived;
            System.out.println(""+progress);
        }



        } catch (IOException ex) {
            Logger.getLogger(udpServer.class.getName()).log(Level.SEVERE, null, ex);
        }

    }
}

public static void main(String[] args) throws IOException {
    new UDPtests();
}

}

Вскоре я опубликую другие статьи на RUDP, если это будет возможно.