利用Python中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 = &＃39;xxx.xxx.xxx.xxx&＃39;  
port = 9999  
addr = (host,port)  
  
class Servers(SRH):  
    def handle(self):  
        print &＃39;got connection from &＃39;,self.client_address  
        self.wfile.write(&＃39;connection %s:%s at %s succeed!&＃39; % (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 &＃39;server is running....&＃39;  
server = SocketServer.ThreadingTCPServer(addr,Servers)  
server.serve_forever()

二、创建SocketServerTCP客户端

#from socket
from socket import *  
  
host = &＃39;xxx.xxx.xxx.xxx&＃39;  
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==&＃39;exit&＃39;:  
        break  
    client.send(&＃39;%s\r\n&＃39; % data)  
    data = client.recv(bufsize)  
    if not data:  
        break  
    print data.strip()  
client.close()

以上就是利用Python中SocketServer实现客户端与服务器间非阻塞通信方法介绍的详细内容，更多请关注 第一PHP社区 其它相关文章！