Java NIO: transferFrom do końca strumienia

Question

gram około z biblioteki NIO. Próbuję odsłuchać połączenie na porcie 8888 i gdy połączenie zostanie zaakceptowane, zrzuć wszystko z tego kanału do somefile.

Wiem, jak to zrobić z ByteBuffers, ale chciałbym, aby działało z rzekomo super wydajnym FileChannel.transferFrom.

To jest to, co mam:

ServerSocketChannel ssChannel = ServerSocketChannel.open(); 
ssChannel.socket().bind(new InetSocketAddress(8888)); 

SocketChannel sChannel = ssChannel.accept(); 
FileChannel out = new FileOutputStream("somefile").getChannel(); 

while (... sChannel has not reached the end of the stream ...)  <-- what to put here? 
    out.transferFrom(sChannel, out.position(), BUF_SIZE); 

out.close(); 

Więc moje pytanie brzmi: Jak mogę wyrazić "transferFrom jakiś kanał, aż zostanie osiągnięta end-of-stream"?

---

^{Edycja: Zmiana 1024 do BUF_SIZE, od wielkości użytego buforu, nie ma znaczenia dla kwestii.}

Answer 1

Nie jestem pewien, ale JavaDoc mówi:

próba jest do zapoznania się liczyć bajtów z kanału źródłowego i zapisać je do pliku tego kanału zaczynając dana pozycja. Wywołanie tej metody może lub nie może przesłać wszystkich żądanych bajtów; czy to nie tak zależy na natur i stwierdza z kanałów. Mniej niż wymagana liczba bajtów zostanie przeniesiona, czy kanał źródło ma mniej niż liczyć bajtów Pozostała, czy kanał źródło nie jest blokowanie i ma mniej niż licznik bajtów bezpośrednio dostępne w buforze wejściowym.

Chyba można powiedzieć, że informując go skopiować nieskończone bajtów (oczywiście nie w pętli) będzie wykonać zadanie:

out.transferFrom(sChannel, out.position(), Integer.MAX_VALUE); 

Tak, myślę, że kiedy gra gniazdo jest zamknięty, stan zostanie zmieniony, co zatrzyma metodę transferFrom.

Ale jak już powiedziałem: Nie jestem pewien.

Answer 2

Odpowiadając na zapytanie bezpośrednio:

while((count = socketChannel.read(this.readBuffer)) >= 0) { 
    /// do something 
} 

Ale jeśli to jest to, czego robić nie wolno używać żadnych korzyści z non-blocking IO bo faktycznie używać go dokładnie tak, jak blokowanie IO. Punktem niezablokowania IO jest to, że jeden wątek sieciowy może obsługiwać wielu klientów jednocześnie: jeśli nie ma niczego do odczytu z jednego kanału (tj. count == 0), możesz przełączyć się na inny kanał (który należy do innego połączenia klienta).

Tak, pętla powinna faktycznie iteracji różnych kanałów zamiast czytania z jednego kanału, dopóki nie jest skończona.

Spójrz na ten samouczek: http://rox-xmlrpc.sourceforge.net/niotut/ Wierzę, że pomoże ci zrozumieć problem.

Answer 3

transferFrom() zwraca liczbę. Po prostu wywołuj to, przesuwając pozycję/offset, aż zwróci zero.Ale zacznij od znacznie większej liczby niż 1024, bardziej jak megabajt lub dwa, w przeciwnym razie nie otrzymasz wiele korzyści z tej metody.

EDIT rozwiązać wszystkie poniższe komentarze, dokumentacja mówi, że „Mniej niż wymaganej liczby bajtów zostanie przeniesiona jeśli kanał źródło ma mniej niż liczyć bajtów pozostały, lub jeżeli kanał źródłowy jest nieblokującą ma mniej niż liczba bajtów natychmiast dostępnych w swoim buforze wejściowym. " Pod warunkiem, że jesteś w trybie blokowania, nie zwróci zero, dopóki nie pozostanie w źródle. Tak więc pętla, dopóki nie zwróci zero, jest poprawna.

