IPC : : PubSub est module de Perl pour interprocessus publient/souscrivent des glissières.

SYNTHÈSE

# bus neuf de message d'A avec le DBM : : Profonde partie postérieure
# (l'autre possible centralise comprend Memcached et PlainHash)
mon $bus = IPC : : PubSub->new (=> /tmp/pubsub.db de DBM_Deep) ;

# la glissière d'A est n'importe quelle chaîne de caractères arbitraire
mon $channel = #perl6 ;

# registre un éditeur neuf (vous pouvez publier aux glissières multiples)
mon $pub = $bus->new_publisher (« #perl6 », « #moose ») ;

# publier un message (peut être un objectif complexe) à ces glissières
$pub->msg (« c'est un message ») ;

# registre un abonné neuf (vous pouvez souscrire aux glissières multiples)
mon $sub = $bus->new_subscriber (« #moose ») ;

# publier un objectif aux glissières
$pub->msg (« c'est un autre message ») ;

# régler tous les messages suivants de cet éditeur pour expirer en 30 secondes
$pub->expiry (30) ;
$pub->msg (« ce message entrera loin en 30 secondes ») ;

# simple obtenir : Renvoie les messages envoyés puisque les précédents obtiennent,
# mais seulement pour la première glissière.
mes @msgs = $sub->get ;

# simple obtenir, avec une clavette expressément de glissière (doit être parmi celle
# elle a au commencement souscrit à)
mes @moose_msgs = $sub->get (« #moose ») ;

# le composé obtiennent : Renvoie une référence d'informations parasites des glissières au choix
# références de [horodateur, message].
mon $hash_ref = $sub->get_all ;

# changeant la liste de glissières que nous souscrivons à
$sub->subscribe (quelque-autre-glissière) ;
$sub->unsubscribe (quelque-autre-glissière) ;

# changeant la liste de glissières que nous publions à
$pub->publish (quelque-autre-glissière) ;
$pub->unpublish (quelque-autre-glissière) ;

# liste et vérifier si nous sommes dans une glissière
mes @sub_channels = $sub->channels ;
mes @pub_channels = $pub->channels ;
l'impression « sous-marin est dans le #moose » si $sub->channels-> {#moose} ;
l'impression « Pub est dans le #moose » si $pub->channels-> {#moose} ;

# api crus de manipulation de cache (non informés ; utilisation - >modify au lieu)
$bus->lock (glissière) ;
$bus->unlock (glissière) ;
mes @timed_msgs = $bus->fetch (key1, key2, key3) ;
$bus->store (clavette, valeur, temps, 30) ;

# mise à jour atomique du contenu de cache ; $ de _ est enregistré en arrière sur
# fin du rappel de service.
mon $rv = $bus->modify (sous-marin principal de => {effacement $_-> {foo}}) ;

# sténographie pour $bus->modify (sous-marin principal de => {_ de $ = val}) ;
$bus->modify (=> principal val) ;

# sténographie pour $bus->modify (sous-marin principal de => {_ de $}) ;
$bus->modify (clavette) ;

Ce module fournit un api simple pour les messages publiants aux glissières et pour souscrire à elles.

Quand un message est publié sur une glissière, tous les abonnés actuel dans cette glissière l'obtiendront sur leur prochain obtiennent ou l'appel de get_all.

Actuel, il offre trois centralise : DBM_Deep pour le stockage de sur-disque, Memcached pour probablement le stockage de multi-serveur, et PlainHash pour le stockage d'unique-procédé.

Veuillez voir les tests dans le t pour cette distribution, aussi bien que la « SYNTHÈSE » ci-dessus, pour quelques exemples d'usage ; la documentation détaillée n'est pas encore procurable.