0

HWM 似乎在 clrzmq 2.2.5 中不起作用。这是我的代码

    private static ulong hwm = 50;
    static void testMQ()
    {

        var _Context = new Context(1);

        var pubSock = _Context.Socket(SocketType.PUB); 
        pubSock.HWM = hwm;  
        pubSock.Bind("tcp://*:9999");

        new Thread(testSub).Start(); 
        Thread.Sleep(1000); // client connect

        int i = 0;
        while (true)
        {
            pubSock.Send(i.ToString(), Encoding.ASCII);
            Debug.WriteLine(pubSock.Backlog + "/" + i++);
        }
    }

    static void testSub()
    {
        var _ZmqCtx = new Context(1);

        var subSock = _ZmqCtx.Socket(SocketType.SUB);
        subSock.HWM = 500;
        subSock.Identity = new ASCIIEncoding().GetBytes("bla");
        subSock.Connect("tcp://127.0.0.1:9999");

        Debug.WriteLine("connected");
        subSock.Subscribe("", Encoding.ASCII);
        while (true)
        {
            Debug.WriteLine("r:" + subSock.Recv(Encoding.ASCII));
            Thread.Sleep(10);
        }
    }

输出：

'quickies.vshost.exe' (Managed (v4.0.30319)):      
Loaded 'B:\sdev\MSenseWS\GoogleImporter\bin\Debug\clrzmq.dll', Symbols loaded.
connected
r:0
100/0
100/1
100/2 
[...]
100/13
r:1
100/14
[...] 
100/2988
100/2989
100/2990
100/2991
100/2992
100/2993
100/2994
100/2995
100/2996
r:179
100/2997
100/2998

预期行为： pubSock.Send 在 500 条消息排队后阻塞。经历过的行为：pubSock.Sends 不会阻塞并永远发送，直到抛出内存异常 vom 本机代码 (clrzmq.dll)。

另外：为什么积压总是100？

感谢您的见解，阿明

编辑：推送/轮询套接字达到相同的结果

##

解决方案： - 错误在我这边，因为我期望 HWM 是客户端未提交（接收）的未完成消息的数量。事实上，HWM 是缓冲和排队等待通过网络发送的消息数量。

  • 就我而言，我有一个客户端无法足够快地处理消息，因此分配了缓冲区空间直到内存不足。

  • 为了解决这个问题，我发现在客户端套接字上设置 HWM 和 SWAP 解决了我的问题，因为消息被 zmq 排队到一个大的交换文件中，并被应用程序连续处理。

4

1 回答 1

2

啊，所以我猜你有订阅者线程睡眠，但这并不意味着底层 ZMQ 套接字线程也睡眠。因此，订阅者将继续从发布者队列中取出消息。换句话说，使用Thread.Sleep()可能不是模拟有限网络连接或您期望导致运行到 HWM 的其他问题的好方法。

于 2013-03-19T14:33:46.760 回答