8-2udp和tcp网络编程以及粘包和解决粘包的方法

一 tcp网络编程

 server 端

 import socket

 sk=socket.socket()  #实例化一个对象

 sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)#端口可以重用

 sk.bind(('127.0.0.1',9100))

 sk.listen()#监听

 while True:

     conn,addr=sk.accept() #阻塞，三次握手完毕

     while True:

         inp=input('请输入你要发送的消息：')

         conn.send(inp.encode('utf-8'))

         if inp == 'q': break

         ret=conn.recv(1024).decode('utf-8')

         if ret == 'q': break

         print(ret)

     conn.close()

 sk.close()

  client端
 1 import socket

 sk=socket.socket()

 #while True:

 sk.connect(('127.0.0.1',9100))

 while True:

     ret=(sk.recv(1024).decode('utf-8'))

     if ret == 'q': break

     print(ret)

     inp=input('请输入你要发送的消息：')

     sk.send(inp.encode('utf-8'))

     if inp == 'q': break

 sk.close()

二 tcp粘包

1 发送方的缓存机制

发送数据时间间隔很短，数据了很小，会合到一起，产生粘包

 服务端

 #_*_coding:utf-8_*_

 from socket import *

 ip_port=('127.0.0.1',8080)

 tcp_socket_server=socket(AF_INET,SOCK_STREAM)

 tcp_socket_server.bind(ip_port)

 tcp_socket_server.listen(5)

 conn,addr=tcp_socket_server.accept()

 data1=conn.recv(10)

 data2=conn.recv(10)

 print('----->',data1.decode('utf-8'))

 print('----->',data2.decode('utf-8'))

 conn.close()

 服务端

服务端

 #_*_coding:utf-8_*_

 import socket

 BUFSIZE=1024

 ip_port=('127.0.0.1',8080)

 s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)

 res=s.connect_ex(ip_port)

 s.send('hello'.encode('utf-8'))

 s.send('egg'.encode('utf-8'))

客户端

2接收方的缓存机制

客户端发送了一段数据，服务端只收了一小部分，服务端下次再收的时候还是从缓冲区拿上次遗留的数据，产生粘包）

 #_*_coding:utf-8_*_

 from socket import *

 ip_port=('127.0.0.1',8080)

 tcp_socket_server=socket(AF_INET,SOCK_STREAM)

 tcp_socket_server.bind(ip_port)

 tcp_socket_server.listen(5)

 conn,addr=tcp_socket_server.accept()

 data1=conn.recv(2) #一次没有收完整

 data2=conn.recv(10)#下次收的时候,会先取旧的数据,然后取新的

 print('----->',data1.decode('utf-8'))

 print('----->',data2.decode('utf-8'))

 conn.close()

服务端

 #_*_coding:utf-8_*_

 import socket

 BUFSIZE=1024

 ip_port=('127.0.0.1',8080)

 s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)

 res=s.connect_ex(ip_port)

 s.send('hello egg'.encode('utf-8'))

客户端

三解决粘包问题

 import socket

 import struct

 sk=socket.socket()

 sk.bind(('127.0.0.1',8090))

 sk.listen()

 conn,addr=sk.accept()

 inp=input('>>>:').encode('utf-8')

 inp_len=len(inp)#计算用户输入的长度

 bytes_msg=struct.pack('i',inp_len)#将数字转换成固定的bytes

 conn.send(bytes_msg) #先发送报头的长度4个bytes

 conn.send(inp)#在发送报头的字节格式

 conn.send(b'alex sb')#最后发送真实内容的字节格式

 conn.close()

 sk.close()

服务端

 import socket

 import struct

 sk=socket.socket()

 sk.connect(('127.0.0.1',8090))

 num=sk.recv(4) #先接受bytes的长度

 num=struct.unpack('i',num)[0]#提取报文的长度

 print(sk.recv(num).decode('utf-8'))

 print(sk.recv(10))

 sk.close()

客户端

四 udp

 udp server端

 import socket

 sk=socket.socket(type=socket.SOCK_DGRAM)

 sk.bind(('127.0.0.1',8899))

 while True:

     msg,addr=sk.recvfrom(1024)

     print(msg.decode('utf-8'),addr)

     inp=input('>>>:')

     if inp=='q':break

     sk.sendto(inp.encode('utf-8'),addr)

     #print(msg)

 sk.close()

 udp client

 import socket

 sk=socket.socket(type=socket.SOCK_DGRAM)

 sk.bind(('127.0.0.1',8899))

 while True:

     msg,addr=sk.recvfrom(1024)

     print(msg.decode('utf-8'),addr)

     inp=input('>>>:')

     if inp=='q':break

     sk.sendto(inp.encode('utf-8'),addr)

     #print(msg)

 sk.close()

巴特西

8-2udp和tcp网络编程以及粘包和解决粘包的方法

最新文章

热门文章