Java NIO - Pipe
In Java, NIO pipe è un componente che viene utilizzato per scrivere e leggere dati tra due thread. Il pipe consiste principalmente di due canali responsabili della propagazione dei dati.
Tra i due canali costituenti uno è chiamato canale Sink che è principalmente per la scrittura di dati e l'altro è il canale Source il cui scopo principale è leggere i dati dal canale Sink.
La sincronizzazione dei dati viene mantenuta in ordine durante la scrittura e la lettura dei dati in quanto è necessario garantire che i dati vengano letti nello stesso ordine in cui vengono scritti sul tubo.
Si deve tenere presente che si tratta di un flusso unidirezionale di dati in Pipe, ovvero i dati vengono scritti solo nel canale Sink e possono essere letti solo dal canale Sorgente.
In Java, NIO pipe è definita come una classe astratta con principalmente tre metodi di cui due astratti.
Metodi della classe Pipe
open() - Questo metodo viene utilizzato per ottenere un'istanza di Pipe oppure possiamo dire che pipe viene creato chiamando questo metodo.
sink() - Questo metodo restituisce il canale sink del pipe che viene utilizzato per scrivere dati chiamando il relativo metodo di scrittura.
source() - Questo metodo restituisce il canale di origine della pipe che viene utilizzato per leggere i dati chiamando il relativo metodo di lettura.
Esempio
Il seguente esempio mostra l'implementazione di Java NIO pipe.
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.Pipe;
public class PipeDemo {
public static void main(String[] args) throws IOException {
//An instance of Pipe is created
Pipe pipe = Pipe.open();
// gets the pipe's sink channel
Pipe.SinkChannel skChannel = pipe.sink();
String testData = "Test Data to Check java NIO Channels Pipe.";
ByteBuffer buffer = ByteBuffer.allocate(512);
buffer.clear();
buffer.put(testData.getBytes());
buffer.flip();
//write data into sink channel.
while(buffer.hasRemaining()) {
skChannel.write(buffer);
}
//gets pipe's source channel
Pipe.SourceChannel sourceChannel = pipe.source();
buffer = ByteBuffer.allocate(512);
//write data into console
while(sourceChannel.read(buffer) > 0){
//limit is set to current position and position is set to zero
buffer.flip();
while(buffer.hasRemaining()){
char ch = (char) buffer.get();
System.out.print(ch);
}
//position is set to zero and limit is set to capacity to clear the buffer.
buffer.clear();
}
}
}
Produzione
Test Data to Check java NIO Channels Pipe.
Supponendo di avere un file di testo c:/test.txt, che ha il seguente contenuto. Questo file verrà utilizzato come input per il nostro programma di esempio.