Day9 基于TCP的套接字和基于UDP的套接字

时间：2023-03-09 06:46:37
Day9 基于TCP的套接字和基于UDP的套接字 
 服务端：

 ss=socket()    #创建服务器套接字

 ss.bind()        #把地址绑定到套接字

 ss.listen()        #监听套接字,

 inf_loop:          #服务器无限循环

     cs=ss.accept()    接受客户端连接

     comm_loop:        #通讯循环

         cs.recv()/cs.send()     #对话（接收与发送）

     cs.close()    #关闭客户端套接字

 ss.close()        #关闭服务器套接字（可选）

 #客户端
14　cs=socker()　　#创建客户端套接字
15 cs.connet()　　 #尝试连接服务器
16 command_loop:　　#通讯循环
17 　　cs.send()/cs.recv()　　#对话（发送/接收）
18 cs.close()　　 #关闭客户端套接字

这是基于TCP连接的套接字模型。

UDP链接的套接字模型是这样的：

服务端：

ss=socket()    #创建一个服务器的套接字

ss.bind()         #绑定服务器套接字

inf_loop:         #服务器无限循环

    cs=ss.recvfrom()/ss.sendto()     #对话（接收与发送）

ss.cloes()    #关闭服务器套接字

客户端：

cs=socket()    #创建客户端套接字

comm_loop：    #通信循环

    cs.sendto()/cs.recvfrom()   #对话（发送和接收）

cs.close()      #关闭客户套接字

UDP的会话的无关先启动哪一端，先启动服务端或者客户端都不会报错。

而且当客户端发消息的时候，无论服务端收到或者收不到都不会报错；

客户端和服务端收到的消息都分为两部分，

（b"发送的内容"，（"127.0.0.1",4888）） 我们可以利用 data1,client_addr=udp_server.recvfrom(1024)这种方式来收取数据和对方的地址。

 #udp服务端

 from socket import *

 udp_server=socket(AF_INET,SOCK_DGRAM)

 udp_server.bind(('127.0.0.1',8080))

 while True:

     data,client_addr=udp_server.recvfrom(1024)

     print(data,client_addr)

     udp_server.sendto(data.upper(),client_addr)

 #udp   client

 from socket import *

 udp_client=socket(AF_INET,SOCK_DGRAM)

 while True:

     msg=input('>>: ').strip()

     udp_client.sendto(msg.encode('utf-8'),('127.0.0.1',8080))

     data,server_addr=udp_client.recvfrom(1024)

     print(data.decode('utf-8'))

基于TCP的连接，发送数据的时候可能会发生粘包（在数据量比较小，时间间隔比较短的情况下），所以我们要探讨下UDP会不会出现这种情况。

#测试代码：

 #udp    server

 from socket import *

 udp_server=socket(AF_INET,SOCK_DGRAM)

 udp_server.bind(('127.0.0.1',8080))

 data1,client_addr=udp_server.recvfrom(1)

 print('data1',data1)

 data2,client_addr=udp_server.recvfrom(1024)

 print('data2',data2)

 #udp   client

 from socket import *

 udp_client=socket(AF_INET,SOCK_DGRAM)

 udp_client.sendto('hello'.encode('utf-8'),('127.0.0.1',8080))

 udp_client.sendto('world'.encode('utf-8'),('127.0.0.1',8080))

#通过代码测试我们可以清楚的看到，基于UDP的链接不会发生粘包现象

#但是当UDP发送的字节大于服务端（或者客户端）所接收的字节时，会报错。

实现并发的UDP链接：

#服务端

import socketserver

class MyUDPhandler(socketserver.BaseRequestHandler):

    def handle(self):

        print(self.request)   
　　　　　　#(b'aaa', <socket.socket fd=252, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)>)打印出来是这种格式

        　#数据+用来给回消息的socket+地址
　　　　　　self.request[1].sendto(self.request[0].upper(),self.client_address)

if __name__ == '__main__':

    s=socketserver.ThreadingUDPServer(('127.0.0.1',8080),MyUDPhandler)   #UDP的socket服务进程,()内的是地址和端口，后边跟的是自己定义的类

    s.serve_forever()

相关文章