ZeroMQ socket éditeur - événement lever sur abonnement

Question

Je me demandais s'il y a un moyen de déclencher des événements sur un nouvel abonnement à une prise éditeur

Par exemple:

 PublisherSocket publisher = new PublisherSocket(); 

     publisher.Bind("tcp://*:5555"); 

     NetMQPoller poller = new NetMQPoller { publisher }; 
     poller.RunAsync(); 

     poller.OnSubscription += topic => 
     { 
      AddToPool(topic); 
     }; 

     Task.Factory.StartNew(() => 
     { 
      SubscriberSocket sub = new SubscriberSocket(); 
      sub.Connect("tcp://127.0.0.1:5555"); 

      Thread.Sleep(1000); 
      sub.Subscribe("A"); 
     }, TaskCreationOptions.LongRunning); 

     publisher.ReceiveReady += Publisher_ReceiveReady; 

Bien sûr, OnSubscription doesn Je n'existe pas vraiment, mais je me demandais s'il y avait un moyen de le contourner.

J'ai besoin que mon serveur prenne connaissance de tous les abonnements.

Je pensais environ deux façons de la mettre en œuvre:

1. Créer une prise de routeur supplémentaire sur le serveur, tous les abonnements seront envoyés à la fois à la prise de l'éditeur et à la prise de routeur (désabonnements ainsi). Cela me permettra d'interroger les abonnements du routeur. Ne pas utiliser éditeur/abonné du tout, créer tout le mécanisme pubsub avec routeur/revendeur.

Que me suggérez-vous de faire?

Answer 1

Si vous utilisez un socket XPUB plutôt que PUB, vous pouvez recevoir les messages d'abonnement comme vous le feriez pour les messages standard sur tout autre type de socket.