利用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 实现客户端与服务器间非阻塞通信的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。