ZeroMQ 게시자 소켓 - 예를 들어 게시자 소켓</p> <p>에 새 구독에 이벤트를 발생시킬 수있는 방법이 있다면 가입

Question

궁금 해서요에 이벤트를 발생 : 물론

 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; 

, OnSubscription 아무튼를 실제로 존재하지는 않지만 주위에 어떤 방법이 있는지 궁금해하고있었습니다.

모든 구독을 알기 위해서는 내 서버가 필요합니다. 에 대한 두 가지 방법을 구현하지만

I :

1. 서버의 추가 라우터 소켓을 작성합니다 모든 구독은 게시자 소켓 및 라우터 소켓 (구독 취소뿐만 아니라)에 모두 전송됩니다. 이렇게하면 라우터에서 구독을 폴링 할 수 있습니다.

2. publisher/subscriber를 전혀 사용하지 않는 경우 router/dealer를 통해 모든 pubsub 메커니즘을 만듭니다.

내가 뭐라고 하시겠습니까?

Answer 1

PUB 소켓이 아닌 XPUB를 사용하면 다른 소켓 유형의 일반 메시지처럼 가입 메시지를 수신 할 수 있습니다.