According to the method you provide, HWM was increased, the system(zmq 3.2 version) appeared a new problem when testing. i.e, a node(Node_A) sends more than 2.5 million messages to another node(Node_B). In the initial stage of sending messages, all messages were blocked in Node_A for a long time(20+ seconds). In zmq 2.2 version, the problem is also appeared, but all message was blocked in Node_A for a long time(20+ seconds) in the later stage of sending messages. Can you help me with this problem? Thanks very much!
发件人: [email protected] [mailto:[email protected]] 代表 Pieter Hintjens 发送时间: 2012年12月27日 21:54 收件人: ZeroMQ development list 抄送: Wangtieying; Zhangjun (Jerry) 主题: Re: [zeromq-dev] questions about zmq The blocking probably comes from the receiver not being able to process the messages fast enough, and since you're using PUSH/PULL sockets, when you reach the high-water mark, the sender will block. Solutions: increase HWM, or make recipients faster. On Thu, Dec 27, 2012 at 11:09 AM, Lushuifeng <[email protected]<mailto:[email protected]>> wrote: Hi: I'm using zmq(3.2 version) to do message transmission and distribution currently, however, several problems has encountered me and I’m hoping to get help from you, my question is listed as below: First, in order to accelerate the processing speed of the end of the receiving message, I extended High-speed Subscribers (Black Box Pattern)<http://zguide.zeromq.org/page:all#High-speed-Subscribers-Black-Box-Pattern> as mentioned in the guide documents. 8+ ports have been used and each port receives messages using the the zmq device to forward the message to the PUSH socket. Other at least two separate threads create one PULL socket respectively to handle the forwarded message, However under this mode, following questions occur: when a node sends a message to another one,more than 2.5 million messages will make the node which receives messages blocking for a long time. I would like to ask what is the reason of this phenomenon ? Second, I would like to study zmq code, so I need to run the source code of zmq and print some useful information. First, I try to print information in zmq code while when runing the code, the printing information does not print out as I expected. I would like to ask how to set up the zmq to see the debugging information. See Attach Thanks very much! _______________________________________________ zeromq-dev mailing list [email protected]<mailto:[email protected]> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
<<attachment: zmq问题.JPG>>
_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
