python3socket非阻塞_利用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服务端
?
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
#创建SocketServerTCP服务器：
import SocketServer
from SocketServerimport StreamRequestHandler as SRH
from timeimport 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客户端
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
[python] view plain copy
from socketimport *
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 dataor 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
总结
以上是生活随笔为你收集整理的python3socket非阻塞_利用Python中SocketServer 实现客户端与服务器间非阻塞通信的全部内容，希望文章能够帮你解决所遇到的问题。
- 上一篇： 逻辑回归代码_Pytorch教程（四）：
- 下一篇： uniapp同步获取用户信息_微信小程序