本代碼主要實(shí)現(xiàn)的是利用網(wǎng)絡(luò)傳輸圖片，用在我的樹莓派項(xiàng)目之上。該項(xiàng)目在PC上運(yùn)行服務(wù)端，樹莓派上運(yùn)行客戶端，兩者連接到同一局域網(wǎng)中，修改代碼中的IP地址，就可以實(shí)現(xiàn)將樹莓派采集到的圖像數(shù)據(jù)實(shí)時(shí)傳輸?shù)絇C端。先運(yùn)行服務(wù)端代碼，然后運(yùn)行客戶端代碼即可。樹莓派攝像頭使用的是普通的USB攝像頭，并且在樹莓派上安裝了opencv，在樹莓派上安裝opencv的過程可以參考https://www.pyimagesearch.com/2017/09/04/raspbian-stretch-install-opencv-3-python-on-your-raspberry-pi/。最后，該代碼稍加修改就可以傳輸其他的信息，當(dāng)然服務(wù)端，客戶端也可以同時(shí)在PC上運(yùn)行，以驗(yàn)證結(jié)果。所以本質(zhì)還是希望讀者借此代碼可以了解python的socket編程。代碼意義已在注釋中詳細(xì)說明，僅供參考。使用時(shí)請(qǐng)注意修改IP地址和端口號(hào)。

服務(wù)端代碼

import socketimport timeimport cv2import numpy def ReceiveVideo():#IP地址’0.0.0.0’為等待客戶端連接address = (’0.0.0.0’, 8002)#建立socket對(duì)象，參數(shù)意義見https://blog.csdn.net/rebelqsp/article/details/22109925#socket.AF_INET：服務(wù)器之間網(wǎng)絡(luò)通信 #socket.SOCK_STREAM：流式socket , for TCPs = 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是一個(gè)byte類型while count:#接受TCP套接字的數(shù)據(jù)。數(shù)據(jù)以字符串形式返回，count指定要接收的最大數(shù)據(jù)量.newbuf = sock.recv(count)if not newbuf: return Nonebuf += newbufcount -= len(newbuf)return buf#接受TCP連接并返回（conn,address）,其中conn是新的套接字對(duì)象，可以用來接收和發(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 - startfps = 1/seconds;conn.send(bytes(str(int(fps)),encoding=’utf-8’))k = cv2.waitKey(10)&0xffif k == 27:breaks.close()cv2.destroyAllWindows() if __name__ == ’__main__’:ReceiveVideo()

客戶端代碼：

import socketimport cv2import numpyimport time def SendVideo():#建立sock連接#address要連接的服務(wù)器IP地址和端口號(hào)address = (’127.0.0.1’, 8002)try:#建立socket對(duì)象，參數(shù)意義見https://blog.csdn.net/rebelqsp/article/details/22109925#socket.AF_INET：服務(wù)器之間網(wǎng)絡(luò)通信 #socket.SOCK_STREAM：流式socket , for TCPsock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#開啟連接sock.connect(address)except socket.error as msg:print(msg)sys.exit(1) #建立圖像讀取對(duì)象capture = cv2.VideoCapture(0)#讀取一幀圖像，讀取成功:ret=1 frame=讀取到的一幀圖像；讀取失敗:ret=0ret, frame = capture.read()#壓縮參數(shù)，后面cv2.imencode將會(huì)用到，對(duì)于jpeg來說，15代表圖像質(zhì)量，越高代表圖像質(zhì)量越好為 0-100，默認(rèn)95encode_param=[int(cv2.IMWRITE_JPEG_QUALITY),15] while ret:#停止0.1S 防止發(fā)送過快服務(wù)的處理不過來，如果服務(wù)端的處理很多，那么應(yīng)該加大這個(gè)值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() 方法返回一個(gè)原字符串左對(duì)齊,并使用空格填充至指定長度的新字符串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:breaksock.close()if __name__ == ’__main__’:SendVideo()

以上就是python 利用opencv實(shí)現(xiàn)圖像網(wǎng)絡(luò)傳輸?shù)脑敿?xì)內(nèi)容，更多關(guān)于python 圖像網(wǎng)絡(luò)傳輸?shù)馁Y料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章！