python写一个app接收摄像头传输的视频_如何使用Python中的tcp套接字发送和接收网络摄像头流？...

我正在尝试重新创建this project。我有一台服务器(我的电脑)和一台客户机(我的树莓皮)。我所做的与最初的项目不同的是&＃xff0c;我尝试使用一个简单的网络摄像头而不是一个覆盆子pi相机将图像从我的rpi传输到服务器。我知道我必须&＃xff1a;从相机获取opencv图像帧。在

将帧(numpy数组)转换为字节。在

将字节从客户端传输到服务器。在

将字节转换回帧和视图。在

请举例说明。在

自我_驱动程序.pyimport SocketServer

import threading

import numpy as np

import cv2

import sys

ultrasonic_data &＃61; None

#BaseRequestHandler is used to process incoming requests

class UltrasonicHandler(SocketServer.BaseRequestHandler):

data &＃61; " "

def handle(self):

while self.data:

self.data &＃61; self.request.recv(1024)

ultrasonic_data &＃61; float(self.data.split(&＃39;.&＃39;)[0])

print(ultrasonic_data)

#VideoStreamHandler uses streams which are file-like objects for communication

class VideoStreamHandler(SocketServer.StreamRequestHandler):

def handle(self):

stream_bytes &＃61; b&＃39;&＃39;

try:

stream_bytes &＃43;&＃61; self.rfile.read(1024)

image &＃61; np.frombuffer(stream_bytes, dtype&＃61;"B")

print(image.shape)

cv2.imshow(&＃39;F&＃39;, image)

cv2.waitKey(0)

finally:

cv2.destroyAllWindows()

sys.exit()

class Self_Driver_Server:

def __init__(self, host, portUS, portCam):

self.host &＃61; host

self.portUS &＃61; portUS

self.portCam &＃61; portCam

def startUltrasonicServer(self):

# Create the Ultrasonic server, binding to localhost on port 50001

server &＃61; SocketServer.TCPServer((self.host, self.portUS), UltrasonicHandler)

server.serve_forever()

def startVideoServer(self):

# Create the video server, binding to localhost on port 50002

server &＃61; SocketServer.TCPServer((self.host, self.portCam), VideoStreamHandler)

server.serve_forever()

def start(self):

ultrasonic_thread &＃61; threading.Thread(target&＃61;self.startUltrasonicServer)

ultrasonic_thread.daemon &＃61; True

ultrasonic_thread.start()

self.startVideoServer()

if __name__ &＃61;&＃61; "__main__":

#From SocketServer documentation

HOST, PORTUS, PORTCAM &＃61; &＃39;192.168.0.18&＃39;, 50001, 50002

sdc &＃61; Self_Driver_Server(HOST, PORTUS, PORTCAM)

sdc.start()

视频_客户端.py

^{pr2}$