Styjun

I am creating a program that sends a video stream over a socket, and I am using pickle to load/dump my image numpy array. I am sending pictures fast so I can receive frames fast and make a live video from it. When I try this, I get the error _pickle.UnpicklingError: invalid load key, '<'.

I've tried to constantly load the array in pickle (pickle.loads) and use cv2 to open the frame, but after a few frames it gives the error _pickle.UnpicklingError: invalid load key, '<'.

Server.py (The main focus is send_commands())

import os
import time
import socket
import sys
import threading
import cv2
import numpy as np
import pickle

loggedin = 1

all_addresses = []
all_connections = []
def socket_create():
 if loggedin == 0:
 return


 try:
 global host
 global port
 global s
 host = ''
 port = 9999
 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 except socket.error as e:
 print("Socket error > " + str(e))
 return


def socket_bind():
 try:
 global host
 global port
 global s
 host = ''
 print("Socket binding - Port > " + str(port))
 print(host + str(port))
 s.bind((host, int(port)))
 s.listen(1)
 except socket.error as e:
 print("Socket binding - Error > " + str(e))
 time.sleep(3)
 socket_bind()
def accept_connections():
 for c in all_connections:
 c.close()
 del all_connections[:]
 del all_addresses[:]
 while True:
 try:
 conn, address = s.accept()
 conn.setblocking(1)
 all_connections.append(conn)
 all_addresses.append(address)
 print("nC - IP > " + str(address[0]))
 except socket.error as e:
 print("Error: " + str(e))
 time.sleep(3)
 time.sleep(1)
def send_commands():
 print("send")
 time.sleep(2)
 conn = all_connections[0]
 conn.send(str.encode("#Video"))

 while True:
 p = conn.recv(40960000)
 data_arr = pickle.loads(p, fix_imports=True, encoding="bytes")
 frame = cv2.cvtColor(data_arr, cv2.COLOR_RGB2BGR)
 cv2.imshow("frame", frame)
 print("go")
 cv2.waitKey(10)

def go():
 socket_create()
 socket_bind()
 a = threading.Thread(name='background', target=accept_connections)
 a.start()
 send_commands()

go()

Client.py (Main focus is img())

import threading
import time
import os
import sys
import socket
import pyscreenshot
import pickle
import numpy as np
from PIL import ImageGrab

host = "192.168.1.27"
port = 9999





def go():
 global s
 while True:

 try:
 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 s.connect((host, int(port)))
 while True:
 data = s.recv(40960000)
 if data.decode("utf-8") != "#Video":
 return
 while True:
 img()
 print("img")

 except:
 print("Error")
 time.sleep(2)

def img():
 img = ImageGrab.grab()
 img_np = np.array(img)
 data_string = pickle.dumps(img_np)
 s.sendall(data_string)


if __name__ == '__main__':
 go()