Impossible de lire le tube nommé en Java

Question

Je crée un canal nommé en utilisant JNI en appelant la commande mkfifo(). J'utilise le mode = 0666.

J'essaye alors d'écrire dans le tuyau en utilisant Java, mais je suis bloqué en écrivant dans le tuyau. Je suis bloqué à la ligne suivante et je ne peux pas la dépasser. Je ne reçois aucune erreur non plus.

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

Veuillez nous aider.

Cordialement,

-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

Voilà comment les pipes nommés sur le travail * nix. Vous êtes coincé à l'ouverture du tuyau. Ouvrir un fifo pour l'écriture bloquera jusqu'à ce que quelqu'un l'ouvre pour la lecture. Vous aurez un blocage si vous essayez de lire/écrire sur le canal à partir du même thread de façon synchrone, vous devrez soit basculer vers NIO, ou créer un thread qui lit à partir du fifo et un thread qui lui écrit .