利用Python中SocketServer實作客戶端與伺服器間非阻塞通訊方法介紹

利用SocketServer模組來實現網路用戶端與伺服器並發連接非阻塞通訊

首先，先了解下SocketServer模組中可供使用的類別：

BaseServer：包含伺服器的核心功能與混合（mix-in）類別掛鉤；這個類別只用於派生，所以不會產生這個類別的實例；可以考慮使用TCPServer和UDPServer。
TCPServer/UDPServer：基本的網路同步TCP/UDP伺服器。
UnixStreamServer/ UnixDatagramServer：基本的基於檔案同步TCP/UDP伺服器。
ForkingMixIn/ ThreadingMixIn：實現了核心的進程化或線程化的功能；作為混合類，與伺服器類一併使用以提供一些異步特性；這個類不會直接實例化。
ForkingTCPServer/ ForkingUDPServer：ForkingMixIn和TCPServer/UDPServer的組合。
BaseRequestHandler：包含處理服務請求的核心功能。這個類別只用於派生，所以不會產生這個類別的實例可以考慮使用StreamRequestHandler或DatagramRequestHandler。
StreamRequestHandler/ DatagramRequestHandler：用於TCP/UDP伺服器的服務處理工具。

下面我們正式進入主題，這裡我們採用StreamRequestHandler和ThreadingTCPServer來實作客戶端與伺服器並發連接非阻塞socket。

ThreadingTCPServer衍生自ThreadingMixIn，主要實作核心的進程化合執行緒化功能。

StreamRequestHandler主要用於用於TCP/UDP伺服器的服務處理工具。

一、建立SocketServerTCP服務端

#创建SocketServerTCP服务器：  
import SocketServer  
from SocketServer import StreamRequestHandler as SRH  
from time import ctime  
  
host = 'xxx.xxx.xxx.xxx'  
port = 9999  
addr = (host,port)  
  
class Servers(SRH):  
    def handle(self):  
        print 'got connection from ',self.client_address  
        self.wfile.write('connection %s:%s at %s succeed!' % (host,port,ctime()))  
        while True:  
            data = self.request.recv(1024)  
            if not data:   
                break  
            print data  
            print "RECV from ", self.client_address[0]  
            self.request.send(data)  
print 'server is running....'  
server = SocketServer.ThreadingTCPServer(addr,Servers)  
server.serve_forever()

二、建立SocketServerTCP客戶端

#from socket
from socket import *  
  
host = 'xxx.xxx.xxx.xxx'  
port = 9999  
bufsize = 1024  
addr = (host,port)  
#client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client = socket(AF_INET,SOCK_STREAM)  
client.connect(addr)  
while True:  
    data = raw_input()  
    if not data or data=='exit':  
        break  
    client.send('%s\r\n' % data)  
    data = client.recv(bufsize)  
    if not data:  
        break  
    print data.strip()  
client.close()

以上是利用Python中SocketServer實作客戶端與伺服器間非阻塞通訊方法介紹的詳細內容。更多資訊請關注PHP中文網其他相關文章！