hamuchiwa
45 linhas
1.4 KiB
Python
45 linhas
1.4 KiB
Python
__author__ = 'zhengwang'
|
|
|
|
import numpy as np
|
|
import cv2
|
|
import socket
|
|
|
|
|
|
class VideoStreamingTest(object):
|
|
def __init__(self):
|
|
|
|
self.server_socket = socket.socket()
|
|
self.server_socket.bind(('192.168.1.100', 8000))
|
|
self.server_socket.listen(0)
|
|
self.connection, self.client_address = self.server_socket.accept()
|
|
self.connection = self.connection.makefile('rb')
|
|
self.streaming()
|
|
|
|
def streaming(self):
|
|
|
|
try:
|
|
print "Connection from: ", self.client_address
|
|
print "Streaming..."
|
|
print "Press 'q' to exit"
|
|
|
|
stream_bytes = ' '
|
|
while True:
|
|
stream_bytes += self.connection.read(1024)
|
|
first = stream_bytes.find('\xff\xd8')
|
|
last = stream_bytes.find('\xff\xd9')
|
|
if first != -1 and last != -1:
|
|
jpg = stream_bytes[first:last + 2]
|
|
stream_bytes = stream_bytes[last + 2:]
|
|
#image = cv2.imdecode(np.fromstring(jpg, dtype=np.uint8), cv2.CV_LOAD_IMAGE_GRAYSCALE)
|
|
image = cv2.imdecode(np.fromstring(jpg, dtype=np.uint8), cv2.CV_LOAD_IMAGE_UNCHANGED)
|
|
cv2.imshow('image', image)
|
|
|
|
if cv2.waitKey(1) & 0xFF == ord('q'):
|
|
break
|
|
finally:
|
|
self.connection.close()
|
|
self.server_socket.close()
|
|
|
|
if __name__ == '__main__':
|
|
VideoStreamingTest()
|