什么是UDP服务器？

UDP服务器就是实现一个基于UDP协议的服务器来与客户端通信。就是用来收发数据，进行数据处理的。

与TCP服务器不同的是不用建立连接，直接调用recvfrom来收包。

跟TCP服务器一样，UDP服务器也可以通过使用 socketserver 库很容易地被创建。

先定义一个实现 handle() 特殊方法的类，为客户端连接服务。 这个类的 request 属性是一个包含了数据包和底层socket对象的元组。client_address 包含了客户端地址。

1. from socketserver import BaseRequestHandler, UDPServer
2. import time
3. 
   
4. 
   
5. class TimeHandler(BaseRequestHandler):
6. def handle(self):
7. print('Got connection from', self.client_address)
8. message, sock = self.request
9. resp = time.ctime()
10. sock.sendto(resp.encode('ascii'), self.client_address)
11. 
    
12. 
    
13. if __name__ == '__main__':
14. serv = UDPServer(('', 16888), TimeHandler)
15. serv.serve_forever()
16. -----------------------------
17. from socket import socket, AF_INET, SOCK_DGRAM
18. s = socket(AF_INET, SOCK_DGRAM)
19. s.sendto(b'', ('localhost', 16888))
20. print(s.recvfrom(8192))

UDPServer 类是单线程的，一次只能为一个客户端连接服务。 如果想要并发操作，可以实例化一个 ForkingUDPServer 或 ThreadingUDPServer 对象

1. from socketserver import ThreadingUDPServer
2. 
   
3. if __name__ == '__main__':
4. serv = ThreadingUDPServer(('',20000), TimeHandler)
5. serv.serve_forever()

可以直接使用socket

1. from socket import socket, AF_INET, SOCK_DGRAM
2. import time
3. 
   
4. def time_server(address):
5. sock = socket(AF_INET, SOCK_DGRAM)
6. sock.bind(address)
7. while True:
8. msg, addr = sock.recvfrom(8192)
9. print('Got message from', addr)
10. resp = time.ctime()
11. sock.sendto(resp.encode('ascii'), addr)
12. 
    
13. if __name__ == '__main__':
14. time_server(('', 16888))