IPC :: Pubsub IPC :: Pubsub es el módulo PERL para los canales de publicación / suscripción de INTERPROCESS.
Descargar ahora

IPC :: Pubsub Clasificación y resumen

IPC :: Pubsub Etiquetas

Módulo perl publicar introcesamiento Interrocesos Publicar canales

IPC :: Pubsub Descripción

IPC :: Pubsub es el módulo Perl para los canales de publicación / suscripción de interprocess. IPC :: Pubsub es PERL MÓDULO PARA INTERPROCESS Publicar / Suscribir canales.Synopsis # un nuevo bus de mensaje con el DBM :: Deep Backend # (otros posibles backends incluyen Memcached y Pielhash) My $ bus = ipc :: pubsub-> nuevo (dbm_deep => '/tmp/pubsub.db'); # Un canal es cualquier cadena arbitraria mi $ canal = '# perl6'; # Registre un nuevo editor (puede publicar en múltiples canales) My $ pub = $ bus-> new_publisher ("# perl6", "#moose"); # Publicar un mensaje (puede ser un objeto complejo) a los canales $ pub-> MSG ("Este es un mensaje"); # Registrar un nuevo suscriptor (puede suscribirse a múltiples canales) My $ Sub = $ Bus-> New_Subscriber ("# Moose"); # Publique un objeto a canales $ pub-> MSG ("Este es otro mensaje"); # Establecer todos los mensajes posteriores de este editor para caducar en 30 segundos $ pub-> caducidad (30); $ Pub-> MSG ("Este mensaje desaparecerá en 30 segundos"); # Simple GET: Devuelve los mensajes enviados desde la entrada, #, pero solo para el primer canal. mi @msgs = $ sub-> obtener; # Simple Get, con una clave de canal explícita (debe estar entre los # inicialmente suscritos a) mi @MOOSE_MSGS = $ Sub-> Obten ("# Moose"); # Complejo GET: Devuelve una referencia de hash de los canales a la matriz # Referencias de . My $ hash_ref = $ sub-> get_all; # Cambio de la lista de canales Nos suscribimos a $ Sub-> Suscríbase ('Algunos-canal'); $ Sub-> Cancelar la suscripción ('otro de otro canal'); # Cambiando la lista de canales que publicamos en $ pub-> Publicar ('otro de otro canal'); $ pub-> inolvicitud ('otro de otro canal'); # Listando y comprobando si estamos en un canal mis canales @sub_channels = $ sub->; mis canales @pub_channels = $ pub-> Imprimir "Sub está en #moose" si $ Sub-> Canales -> {'# Moose'}; Imprimir "Pub está en #moose" si $ pub-> canales -> {'# Moose'}; # API de manipulación de caché crudo (no aconsejado; uso -> Modificar en su lugar) $ bus-> bloqueo ('canal'); $ bus-> Desbloqueo ('canal'); my @timed_msgs = $ Bus-> Fetch ('Key1', 'Key2', 'Key3'); $ bus-> tienda ('clave', 'valor', hora, 30); # Actualización atómica de contenido de caché; $ _ se almacena de nuevo en el # final de la devolución de llamada. My $ rv = $ bus-> modificar ('clave' => sub {eliminar $ _-> {foo}}); # Shorthand para $ bus-> Modificar ('Clave' => sub {$ _ = 'val'}); $ bus-> modificar ('clave' => 'val'); # Shorthand para $ bus-> modificar ('clave' => sub {$ _}); $ bus-> modificar ('clave'); Este módulo proporciona una API simple para publicar mensajes a los canales y para suscribirlos. Cuando se publica un mensaje en un canal, todos los suscriptores actualmente en ese canal lo obtendrán en su próxima vez. o get_all call.urrently, ofrece tres backends: dbm_deep para almacenamiento en el disco, memcached para un almacenamiento posiblemente multi-host, y Pielhash para el almacenamiento de un solo proceso. Por favor, consulte las pruebas en T / para esta distribución, así como "sinopsis "arriba, para algunos ejemplos de uso; La documentación detallada aún no está disponible. Requisitos: · Perl

IPC :: Pubsub Software relacionado