|
|
@@ -41,13 +41,13 @@ class SmartShooter(metaclass=SingletonType):
|
|
|
json_msg = json.loads(str_msg)
|
|
|
return json_msg
|
|
|
|
|
|
- def __create_req(self) -> tuple[zmq.Socket, zmq.Context]:
|
|
|
+ def __create_req(self,time_out=5) -> tuple[zmq.Socket, zmq.Context]:
|
|
|
context = zmq.Context()
|
|
|
req_socket = context.socket(zmq.REQ)
|
|
|
# 设置发送超时为 5000 毫秒（5 秒）
|
|
|
- req_socket.setsockopt(zmq.RCVTIMEO, 4000)
|
|
|
+ req_socket.setsockopt(zmq.RCVTIMEO, time_out * 1000)
|
|
|
# 设置接收超时为 5000 毫秒（5 秒）
|
|
|
- req_socket.setsockopt(zmq.SNDTIMEO, 4000)
|
|
|
+ req_socket.setsockopt(zmq.SNDTIMEO, time_out * 1000)
|
|
|
req_socket.setsockopt(zmq.LINGER, 0) # 设置为 0 表示不等待未完成的操作
|
|
|
req_socket.connect(self.SET_REQ)
|
|
|
return req_socket, context
|
|
|
@@ -70,8 +70,8 @@ class SmartShooter(metaclass=SingletonType):
|
|
|
"""
|
|
|
实时获取相机信息，是否连接、软件是否被打开
|
|
|
"""
|
|
|
+ socket, context = self.__create_req(time_out=2)
|
|
|
try:
|
|
|
- socket, context = self.__create_req()
|
|
|
req = {}
|
|
|
req["msg_type"] = "Request"
|
|
|
req["msg_id"] = "GetCamera"
|
rambo