Java Передача файлов с использованием сокетов - PullRequest
Новая
       27

Java Передача файлов с использованием сокетов

0 голосов
/ 25 октября 2018

В моем проекте я пытаюсь отправить файл всем подключенным клиентам. Я использовал поток, чтобы отправить файл клиентам. Но когда я попытался проверить это, я обнаружил, что 3 клиента из 7 получили полный файл PDF, ноостальные из них получили только несколько байтов.Как эффективен способ передачи файлов в программировании сокетов Java, чтобы я мог отправить файл более чем 100 клиентам одновременно?

Код отправки файла 

while(true){


            try {
                if(Helper.sendFile)
                {
                    System.out.println("file sending...");
                    File file = new File(Helper.quesPath);
                    // Get the size of the file
                    long length = file.length();
                    byte[] bytes = new byte[16 * 1024];
                    InputStream in = new FileInputStream(file);
                    OutputStream out = socket.getOutputStream();

                    int count;
                    while ((count = in.read(bytes)) > 0) {
                        out.write(bytes, 0, count);
                        System.out.println("ec : "+count);
                    }

                   //out.close();
                   out.flush();
                   in.close();
                    break;
                }
            } catch (IOException e) {

                e.printStackTrace();
            }

        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }



    }

Получение файлакод 

while (true)
        {
            if(Helper.sendFile)
            {
                try {
                    in = socket.getInputStream();
                    String x=System.getProperty("user.home");

                    out = new FileOutputStream(x+"/Desktop/"+Helper.courseCode+".pdf");
                    System.out.println(x);

                    byte[] bytes = new byte[16*1024];

                    int count;
                    while (true) {
                        count = in.read(bytes);
                        System.out.println("v  : "+count);
                        if(count < 16380){
                            out.write(bytes, 0, count);
                            break;
                        }else{
                            out.write(bytes, 0, count);
                        }

                    }

                    System.out.println("File Done");
                    //in.close();
                    out.close();
                    break;

                } catch (Exception ex) {
                    System.out.println("File not found. ");
                }

            }
            try {
                Thread.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

    } catch (IOException e) {
        e.printStackTrace();

    }

Ответы [ 2 ]

0 голосов
/ 25 октября 2018

Я бы предложил следующие изменения:

Вы можете установить FileOutputStream, чтобы добавить полученные байты в файл.Таким образом, вам не нужно обязательно записывать их в правильную позицию. 

out = new FileOutputStream(x+"/Desktop/"+Helper.courseCode+".pdf", true);


Таким образом, запись файла может быть выполнена следующим образом: 

int count = 0;
while ((count = in.read(bytes)) > 0) {
    System.out.println("v  : " + count);
    out.write(bytes, 0, count);
}

Если это не решит вашу проблему, вы должны показать нам код, в котором вы обрабатываете сокеты.

0 голосов
/ 25 октября 2018

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

Я предполагаю, что магическое число 16380 - это ожидаемая длина файла.Так что вам нужно сделать что-то немного другое: 

int count = 0;
while (count < 16380) {
      int incoming = in.read(bytes);
      System.out.println("v  : " + incoming);

      if (incoming > 0) {
        out.write(bytes, 0, incoming); 
        count += incoming;
      } else if (incoming < 0) {
        //end of stream
        break; 
      }
}

Этот цикл будет продолжаться до тех пор, пока число прочитанных байтов (count) не достигнет вашего магического числа.

Что-тоЯ также хотел бы использовать более эффективные входные потоки, такие как BufferedInputStream.

Итак, в вашей первой строке в блоке вы делаете: 

in = new BufferedInputStream(socket.getInputStream());

Если вы хотите большое количество одновременных соединений, возможно, имеет смысл взглянуть на создание вашегонеблокирование сервера с помощью NIO.Но парадигма немного другая.

...