利用SocketServer模塊來(lái)實(shí)現(xiàn)網(wǎng)絡(luò)客戶端與服務(wù)器并發(fā)連接非阻塞通信。
首先，先了解下SocketServer模塊中可供使用的類(lèi)：
BaseServer：包含服務(wù)器的核心功能與混合（mix-in）類(lèi)掛鉤；這個(gè)類(lèi)只用于派生，所以不會(huì)生成這個(gè)類(lèi)的實(shí)例；可以考慮使用TCPServer和UDPServer。
TCPServer/UDPServer：基本的網(wǎng)絡(luò)同步TCP/UDP服務(wù)器。
UnixStreamServer/ UnixDatagramServer：基本的基于文件同步TCP/UDP服務(wù)器。
ForkingMixIn/ ThreadingMixIn：實(shí)現(xiàn)了核心的進(jìn)程化或線程化的功能；作為混合類(lèi)，與服務(wù)器類(lèi)一并使用以提供一些異步特性；這個(gè)類(lèi)不會(huì)直接實(shí)例化。
ForkingTCPServer/ ForkingUDPServer：ForkingMixIn和TCPServer/UDPServer的組合。
BaseRequestHandler：包含處理服務(wù)請(qǐng)求的核心功能。這個(gè)類(lèi)只用于派生，所以不會(huì)生成這個(gè)類(lèi)的實(shí)例可以考慮使用StreamRequestHandler或DatagramRequestHandler。
StreamRequestHandler/ DatagramRequestHandler：用于TCP/UDP服務(wù)器的服務(wù)處理工具。
下面我們正式進(jìn)入主題，這里我們采用StreamRequestHandler和ThreadingTCPServer來(lái)實(shí)現(xiàn)客戶端與服務(wù)器并發(fā)連接非阻塞socket。
ThreadingTCPServer派生自ThreadingMixIn，主要實(shí)現(xiàn)核心的進(jìn)程化合線程化功能。
StreamRequestHandler主要用于用于TCP/UDP服務(wù)器的服務(wù)處理工具。
一、創(chuàng)建SocketServerTCP服務(wù)端
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
[python] view plain copy#創(chuàng)建SocketServerTCP服務(wù)器： import SocketServer from SocketServer import StreamRequestHandler as SRH from time import ctime host = 'xxx.xxx.xxx.xxx'port = 9999addr = (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() |
二、創(chuàng)建SocketServerTCP客戶端
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
[python] view plain copyfrom socket import *host = 'xxx.xxx.xxx.xxx'port = 9999bufsize = 1024addr = (host,port) 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() |
原文鏈接：http://blog.csdn.net/cnmilan/article/details/9664823
