Не в состоянии читать из именованного канала в Java

Question

Я создаю именованный канал, используя JNI, вызывая команду mkfifo (). Я использую режим = 0666.

Затем я пытаюсь записать в канал с помощью Java, но застрял при записи в канал. Я застреваю на следующей строке и не могу пройти мимо. Я тоже не получаю никакой ошибки.

PrintWriter out = new PrintWriter((new BufferedWriter(new FileWriter(pipePath))));

Пожалуйста, помогите.

С уважением,

-H

PipePeer.java

import java.io.*;*

public class PipePeer {

    private native int createPipe(String pipeName, int mode);* // --------> native method to call mkfifo(pipeName, mode); 
    static {
        System.load("/home/user/workspace/Pipes/libpipe.so");
    }

    public static void main(String[] args) {

        PipePeer p = new PipePeer();
        PipeImplement pi = new PipeImplement();
        String pipePath = "/home/user/workspace/Pipes/pipeFolderpipe1";
        int mode = 0777;
        int createResult = p.createPipe(pipePath, mode);
        if (createResult == 0)
            System.out.println("Named pipe created successfully");
        else
            System.out.println("Error: couldnot create Named pipe");


        String pipeLocation = "/home/user/workspace/Pipes/pipeFolder/pipe1";
        pi.writePipe("From Java", pipeLocation);
        System.out.println(pi.readPipe(pipeLocation));
    }
}

PipeImplement.java

import java.io.*;

public class PipeImplement {

    public BufferedReader in;
    public void writePipe(String strWrite, String pipePath){
        PrintWriter out = null;
        try {
        //-------------> cannot go past this line <--------------------
            out = new PrintWriter((new BufferedWriter(new FileWriter(pipePath))));
        } catch(IOException e) {
            System.out.println("error while writing");
            e.printStackTrace();
        }
        out.println(strWrite);
        System.out.println("writen");
        out.close();
        System.out.println("close");
    }

    public String readPipe(String pipePath) {
        try {
            in = new BufferedReader(new FileReader(pipePath));
        }catch (FileNotFoundException e) {
           e.printStackTrace();
        }
        String lineRead = "";
        try {
            lineRead = in.readLine();
        } catch (IOException e) {
            e.printStackTrace();
        }

        return lineRead;
    }
}

Answer 1

Так работают именованные каналы в * nix. Вы застреваете при открытии трубы. Открытие fifo для записи будет блокироваться, пока кто-то не откроет его для чтения.

Вы будете в тупике, если попытаетесь читать / писать в канал из одного и того же потока синхронно, вам придется либо переключиться на NIO, либо создать один поток, который читает из fifo, и один поток, который пишет в него.