树莓派/PC实现实时摄像头数据共享（Python—picamera）

上次实验使用Python—OpenCV实现，发现传输效果并不是很理想，接下来使用Python和picamera实现树莓派/PC实时摄像头数据共享，主要也可分为服务器和客户端两部分。

服务器（PC/树莓派）Demo如下：

  1. import numpy as np
  2. import cv2
  3. import socket
  4. class VideoStreamingTest(object):
  5.     def __init__(self, host, port):
  6.  
  7.         self.server_socket = socket.socket()
  8.         self.server_socket.bind((host, port))
  9.         self.server_socket.listen(0)
  10.         self.connection, self.client_address = self.server_socket.accept()
  11.         self.connection = self.connection.makefile('rb')
  12.         self.host_name = socket.gethostname()
  13.         self.host_ip = socket.gethostbyname(self.host_name)
  14.         self.streaming()
  15.  
  16.     def streaming(self):
  17.  
  18.         try:
  19.             print("Host: ", self.host_name + ' ' + self.host_ip)
  20.             print("Connection from: ", self.client_address)
  21.             print("Streaming...")
  22.             print("Press 'q' to exit")
  23.  
  24.             # need bytes here
  25.             stream_bytes = b' '
  26.             while True:
  27.                 stream_bytes += self.connection.read(1024)
  28.                 first = stream_bytes.find(b'\xff\xd8')
  29.                 last = stream_bytes.find(b'\xff\xd9')
  30.                 if first != -1 and last != -1:
  31.                     jpg = stream_bytes[first:last + 2]
  32.                     stream_bytes = stream_bytes[last + 2:]
  33.                     image = cv2.imdecode(np.frombuffer(jpg, dtype=np.uint8), 
  34. cv2.IMREAD_COLOR)
  35.                     cv2.imshow('image', image)
  36.                     if cv2.waitKey(1) & 0xFF == ord('q'):
  37.                         break
  38.         finally:
  39.             self.connection.close()
  40.             self.server_socket.close()
  41.  
  42.  
  43. if __name__ == '__main__':
  44.     # host, port
  45.     h, p = "192.168.0.4", 8000
  46.     VideoStreamingTest(h, p)

客户端（树莓派）Demo如下：

  1. import io
  2. import socket
  3. import struct
  4. import time
  5. import picamera
  6. # create socket and bind host
  7. client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  8. client_socket.connect(('192.168.2.104', 8000))
  9. connection = client_socket.makefile('wb')
  10.  
  11. try:
  12.     with picamera.PiCamera() as camera:
  13.         camera.resolution = (320, 240)      # pi camera resolution
  14.         camera.framerate = 15               # 15 frames/sec
  15.         time.sleep(2)                       # give 2 secs for camera to initilize
  16.         start = time.time()
  17.         stream = io.BytesIO()
  18.         
  19.         # send jpeg format video stream
  20.         for foo in camera.capture_continuous(stream, 'jpeg', use_video_port = True):
  21.             connection.write(struct.pack('<L', stream.tell()))
  22.             connection.flush()
  23.             stream.seek(0)
  24.             connection.write(stream.read())
  25.             if time.time() - start > 600:
  26.                 break
  27.             stream.seek(0)
  28.             stream.truncate()
  29.     connection.write(struct.pack('<L', 0))
  30. finally:
  31.     connection.close()
  32.     client_socket.close()

无论是运行速度还是画质都是比较理想的。

树莓派与PC视频数据传输 最优方法：https://blog.csdn.net/m0_38106923/article/details/86562451

关注公众号，发送关键字：Java车牌识别，获取项目源码。