ZeroMQ Verlag socket - erhöhen Veranstaltung auf Abonnement

Question

ich mich gefragt, ob es einen Weg gibt Ereignisse auf neues Abonnement an einen Verlag Buchse

Zum Beispiel zu erhöhen:

 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; 

Natürlich OnSubscription doesn Es gibt sie wirklich nicht, aber ich habe mich gefragt, ob es einen Weg gibt.

Ich brauche meinen Server, um alle Abonnements zu kennen.

ich aber über zwei Möglichkeiten, es zu implementieren:

1. Erstellen Sie eine zusätzliche Router-Steckdose im Server, alle Abonnements werden beide Buchse an den Verlag gesendet werden und an den Router-Buchse (Abmeldungen als auch). Dadurch kann ich die Abonnements vom Router abfragen.

2. Publisher/Subscriber überhaupt nicht verwenden, alle Pubsub-Mechanismen mit Router/Dealer erstellen.

Was würden Sie mir vorschlagen?

Answer 1

Wenn Sie einen XPUB- anstatt PUB-Socket verwenden, können Sie die Abonnementnachrichten wie normale Nachrichten auf einem anderen Socket-Typ empfangen.