利用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 import *

host = 'xxx.xxx.xxx.xxx'
port = 9999
bufsize = 1024
addr = (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()