new FileInputStream() blockiert bei fifo (named pipe)

[Wolfram]

Ich versuche, einen Datenstrom in Linux aus einer Fifo zu lesen. Unglücklicherweise blockiert bereits new FileInputStream(), ich würde erwarten, das erst der read() auf dem so erhaltenen InputStream blockiert.

Programm:

import java.io.InputStream;

public class Main {

    public static void main(String[] args) {

        byte[] buffer = new byte[4096];

        java.io.FileInputStream f=null;
        try {
            f = new java.io.FileInputStream("/root/fifo");
        } catch (java.io.FileNotFoundException e) {
            System.out.println(e);
        }

        System.out.println("foo1");

        try {
            f.read(buffer);
        } catch (java.io.IOException e) {
            System.out.println(e);
        }
        System.out.println(buffer);
    }

}

Ausführen:

/root# mkfifo fifo
/root# java Main

das new FileInputStream() darf eigentlich nicht blockieren, aber das foo1 wird erst ausgegeben, wenn ich was in die fifo schreibe.

Hat jemand ne Idee? Einen eigenen InputStream hacken, der new erst aufruft, wenn das erste read() kommt oder so was?

 

[Wolfram]

Drumrumgehackt, einfach einen externen Prozess cat gestartet, cat geht anscheinend besser mit fifos um

public class Main {

    public static void main(String[] args) {

        byte[] buffer = new byte[4096];

        java.lang.Process p = null;

        try {
            p=java.lang.Runtime.getRuntime().exec("cat /root/fifo");
        } catch (java.io.IOException e) {
            System.out.println(e);
        }

        java.io.InputStream f=p.getInputStream();

        System.out.println("foo1");

        try {
            f.read(buffer);
        } catch (java.io.IOException e) {
            System.out.println(e);
        }
        System.out.println(new String(buffer));

        p.destroy();
    }
}

 

[HoaX]

Du Programmierst als Benutzer root? Pfui!

Ansonsten sei dir gesagt dass das Öffnen nur solange hängt bis jemand die Fifo zum Schreiben öffnet.