流式传输视频并使用python套接字发送响应

Question

我修改了picamera脚本https://picamera.readthedocs.io/en/latest/recipes2.html#rapid-捕获和流式传输，以便能够将视频从我的树莓流式传输到我的计算机，同时将命令从计算机发送到树莓。

我的客户端代码如下：

while True:
stream.seek(0)
stream.truncate()
camera.capture(stream, 'jpeg', use_video_port=True)
connection.write(struct.pack('<L', stream.tell()))
connection.flush()
stream.seek(0)
connection.write(stream.read())
returnmessage = struct.unpack('<L', connection.read(struct.calcsize('<L')))[0]
print(returnmessage)
if returnmessage:
if returnmessage == 1: 
#do something
else: 
#do something else

和我的服务器代码：

while True:
image_len = struct.unpack('<L', connection.read(struct.calcsize('<L')))[0]
if not image_len:
break
image_stream = io.BytesIO()
image_stream.write(connection.read(image_len))
image_stream.seek(0)
data = np.frombuffer(image_stream.getvalue(), dtype=np.uint8)
image = cv2.imdecode(data, cv2.IMREAD_COLOR)
cv2.imshow('stream',image)
key = cv2.waitKey(1)
if key != -1:
if key == ord("g"):
print("pressed g")
connection.write(struct.pack('<L', 1))
connection.flush()
elif key == ord("h"):
print("pressed a")
connection.write(struct.pack('<L', 2))
connection.flush()
else:
connection.write(struct.pack('<L', 0))
connection.flush()

这是有效的，但感觉不对劲，有时可能会非常滞后。根据流媒体的fps，我不必在每一帧之后发送命令，因此等待响应并不总是必要的，而是会降低流媒体的fps。

我该如何处理这个问题？我应该在每一侧打开另一个线程和另一个套接字来获取响应吗？

Answer 1

您可以将客户端套接字设置为非阻塞。

这样，当您尝试读取时，套接字不会等待来自服务器的命令。如果没有收到命令，connection.read将立即返回。

为此，请调用connection.setblocking(False)。

Answer 2

出于我的目的，我发现在客户端脚本中添加以下内容似乎可以完成的工作

reader, _, _ = select.select([connection], [], [], 0)
if reader: 
returnmessage = struct.unpack('<L', connection.read(struct.calcsize('<L')))[0]

无论如何，谢谢你的回答。