Java 使用套接字编程进行文件传输

Question

在我的项目中，我试图将文件发送到每个连接的 clients.I 使用线程将文件发送到 clients.But 当我尝试对此进行测试时，我发现总共 7 个客户端中有 3 个得到了完整的 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();

    }

Answer 1

我认为你的问题出在从客户端读取它时。

我假设幻数 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 使您的服务器非阻塞可能是有意义的。但是范式有点不同。

Answer 2

我会建议这些更改：

您可以设置 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);
}

如果这不能解决您的问题，您应该向我们展示您处理套接字的代码。

Java 使用套接字编程进行文件传输

Java File transfer using socket programming

java

sockets

file-transfer