0

我正在运行一个 pub-sub 设置,该设置非常适用于单个发布者和多个订阅者。

但是我现在希望有几个发布者发布到同一个“频道”,当我尝试这个时,我第二次尝试绑定我得到一个地址已经使用的错误。

为什么我不能有第二个出版商?

这适用于大约 250K 消息/秒的高吞吐量应用程序,快速阅读 xPub-xSub 表明中介会增加开销。

   private void BackgroundProcess()
    {
        int msgSeqNum = 0;
        using (var server = new PublisherSocket())
        {
            server.Options.SendHighWatermark = 1000;
            server.Bind(Connection);


            var address = Key;
            string txt;
            while (true)
            {

                if (O.TryTake(out txt, 60000))
                {
                    msgSeqNum++;
                    server.SendMoreFrame(address).SendMoreFrame(msgSeqNum.ToString()).SendMoreFrame(DateTime.UtcNow.ToString("yyyyMMddTHHmmssffffff")).SendFrame("Whatever");
                }

            }

        }
    }
4

1 回答 1

0

Netmq 可以使用一对一的套接字集或一对多的套接字集。您已经接近了,您将需要 xpub xsub 作为代理 netmq 实际上为此提供了一个代理。

https://netmq.readthedocs.io/en/latest/xpub-xsub/

至于为什么,这是底层tcp层的限制,不能将多个tcp监听器绑定到单个端口afaik

于 2018-11-01T17:17:45.387 回答