本文实例为大家分享了python使用tcp传输图片数据的具体代码,供大家参考,具体内容如下
数据包格式如下
客户端:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
import socket import sys HOST,PORT = "172.18.0.3" , 19984 def main(): sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.connect((HOST, PORT)) #包头标志 arrBuf = bytearray(b '\xff\xaa\xff\xaa' ) #以二进制方式读取图片 picData = open ( '1.jpg' , 'rb' ) picBytes = picData.read() #图片大小 picSize = len (picBytes) #数据体长度 = guid大小(固定) + 图片大小 datalen = 64 + picSize #组合数据包 arrBuf + = bytearray(datalen.to_bytes( 4 , byteorder = 'little' )) guid = 23458283482894382928948 arrBuf + = bytearray(guid.to_bytes( 64 , byteorder = 'little' )) arrBuf + = picBytes sock.sendall(arrBuf) sock.close() if __name__ = = '__main__' : main() |
服务端:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
import socketserver import os import sys import time import threading ip_port = ( "172.18.0.3" , 19984 ) class MyServer(socketserver.BaseRequestHandler): def handle( self ): print ( "conn is :" , self .request) # conn print ( "addr is :" , self .client_address) # addr while True : try : self . str = self .request.recv( 8 ) data = bytearray( self . str ) headIndex = data.find(b '\xff\xaa\xff\xaa' ) print (headIndex) if headIndex = = 0 : allLen = int .from_bytes(data[headIndex + 4 :headIndex + 8 ], byteorder = 'little' ) print ( "len is " , allLen) curSize = 0 allData = b'' while curSize < allLen: data = self .request.recv( 1024 ) allData + = data curSize + = len (data) print ( "recv data len is " , len (allData)) #接收到的数据,前64字节是guid,后面的是图片数据 arrGuid = allData[ 0 : 64 ] #去除guid末尾的0 tail = arrGuid.find(b '\x00' ) arrGuid = arrGuid[ 0 :tail] strGuid = str ( int .from_bytes(arrGuid, byteorder = 'little' )) #for test print ( "-------------request guid is " , strGuid) imgData = allData[ 64 :] strImgFile = "2.jpg" print ( "img file name is " , strImgFile) #将图片数据保存到本地文件 with open (strImgFile, 'wb' ) as f: f.write(imgData) f.close() break except Exception as e: print (e) break if __name__ = = "__main__" : s = socketserver.ThreadingTCPServer(ip_port, MyServer) print ( "start listen" ) s.serve_forever() |
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://blog.csdn.net/qq_24282081/article/details/106498871