-------------------------------------------------------------------------------------------------------------------------------------
一、UDP协议:OSI七层协议中的传输协议的一种(另外一种tcp协议),他们都是一种端口协议
而且UDP协议传输具有不安全行,或者说是即时性,给对方发送信息时候,只管发,至于他收不收得到都不会去考虑,
不管是服务端还是客户端都一样。
下面来简单实现基于UDP协议的客户端、服务端通信
# 服务端:
import socket
# udp传输的服务端无需半连接池,因为通信无需建立双向连接通道,无需三次握手四次挥手,只要知道对方ip和port就行
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(('127.0.0.1', 8080))
# 通信循环
while True:
data, client_addr = server.recvfrom(1024) # 这里接收用recvfrom
print('收到客户端发来的udp消息%s' % data.decode('utf-8'))
server.sendto(data.upper(), client_addr) # 这里发送用sendto
# 客户端:
import socket
# 无需connect服务端,因为发送时候跟上服务端ip和port就行
client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
while True:
msg = 'hello'
client.sendto(msg.encode('utf-8'), ('127.0.0.1', 8080))
data, server_addr = client.recvfrom(1024)
print(data.decode('utf-8'))
二、UDP协议的一些特点
总结几个UDP协议的特点:
三、利用socketserver模块实现udp协议的并发通信
## 服务端:
import socketserver
from threading import currentThread # 这里导入当前线程方法,得到当前线程名称
class MyUdpHandler(socketserver.BaseRequestHandler):
def handle(self):
# 这里和tcp利用socketserver模块并发的服务端不一样,tcp服务端是直接data = self.request.recv(1024)
data, sock = self.request # 这里多了一个sock,这个sock用于发送,同时self对象本身可以得到client_address
msg = '%s [%s]' % (currentThread().name, data.upper().decode('utf-8'))
sock.sendto(msg.encode('utf-8'), self.client_address)
if __name__ == '__main__':
server = socketserver.ThreadingUDPServer(('127.0.0.1', 8080), MyUdpHandler)
server.serve_forever()
## 客户端
from threading import Thread,currentThread
import time
from socket import *
def task():
client = socket(AF_INET,SOCK_DGRAM)
addr = ('127.0.0.1', 8080)
n = 0
while n < 10: # 模拟让每个客户端与服务端通信循环10次。
msg = '%s [%s]' % (currentThread().name, n)
client.sendto(msg.encode('utf-8'), addr)
data, addr0 = client.recvfrom(1024)
print(data.decode('utf-8'))
n += 1
if __name__ == '__main__':
for i in range(50): # 开启50个客户端线程去连接服务端,模拟并发
t = Thread(target=task)
t.start()