利用Python中SocketServer 实现客户端与服务器间非阻塞通信

利用利用Python中中SocketServer 实现客户端与服务器间非阻塞通实现客户端与服务器间非阻塞通

信信

本文主要介绍了利用Python中SocketServer 实现客户端与服务器间非阻塞通信示例代码，具有很好的参考价

值，需要的朋友一起来看下吧

利用SocketServer模块来实现网络客户端与服务器并发连接非阻塞通信。

首先，先了解下SocketServer模块中可供使用的类：

BaseServer：包含服务器的核心功能与混合（mix-in）类挂钩；这个类只用于派生，所以不会生成这个类的实例；可以考虑使

用TCPServer和UDPServer。

StreamRequestHandler或DatagramRequestHandler。

StreamRequestHandler/ DatagramRequestHandler：用于TCP/UDP服务器的服务处理工具。

下面我们正式进入主题，这里我们采用StreamRequestHandler和ThreadingTCPServer来实现客户端与服务器并发连接非阻塞

socket。

ThreadingTCPServer派生自ThreadingMixIn，主要实现核心的进程化合线程化功能。

StreamRequestHandler主要用于用于TCP/UDP服务器的服务处理工具。

一、创建一、创建SocketServerTCP服务端服务端

[python] view plain copy

#创建SocketServerTCP服务器：

import SocketServer

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)

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