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套接字状态的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！