python粘包问题及socket套接字编程详解
粘包问题
TCP协议在传输过程中会出现数据粘包问题
讲一下TCP和UDP的区别,都是传数据的协议,没有好坏之说,只是不同的应用需求可能会更好选择哪一个协议
TCP:适合传输数量大,需要建立连接,会出现粘包问题,粘包问题可以解决,确定传入的长度,接收同样长度就可以保证一次性传输完
UDP:适合传输数据量小,没有粘包,不需要连接,一次性传输,下一次就是新的数据,弊端就是数据丢失,不安全
QQ是用什么协议呢?按理应该可以用UDP协议,但是实际用的是TCP协议,这是历史遗留问题,可还记得我们输入QQ一次性输入的内容字数有限制吗?就是规定了发送与接收的数据长度是一样的.
形成粘包的原因
1.两个数据非常小,然后间隔时间又短
2.数据太大,一次取不完,下一次还会取这个大数据
解决粘包问题
==在传数据之前,传一个数据的大小,数据的大小必须得定长==
#TCP解决粘包问题附带处理了一下
importsocket
importstruct
importsubprocess
server=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind(('127.0.0.1',8000))
server.listen(5)
print('start...')
#连接循环
whileTrue:
conn,client_address=server.accept()
print(client_address)
#通信循环
whileTrue:
try:
cmd=conn.recv(1024)
print(cmd)
pipeline=subprocess.Popen(cmd.decode('utf8'),
shell=True,
stderr=subprocess.PIPE,
stdout=subprocess.PIPE)
stdout=pipeline.stdout.read()
stderr=pipeline.stderr.read()
count_len=len(stdout)+len(stderr)
guding_bytes=struct.pack('i',count_len)
conn.send(guding_bytes)#4
conn.send(stderr+stdout)
exceptConnectionResetError:#连接循环时出现的中断
break
conn.close()
#客户端
mportstruct
fromsocketimport*
client=socket(AF_INET,SOCK_STREAM)
client.connect(('127.0.0.1',8000))
whileTrue:
#cmd=input('pleaseenteryourcmdyouwant:')
cmd='dir'
client.send(cmd.encode('utf8'))
guding_bytes=client.recv(4)
count_len=struct.unpack('i',guding_bytes)[0]
data=client.recv(count_len)
print(data.decode('gbk'))
基于UDP协议的socket套接字编程
UDP无连接
#UDP服务端
importsocket
server=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
server.bind(('127.0.0.1',8000))
print('start...')
whileTrue:
data,client_addr=server.recvfrom(1024)
print(client_addr)
print(data)
server.sendto(data.upper(),client_addr)
#UDP客户端
importsocket
client=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
whileTrue:
msg=input('pleaseenteryourmsg:')
client.sendto(msg.encode('utf8'),('127.0.0.1',8000))
data=client.recvfrom(1024)
print(data)
和TCP是差不多的,调用的功能是一样的,只是方法名的具体表示方法不一样,因为UDP无连接,UDP的sendto和TCP的send,就是UDP的sendto要直接指到地址的
基于socketserver实现并发的socket套接字编程
让服务端同时和多个客户端进行连接,以前我们写的是一个警局有五部电话只有一个人,现在写的五部电话五个人
#同一时刻有多个人在接听
importsocketserver
importsubprocess
importstruct
classMyHandler(socketserver.BaseRequestHandler):
#通信循环
defhandle(self):
whileTrue:
try:
cmd=self.request.recv(1024)
print(cmd)
pipeline=subprocess.Popen(cmd.decode('utf8'),
shell=True,
stderr=subprocess.PIPE,
stdout=subprocess.PIPE)
stdout=pipeline.stdout.read()
stderr=pipeline.stderr.read()
count_len=len(stderr)+len(stdout)
guding_bytes=struct.pack('i',count_len)
self.request.send(guding_bytes)#4
self.request.send(stderr+stdout)
exceptConnectionResetError:
break
#使用socketserver的连接循环(并发),但是使用了自己的通信循环
#myhandler=MyHandler()
if__name__=='__main__':
server=socketserver.ThreadingTCPServer(('127.0.0.1',8000),MyHandler,bind_and_activate=True)
print('start...')
server.serve_forever()
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。