Live Video Streaming using CV2

Server.py

import cv2, pickle, socket, struct
try:     skt = socket.socket(socket.AF_INET, socket.SOCK_STREAM)     print("Socket successfully created ...") except socket.error as err:     print("Socket creation failed with error {}".formatat(err))
port = 1234
skt.bind(("", port))
skt.listen()
print("Socket is listening......")
while True:
    session, address = skt.accept()
    print("Connected to : ",address)
    if session:
        cam = cv2.VideoCapture(0)
        while(cam.isOpened()):
            ret, img = cam.read()
            data = pickle.dumps(img)
            msg = struct.pack("Q", len(data))+data
            session.sendall(msg)
            cv2.imshow("Transmitting video...",img)
            if cv2.waitKey(1) == 13:
                cv2.destroyAllWindows()
                session.close()
                break

Client.py

import cv2, pickle, socket, struct
try:     skt = socket.socket(socket.AF_INET, socket.SOCK_STREAM)     print("Socket successfully created ...") except socket.error as err:     print("Socket creation failed with error {}".formatat(err))
port = 1234
server_ip = "192.168.137.1"
skt.connect((server_ip,port))
data = b""
payload_size = struct.calcsize("Q")
while True:
    while len(data) < payload_size:
        packet = skt.recv(4*1024)
        if not packet: break
        data += packet
    packed_msg_size = data[:payload_size]
    data = data[payload_size:]
    msg_size =  struct.unpack("Q",packed_msg_size)[0]
    
    while len(data) < msg_size:
        data+= skt.recv(4*1024)
    img_data = data[:msg_size]
    data = data[msg_size:]
    img = pickle.loads(img_data)
    cv2.imshow("Receiving video", img)
    if cv2.waitKey(1) == 13:
        cv2.destroyAllWindows()
        break
skt.close()