Task3-Create-Live-Video-Streaming-App-using-OpenCV-and-Socket-Programming

server code:

import cv2
import socket
import pickle
import 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 {} “.fornatat(err))

port = 1234
skt.bind((“”,port))
skt.listen()
print(“Socket is listening”)

while True:
session, address = skt.accept()
print(“Connnected 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 code:

using cv2, socket, pickle, struct modules creating client side code

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 {} “.fornatat(err))

port = 1234
server_ip = “192.168.0.104”
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()