¿Cómo veo un STDOUT de un programa en ejecución de un programa perl que lo llamó?

Question

Estamos tratando de averiguar cómo ejecutar una aplicación java desde un script de Perl, pero aún así poder leer periódicamente desde el STDOUT de la aplicación java.

print "running dcmrcv.bat\n"; 

open my $fh_dcmrcv, "-|", 'z:\apps\dcm4che\dcm4che-2.0.26\bin\dcmrcv.bat \ 
    DCMRCV:11112 -dest z:\dcmrcv -journal z:\dcmrcv', 
    or die "could not execute dcmrcv: $!"; 

print "dcmrcv.bat started\n"; 

queríamos ser capaz de leer desde el gestor de archivo, $ fh_dmcrcv, cada pocos minutos o tal vez mediante la creación de un AnyEvent io gatillo cuando hay actividad en el gestor de archivo.

Sin embargo, cuando intento leer desde el gestor de archivo, se bloquea si uso algo como esto:

foreach my $line (<$fh_dmcrcv>) { 
    print $line; 
} 

Hemos intentado varios enfoques, no creo que podamos utilizar Archivo :: cola, ya que parece que el módulo necesita un archivo real. El problema parece ser que $ fh_dcmrcv nos bloquea cuando leemos, no estamos seguros del enfoque correcto sobre cómo lograr lo que queremos.

editar # salida 1

Cuando ejecutamos nuestro script Perl que estamos viendo como esto:

Z:\projects\demo_2>process_files.pl 
running dcmrcv.bat 
dcmrcv.bat started 
Start Server listening on port 11112 
11:55:13,495 INFO - Start listening on 0.0.0.0/0.0.0.0:11112 

El guión, process_files.pl está emitiendo los mens .:

running dcmrcv.bat 
dcmrcv.bat started 

Los mensajes. desde el programa Java son: Iniciar servidor escucha en el puerto 11112 11: 55: 13.495 INFO - empezar a escuchar en 0.0.0.0/0.0.0.0:11112

En este caso estamos haciendo eco de aquellos que por el simple hecho de esta pregunta, realmente queremos analizar periódicamente ciertos mensajes. y nunca hacer eco de ninguno de ellos.

Cualquier idea es apreciado,

-Sam

Answer 1

La mayoría de los sistemas admiten una función de 0 argumentos select (también empaquetada muy bien en IO::Select) que le puede indicar si hay entrada esperando en sockethandle o pipehandle.En Windows, select es compatible únicamente con tomas de corriente, lo que conduce a esta solución bizantino:

1. Crear un par de sockets
2. Tenedor y ejecutar el comando en un proceso hijo
3. en el proceso hijo, recuperar la salida de comandos y escribir a la toma de
4. en el padre, utilizar y seleccione las operaciones de lectura en el zócalo según se desee

Ejemplo:

use Socket; 
use IO::Select; 
use Time::HiRes; 
$cmd = $^X . ' -MMath::BigInt -e "$_=1; ' 
     . 'print qq/$_!=/,Math::BigInt->new($_)->bfac(),qq/\n\n\n/' 
     . ' for 4000..4100"'; 
socketpair A,B,AF_UNIX,SOCK_STREAM,PF_UNSPEC; # step 1 
if (fork() == 0) { 
    open my $fh, '-|', $cmd;     # step 2 
    while (<$fh>) { 
     print B;        # step 3 
    } 
    close $fh; 
    exit $? >> 8; 
} 
$s = IO::Select->new(); 
$s->add(\*A); 
for (;;) { 
    if ($s->can_read(0.25)) {     # step 4 
     $line = <A>; 
     print "Do something with command output: $line"; 
    } else { 
     print "No output now. Could be doing something else ...\n"; 
     Time::HiRes::sleep(0.25); 
    } 
} 

¿Está seguro de que no quiere simplemente escribir su salida de comando en un archivo temporal?

Answer 2

tratar de leer con este lugar:

while (my $line = <$fh_dmcrcv>) { 
    print $line; 
} 

respecto

Answer 3

Uso IO::Select o cuatro argumento select() de leer cuando la lectura no lo hará bloquear. EDITAR: No importa, usted es on Windows, por lo que esto no funcionará. Una opción: haga que se lea un proceso intermedio de este conducto y mantenga un archivo intermediario rellenado con la longitud de cola que necesite. Bleh.

Dicho esto, la mejor manera de leer "cada pocos minutos" de una tubería es leer cada pocos segundos.