car*_*mst 7 sockets distributed system zeromq
在REQ/REP套接字中,如果套接字向死(断开连接)节点发送请求,则消息不会被传递并停留在占用内存的消息队列中.如何清理这些未传递的消息(比方说,队列中的消息超过1分钟)?
谢谢!
您可能想要设置可选参数ZMQ_LINGER:
ZMQ_LINGER 选项应设置指定套接字的延迟时间。延迟时间决定了在使用 zmq_close(3) 关闭套接字后,尚未发送到对等方的挂起消息应在内存中停留多长时间,并进一步影响使用 zmq_term(3) 终止套接字上下文。
...正值将设置消息在队列中阻塞的最长时间。
请参阅 http://api.zeromq.org/2-1-1:zmq-setsockopt
| 归档时间: |
|
| 查看次数: |
1857 次 |
| 最近记录: |