脚本之家,脚本语言编程技术及教程分享平台!
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

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

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

2020-09-14 13:25myKernel Python

本文主要介绍了利用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 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客户端

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
[python] view plain copy
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()

原文链接:http://blog.csdn.net/cnmilan/article/details/9664823

延伸 · 阅读

精彩推荐