c# - nanomsg を使用してサブスクライバー/パブリッシャーからデータを受信します。

Question

nanomsgに C# データ バインディングを使用しています。URL ipc://report_data でGoogle Protocol Bufferメッセージを送信している外部プログラムがあり、サブスクライバーはまったく同じ URL に接続します。したがって、サブスクライバーがその URL で送信されているデータを取得できると期待していますが、そうではありません。関数 Receive() を使用していますが、何も届きません。その URL から届くメッセージは 1 種類だけなので、このトピックについては気にしません。nanomsg の経験がある人は、トピックに関係なく、トランスポート URL で受信するデータを読み取る方法を知っていますか?

これは私のサブスクライバーと受信メッセージのコードです:

public static void CreateSubscriber(string url, string topic)
{
    Console.WriteLine("\nCreating new subscriber with topic {0} and url {1}.", topic, url);

    var subscriber = new SubscribeSocket();

    subscriber.Connect(url);
    var sw = Stopwatch.StartNew();

    while (sw.Elapsed.TotalSeconds < 5000)
    {
        if (sw.Elapsed.TotalSeconds % 3 == 0)
        {
            Console.WriteLine("Checking for new data.");
            var streamOutput = ReceiveProtoBufferMessage(subscriber, topic);
        }
    }
    sw.Stop();
    Thread.Sleep(1);
    Console.WriteLine("Disposing subscriber.");
    subscriber.Dispose();
}

static byte[] ReceiveProtoBufferMessage(SubscribeSocket s, string topic)
{
    byte[] data = null;

    try
    {
        data = s.Receive();
        Console.WriteLine("Received data.");
    }
    catch
    {
        Console.WriteLine("Couldn't receive data.");
    }

    if (data != null)
    {
        Console.WriteLine("Data is not null.");
    }
    else
    {
        Console.WriteLine("Null data");
    }

    return data;
}