El IPC:: PubSub es el módulo Perl para el Interproceso Se publican/Suscriben canales.

SINOPSIS

# Un nuevo ducto de mensaje con el DBM:: parte trasera Profunda
# (Otras partes traseras posibles incluyen Memcached y PlainHash)
mi $bus = IPC:: PubSub-> nuevo (DBM_Deep =>/tmp/pubsub.db);

# Un canal es cualquier cuerda arbitraria
mi $channel = #perl6;

# Registre a un nuevo editor (usted puede publicar a canales múltiples)
mi $pub = $bus-> new_publisher ("#perl6", "#moose");

# Publique un mensaje (puede ser un objeto complejo) a aquellos canales
El $pub-> mensaje ("Esto es un mensaje");

# Registre a un nuevo suscriptor (usted puede suscribirse a canales múltiples)
mi $sub = $bus-> new_subscriber ("#moose");

# Publique un objeto a canales
El $pub-> mensaje ("Esto es otro mensaje");

# Ponga todos los mensajes subsecuentes de este editor expirar en 30 segundos
$pub-> vencimiento (30);
El $pub-> mensaje ("Este mensaje se marchará en 30 segundos");

# Simple póngase: Devuelve los mensajes enviados ya que los anteriores se ponen,
# pero sólo para el primer canal.
mis @msgs = $sub-> se ponen;

# Simple se ponen, con una tecla de canal explícita (debe estar entre estos
# esto al principio se suscribió a)
mis @moose_msgs = $sub-> se ponen ("#moose");

# El complejo se pone: Devuelve una referencia de picadillo de canales para poner en orden
# referencias [de timestamp, mensaje].
mi $hash_ref = $sub-> get_all;

# Cambiando la lista de canales nos suscribimos a
El $sub-> se suscribe ("algún otro canal");
El $sub-> se no suscribe ("algún otro canal");

# Cambiando la lista de canales publicamos a
El $pub-> publica ("algún otro canal");
El $pub-> no publica ("algún otro canal");

# El listado y la comprobación si estamos en un canal
mi @sub_channels = $sub-> canales;
mi @pub_channels = $pub-> canales;
letra "Suscripción está en #moose" si $sub-> canales-> {#moose};
letra "Bar está en #moose" si $pub-> canales-> {#moose};

# APIs de manipulación de cache crudos (no aconsejado; use-> modifican en cambio)
$bus-> cerradura (canal);
El $bus-> abre (canal);
mi @timed_msgs = $bus-> esfuerzo (key1, key2, key3);
$bus-> tienda (tecla, valor, tiempo, 30);

# Actualización atómica de contenido de cache; el $ _ es almacenado atrás en el
# final de la rellamada.
mi $rv = el $bus-> modifica (tecla => la suscripción {borra el $ _-> {foo}});

# La taquigrafía para el $bus-> modifica (tecla => suscripción {$ _ = val});
El $bus-> modifica (tecla => val);

# La taquigrafía para el $bus-> modifica (tecla => suscripción {$ _});
El $bus-> modifica (tecla);

Este módulo proporciona un API simple a publicar mensajes a canales y para suscribirse a ellos.

Cuando un mensaje es publicado en un canal, todos los suscriptores actualmente en aquel canal se pondrán en su siguiente se pone o llamada de get_all.

Actualmente, esto ofrece tres partes traseras: DBM_Deep para el almacenaje en el disco, Memcached para posiblemente multireciben el almacenaje, y PlainHash para el almacenaje de proceso solo.

Por favor ver las pruebas en t/para esta distribución, así como "SINOPSIS" encima, para algunos ejemplos de uso; la documentación detallada todavía no no está disponible.