Comunicacion entre Procesos con Named Pipes

 
Las “Named Pipes” o “Tuberias Nombradas” son el nombre de una tecnica para lograr realizar una comunicacion entre procesos, a esto se le conoce como IPC (Inter Process Communication).  Permite a dos procesos en una misma maquina o de diferentes maquinas conectadas compartir mensajes entre procesos para comunicarse, esto es necesario en ocasiones en sistemas multitarea o multiproceso.

Las principales caracteristicas de una tuberia nombrada son:

• Existen en el sistema como un archivo especial.
• Los procesos de diferentes padres pueden compartir datos.
• Cuando se realizan todas las operaciones permanece en el sistema (a menos que se especifique lo contrario)
• Deben tener un lector y un escritor

Vamos a realizar un ejemplo en el que crearemos 2 sencillos programas en C en el que crearemos una tuberia, uno escribira en ella y otro leera de ella. Se compartira un mensaje de texto que sera mostrado en pantalla a traves de la terminal.

• Clase Escritora

#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>

int main(){
 int t;
 char *tuberia = "/tmp/tuberia";

 /*crea un nuevo archivo fifo especial,
 incluye una ruta y un parametro con una
 mascara de permisos.
 */ mkfifo(tuberia,0666);

 /*
 abrimos una nueva tuberia
 O_RDONLY - Abrir para solo lectura
 O_WRONLY - Abrir para solo escritura
 O_RDWR - Abrir para lectura / escritura
 O_APPEND - Agrega al final del Archivo
 ...
 */ t = open(tuberia,O_WRONLY);
 //escribimos el mensaje que compartiremos
 write(t,"Mensaje entre Procesos",sizeof("Mensaje entre Procesos"));
 //cerramos la tuberia
 close(t);

 //borramos
 unlink(tuberia);

 return 0;
}

Compilamos:
sudo gcc -o writer writer.c

• Clase Lectora

#include <fcntl.h>
#include <stdio.h>
#include <sys/stat.h>
#include <unistd.h>

#define MAX_BUF 1024

int main(){
 int t;
 char *tuberia = "/tmp/tuberia";
 char msj[MAX_BUF];

 //abre la tuberia
 t = open(tuberia,O_RDONLY);
 //lee el mensaje desde la tuberia y lo almacena
 read(t,msj,MAX_BUF);
 //imprime el valor que comparte el otro proceso
 printf("Recibido: %sn",msj);
 //cerramos el tubo
 close(t);

 return 0;
}

Compilamos:
sudo gcc -o reader reader.c

Abrimos 2 terminales y ejectamos el writer en una y el reader en otra.

sudo ./writer
sudo ./reader

y vemos el resultado, al ejecutar writer y despues reader en terminales distintas, aparece el mensaje que colocamos en writer en la terminal donde se ejecuta el programa reader.