Минимизируйте отставание в потоковой передаче видео по TCP в python - PullRequest
0 голосов
/ 05 июля 2018

Я провожу исследование, используя Raspberry Pi. Я хочу передать видео с моего raspberry pi (Клиент) на мой ноутбук (Сервер) для моего проекта. После двухдневного исследования я нашел следующий код.

КЛИЕНТ

import socket
import cv2
import pickle
import struct

device = cv2.VideoCapture(-1)
ok, frame = device.read()

host = '192.168.1.4'
port = 12345
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect((host, port))

while True:
    ok, frame = device.read()
    data = pickle.dumps(frame)
    client_socket.sendall(struct.pack("L", len(data)) + data)

    cv2.imshow("",frame)
    if cv2.waitKey(1) == 27:       
        break

device.release()
cv2.destroyAllWindows()

SERVER

import socket
import cv2
import numpy as np
import time
import pickle
import struct

host = '192.168.1.4' 
port = 12345
client_socket = None
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind((host, port))
server_socket.listen(5)

conn, addr = server_socket.accept()
data = b''
payload_size = struct.calcsize("L")

while True:
    while len(data) < payload_size:
        #data += conn.recv(90456)
        data += conn.recv(4096)

    packed_msg_size = data[:payload_size]

    data = data[payload_size:]
    msg_size = struct.unpack("L", packed_msg_size)[0]

    while len(data) < msg_size:
        data += conn.recv(4096)

    frame_data = data[:msg_size]
    data = data[msg_size:]

    frame = pickle.loads(frame_data)
    #print (frame.size)

    cv2.imshow('frame', frame)
    cv2.waitKey(1)

Но есть большое отставание. То, что я хочу, - это прямая трансляция (если возможно) или как можно ближе к прямой трансляции (с минимальной задержкой). Кто-то может предложить UDP, но так как он не гарантирует получение всех кадров.

Может кто-нибудь предложить мне улучшить мой код. Любая помощь?? Заранее большое спасибо !!

...