Java - Chuyển các tệp lớn qua các kênh - NIO

Question

Tôi phải chuyển ~ 100MB dữ liệu qua ServerSocket bằng NIO, nhưng tôi không thể tìm ra cách thực hiện điều này mà không cần chuyển bất kỳ nơi nào/giữ trạng thái chuyển.

Ý tưởng đầu tiên của tôi là gửi kích thước tệp, dường như tôi không thể gửi kích thước của các tệp lớn đó vì nó thậm chí không phù hợp với RAM cùng một lúc. Sau đó, tôi nghĩ, tại sao không chỉ chuyển đến khi không có gì được nhận, nhưng thats khi vấn đề đi kèm trong.

Thậm chí nếu tôi ghi dữ liệu máy chủ mặt mọi lúc

 FileChannel fc = new FileInputStream(f).getChannel(); 
     ByteBuffer buffer = ByteBuffer.allocate(1024); 
     while(fc.read(buffer) > 0) { 
      buffer.flip(); 
      while(channel.write(buffer) > 0); 
      buffer.clear(); 
     } 

nhưng vì có phải phá vỡ trong chuyển tập tin một số thời gian đọc dữ liệu liên tục và phá vỡ khi không có gì là có sẵn là ý tưởng tồi.

Tôi không thể hiểu làm thế nào tôi có thể nói với khách hàng nếu vẫn còn dữ liệu sẵn có mà không phải gửi từng đoạn dữ liệu dưới dạng gói mới với mã opcode, v.v.

Tôi cũng tự hỏi nếu cách theres tốt hơn để gửi toàn bộ đệm hơn dưới

while(channel.write(buffer) > 0); 

Answer 1

Cách đúng để sao chép các kênh truyền hình qua bộ đệm như sau:

while (in.read(buffer) >= 0 || buffer.position() > 0) 
{ 
    buffer.flip(); 
    out.write(buffer); 
    buffer.compact(); 
} 

này sẽ chăm sóc của tất cả các trường hợp góc bao gồm chiều dài đọc = ghi chiều dài và có dữ liệu còn sót lại ở phần cuối của đầu vào!.

NB dành cho chế độ chặn. Nếu bạn đang ở chế độ không chặn, bạn nên quay lại vòng lặp select() nếu read() hoặc write() trả về 0.

Answer 2

Có lẽ bạn đang tìm kiếm này:

channel.transferFrom(0, fc.size(), fc); 

Answer 3

Nếu bạn không thể phụ thuộc vào ổ cắm để ngỏ, không có cách nào xung quanh xây dựng một cơ chế phục hồi và tiếp tục vào giao thức của bạn. Như để nói cho khách hàng biết bao nhiêu byte để mong đợi, bạn có thể tìm thấy kích thước của một tập tin mà không cần đọc nó vào bộ nhớ bằng cách sử dụng File.length.