NetMQ: я новичок в. Net и NetMQ. Я работаю над приложением Pub: Sub pattern в. Net - PullRequest
Новая
       29

NetMQ: я новичок в. Net и NetMQ. Я работаю над приложением Pub: Sub pattern в. Net

1 голос
/ 29 февраля 2020

Вот мой код для издателя 

 private void CreateMessages()
    {
        using (var QuotePublishSocket = new PublisherSocket("tcp://192.168.0.9:9011"))
        {
            QuotePublishSocket.Options.SendHighWatermark = 10009;
            QuotePublishSocket.Bind("tcp://*:9011");
            QuotePublishSocket.SendFrame("Hello :" + DateTimeOffset.Now.ToUnixTimeMilliseconds());;

        }
    }

А это мой код для подписчика 

private void CreateSubscriberTread(string portNo) {
        using (var subSocket = new SubscriberSocket())
        {
            subSocket.Options.ReceiveHighWatermark = 1000;
            subSocket.Connect("tcp://192.168.0.9:9011");
            //subSocket.Bind("tcp://*:9011");
            subSocket.Subscribe("");
            Console.WriteLine("Subscriber socket connecting...");
            while (true)
            {
                string messageReceived = subSocket.ReceiveFrameString();
                Console.WriteLine(messageReceived );

            }
        }

    }

Но когда я запускаю издателя и подписчика на том же P C, он работает, и я получать данные от издателя. Но когда я запускаю издателя и подписчика на двух разных p c, я не получу никаких данных. пожалуйста, объясните мне, что я делаю неправильно.

...