python項(xiàng)目中使用opencv如何實(shí)現(xiàn)網(wǎng)絡(luò)傳輸圖像

import socket
import time
import cv2
import numpy
 
def ReceiveVideo():
	#IP地址'0.0.0.0'為等待客戶端連接
	address = ('0.0.0.0', 8002)
	#建立socket對象，參數(shù)意義見https://blog.csdn.net/rebelqsp/article/details/22109925
	#socket.AF_INET：服務(wù)器之間網(wǎng)絡(luò)通信 
	#socket.SOCK_STREAM：流式socket , for TCP
	s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
	#將套接字綁定到地址, 在AF_INET下,以元組（host,port）的形式表示地址.
	s.bind(address)
	#開始監(jiān)聽TCP傳入連接。參數(shù)指定在拒絕連接之前，操作系統(tǒng)可以掛起的最大連接數(shù)量。該值至少為1，大部分應(yīng)用程序設(shè)為5就可以了。
	s.listen(1)
 
	def recvall(sock, count):
		buf = b''#buf是一個byte類型
		while count:
			#接受TCP套接字的數(shù)據(jù)。數(shù)據(jù)以字符串形式返回，count指定要接收的最大數(shù)據(jù)量.
			newbuf = sock.recv(count)
			if not newbuf: return None
			buf += newbuf
			count -= len(newbuf)
		return buf
		
	#接受TCP連接并返回（conn,address）,其中conn是新的套接字對象，可以用來接收和發(fā)送數(shù)據(jù)。addr是連接客戶端的地址。
	#沒有連接則等待有連接
	conn, addr = s.accept()
	print('connect from:'+str(addr))
	while 1:
		start = time.time()#用于計(jì)算幀率信息
		length = recvall(conn,16)#獲得圖片文件的長度,16代表獲取長度
		stringData = recvall(conn, int(length))#根據(jù)獲得的文件長度，獲取圖片文件
		data = numpy.frombuffer(stringData, numpy.uint8)#將獲取到的字符流數(shù)據(jù)轉(zhuǎn)換成1維數(shù)組
		decimg=cv2.imdecode(data,cv2.IMREAD_COLOR)#將數(shù)組解碼成圖像
		cv2.imshow('SERVER',decimg)#顯示圖像
		
		#進(jìn)行下一步處理
		#。
		#。
		#。
 
    #將幀率信息回傳，主要目的是測試可以雙向通信
		end = time.time()
		seconds = end - start
		fps = 1/seconds;
		conn.send(bytes(str(int(fps)),encoding='utf-8'))
		k = cv2.waitKey(10)&0xff
		if k == 27:
			break
	s.close()
	cv2.destroyAllWindows()
 
if __name__ == '__main__':
	ReceiveVideo()

import socket
import cv2
import numpy
import time
 
def SendVideo():
	#建立sock連接
	#address要連接的服務(wù)器IP地址和端口號
	address = ('127.0.0.1', 8002)
	try:
		#建立socket對象，參數(shù)意義見https://blog.csdn.net/rebelqsp/article/details/22109925
		#socket.AF_INET：服務(wù)器之間網(wǎng)絡(luò)通信 
		#socket.SOCK_STREAM：流式socket , for TCP
		sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
		#開啟連接
		sock.connect(address)
	except socket.error as msg:
		print(msg)
		sys.exit(1)
 
	#建立圖像讀取對象
	capture = cv2.VideoCapture(0)
	#讀取一幀圖像，讀取成功:ret=1 frame=讀取到的一幀圖像；讀取失敗:ret=0
	ret, frame = capture.read()
	#壓縮參數(shù)，后面cv2.imencode將會用到，對于jpeg來說，15代表圖像質(zhì)量，越高代表圖像質(zhì)量越好為 0-100，默認(rèn)95
	encode_param=[int(cv2.IMWRITE_JPEG_QUALITY),15]
 
	while ret:
		#停止0.1S 防止發(fā)送過快服務(wù)的處理不過來，如果服務(wù)端的處理很多，那么應(yīng)該加大這個值
		time.sleep(0.01)
		#cv2.imencode將圖片格式轉(zhuǎn)換(編碼)成流數(shù)據(jù)，賦值到內(nèi)存緩存中;主要用于圖像數(shù)據(jù)格式的壓縮，方便網(wǎng)絡(luò)傳輸
		#'.jpg'表示將圖片按照jpg格式編碼。
		result, imgencode = cv2.imencode('.jpg', frame, encode_param)
		#建立矩陣
		data = numpy.array(imgencode)
		#將numpy矩陣轉(zhuǎn)換成字符形式，以便在網(wǎng)絡(luò)中傳輸
		stringData = data.tostring()
		
		#先發(fā)送要發(fā)送的數(shù)據(jù)的長度
		#ljust() 方法返回一個原字符串左對齊,并使用空格填充至指定長度的新字符串
		sock.send(str.encode(str(len(stringData)).ljust(16)));
		#發(fā)送數(shù)據(jù)
		sock.send(stringData);
		#讀取服務(wù)器返回值
		receive = sock.recv(1024)
		if len(receive):print(str(receive,encoding='utf-8'))
		#讀取下一幀圖片
		ret, frame = capture.read()
		if cv2.waitKey(10) == 27:
			break
	sock.close()
	
if __name__ == '__main__':
	SendVideo()