本文介绍了Zeromq：重置REQ/REP套接字状态的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
当您使用简单的ZeroMQ REQ/rep模式时，您依赖于固定的end()->recv()/recv()->end()序列。 正如this文章所描述的，当参与者在请求中途断开连接时，您会遇到麻烦，因为这样您就不能重新开始接收来自另一个连接的下一个请求，而状态机会强制您向断开连接的连接发送请求。写完这篇文章后，有没有更好的办法来解决这个问题？
重新连接是解决此问题的唯一方法(除了不使用REQ/REP而使用另一种模式)
推荐答案
好消息是，从ZMQ3.0及更高版本(现代)开始，您可以在套接字上设置超时。正如其他人在其他地方指出的那样，您必须在创建套接字之后、但在连接它之前执行此操作：
zmq_req_socket.setsockopt( zmq.RCVTIMEO, 500 ) # milliseconds
然后，当您实际尝试接收回复时(在向rep套接字发送消息之后)，您可以捕获在超过超时时将断言的错误：
try:
send( message, 0 )
send_failed = False
except zmq.Again:
logging.warning( "Image send failed." )
send_failed = True
然而！当这种情况发生时，正如在其他地方观察到的那样，您的套接字将处于一种奇怪的状态，因为它仍将等待响应。在这一点上，除了重新启动套接字之外，我找不到任何可靠的工作方式。请注意，如果断开套接字的连接()，然后重新连接()，它仍将处于此错误状态。因此，您需要
def reset_my_socket:
zmq_req_socket.close()
zmq_req_socket = zmq_context.socket( zmq.REQ )
zmq_req_socket.setsockopt( zmq.RCVTIMEO, 500 ) # milliseconds
zmq_req_socket.connect( zmq_endpoint )
您还会注意到，因为我关闭了套接字()d套接字，所以接收超时选项"丢失"，因此在新套接字上设置该选项很重要。
我希望这能有所帮助。我希望这不是这个问题的最佳答案。：)
这篇关于Zeromq：重置REQ/REP套接字状态的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！