11.3 創建UDP服務器 · Python3 CookBook中文版

## 問題你想實現一個基于UDP協議的服務器來與客戶端通信。 ## 解決方案跟TCP一樣，UDP服務器也可以通過使用?`socketserver`?庫很容易的被創建。例如，下面是一個簡單的時間服務器： ~~~ from socketserver import BaseRequestHandler, UDPServer import time class TimeHandler(BaseRequestHandler): def handle(self): print('Got connection from', self.client_address) # Get message and client socket msg, sock = self.request resp = time.ctime() sock.sendto(resp.encode('ascii'), self.client_address) if __name__ == '__main__': serv = UDPServer(('', 20000), TimeHandler) serv.serve_forever() ~~~ 跟之前一樣，你先定義一個實現?`handle()`?特殊方法的類，為客戶端連接服務。這個類的?`request`屬性是一個包含了數據報和底層socket對象的元組。`client_address`?包含了客戶端地址。我們來測試下這個服務器，首先運行它，然后打開另外一個Python進程向服務器發送消息： ~~~ >>> from socket import socket, AF_INET, SOCK_DGRAM >>> s = socket(AF_INET, SOCK_DGRAM) >>> s.sendto(b'', ('localhost', 20000)) 0 >>> s.recvfrom(8192) (b'Wed Aug 15 20:35:08 2012', ('127.0.0.1', 20000)) >>> ~~~ ## 討論一個典型的UPD服務器接收到達的數據報(消息)和客戶端地址。如果服務器需要做應答，它要給客戶端回發一個數據報。對于數據報的傳送，你應該使用socket的?`sendto()`?和?`recvfrom()`?方法。盡管傳統的?`send()`?和?`recv()`?也可以達到同樣的效果，但是前面的兩個方法對于UDP連接而言更普遍。由于沒有底層的連接，UPD服務器相對于TCP服務器來講實現起來更加簡單。不過，UDP天生是不可靠的（因為通信沒有建立連接，消息可能丟失）。因此需要由你自己來決定該怎樣處理丟失消息的情況。這個已經不在本書討論范圍內了，不過通常來說，如果可靠性對于你程序很重要，你需要借助于序列號、重試、超時以及一些其他方法來保證。 UDP通常被用在那些對于可靠傳輸要求不是很高的場合。例如，在實時應用如多媒體流以及游戲領域，無需返回恢復丟失的數據包（程序只需簡單的忽略它并繼續向前運行）。 `UDPServer`?類是單線程的，也就是說一次只能為一個客戶端連接服務。實際使用中，這個無論是對于UDP還是TCP都不是什么大問題。如果你想要并發操作，可以實例化一個?`ForkingUDPServer`?或`ThreadingUDPServer`?對象： ~~~ from socketserver import ThreadingUDPServer if __name__ == '__main__': serv = ThreadingUDPServer(('',20000), TimeHandler) serv.serve_forever() ~~~ 直接使用?`socket`?來是想一個UDP服務器也不難，下面是一個例子： ~~~ from socket import socket, AF_INET, SOCK_DGRAM import time def time_server(address): sock = socket(AF_INET, SOCK_DGRAM) sock.bind(address) while True: msg, addr = sock.recvfrom(8192) print('Got message from', addr) resp = time.ctime() sock.sendto(resp.encode('ascii'), addr) if __name__ == '__main__': time_server(('', 20000)) ~~~