EDIT 2

Sposoby transferu pewnością MIS zaprojektowane. Powinny one zostać zaprojektowane tak, aby zwracały -1 na końcu strumienia, podobnie jak wszystkie metody read().

Answer 4

rzekomo super wydajny FileChannel.transferFrom.

Jeśli chcesz zarówno korzyści dostępu DMA i powodują blokowania IO najlepszym sposobem jest pamięć-map plik, a następnie po prostu czytać z gniazda w buforach pamięci odwzorowany.

Ale to wymaga wcześniejszego przydzielenia pliku.

Answer 5

Istnieje kilka sposobów na załatwienie sprawy. Niektóre informacje dodatkowe, jak program trasnferTo/From jest implementowany wewnętrznie i kiedy może być lepszy.

• 1. i wszystkim należy wiedzieć, ile bajtów trzeba Xfer, to znaczy używać FileChannel.size() określić maksymalną dostępną i podsumować wynik. Przypadek odnosi się do: FileChannel.trasnferTo(socketChanel)
• Metoda nie zwraca -1
• Metoda jest emulowana w systemie Windows. Windows nie ma funkcji API, która prześle dane z pliku filedescriptor do gniazda, ma jedno (dwa) do wypakowania z pliku oznaczonego nazwą - ale jest to niezgodne z interfejsem API języka Java.
• W systemie Linux używany jest standard sendfile (lub sendfile64), w systemie Solaris jest to sendfilev64.

w skrócie for (long xferBytes=0; startPos + xferBytes<fchannel.size();) doXfer() będzie działać do przesyłania z pliku -> gniazda. Nie ma funkcji systemu operacyjnego, która przesyła z gniazda do pliku (który jest zainteresowany programem OP). Ponieważ dane gniazda nie są w pamięci podręcznej systemu operacyjnego, nie można tego zrobić tak skutecznie, jest to emulowane. Najlepszym sposobem zaimplementowania kopii jest standardowa pętla za pomocą odpytanego bezpośredniego ByteBuffera z buforem odczytu gniazda. Ponieważ używam tylko niezablokowanego IO, które obejmuje również selektor.

takiej sytuacji: Chciałbym dostać pracy z rzekomo bardzo wydajny” - nie jest skuteczny i jest emulowane na wszystkich systemów operacyjnych, a więc będzie to skończyć transferu gdy gniazdo jest zamknięty wdzięcznie Funkcja nie będzie nawet rzucić odziedziczony wyjątek IOException, pod warunkiem, że istnieje JAKIKOLWIEK transfer (Jeśli gniazdo było czytelne i otwarte)

Mam nadzieję, że odpowiedź jest jasna: jedyne interesujące użycie File.transferFrom dzieje się, gdy źródło jest Plik najbardziej efektywny (i interesujący przypadek) to plik-> gniazdo i plik-> plik jest realizowany przez filechanel.map/unmap(!!).

Answer 6

ten sposób:

URLConnection connection = new URL("target").openConnection(); 
File file = new File(connection.getURL().getPath().substring(1)); 
FileChannel download = new FileOutputStream(file).getChannel(); 

while(download.transferFrom(Channels.newChannel(connection.getInputStream()), 
     file.length(), 1024) > 0) { 
    //Some calculs to get current speed ;) 
} 

Answer 7

Opierając się na górze, co inni ludzie tutaj pisałem, oto prosty sposób pomocnikiem, który realizuje cel:

public static void transferFully(FileChannel fileChannel, ReadableByteChannel sourceChannel, long totalSize) { 
    for (long bytesWritten = 0; bytesWritten < totalSize;) { 
     bytesWritten += fileChannel.transferFrom(sourceChannel, bytesWritten, totalSize - bytesWritten); 
    } 
}