个人中心
gpt4 book ai didi

实例讲解Python中SocketServer模块处理网络请求的用法

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 29 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章实例讲解Python中SocketServer模块处理网络请求的用法由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

SocketServer创建一个网络服务框架。它定义了类来处理TCP,UDP, UNIX streams 和UNIX datagrams上的同步网络请求.

1、Server Types 。

有五个不同的服务器类在SocketServer中.

1.BaseServer定义了API, 而且他不是用来实例化和直接使用的。 2.TCPServer用作TCP/IP的socket通讯。 3.UDPServer使用datagram sockets。 4.UnixStreamServer和UnixDatagramServer使用Unix-domain sockets而且智能在unix平台上使用.

2、Server Objects 。

构建一个服务器, 通过它来监听请求的地址和请求的处理类(not instance).

1.class SocketServer.BaseServer 这是模块中所有服务器对象的超类，它定义了接口,实现大多数都在子类中完成.

2.BaseServer.fileno 。

返回一个整数文件描述符来表示哪个服务器正在监听。这个函数最常见的传递给select.select()，允许监控多个相同处理过程的服务.

3.BaseServer.handle_request 。

处理单一的请求,这个函数会顺序调用接下来的方法。get_request(),verify_request和proccess_request。 用户提供handle()方法抛出一个异常，那么handle_error()方法会被调用。 self.timeout的时间内没有收到请求，handle_timeout()和handle_request()将返回.

4.BaseServer.serve_forever 。

BaseServer.serve_forever(poll_interval=0.5)，处理请求一直到明确的shutdown()请求。轮训每隔poll_interval时间内关闭。忽略self.timeout,如果需要使用定时任务，需要使用其他线程.

5.BaseServer.shutdown 。

告诉serve_forever()循环停止.

6.BaseServer.RequestHandlerClass 。

用户请求处理程序类，为每个请求创建这个类的一个实例.

3、Implementing a Server 。

如果你创建一个服务器，它通常可以重复使用现有的类和简单的提供一个自定义请求处理的类。如果不符合需求，有几种BaseServer方法覆盖一个子类.

1.verify_request(reqeust, client_address): 必须返回一个布尔值，如果返回True,请求将被处理，如果返回False，请求将被拒绝。这个函数可以覆盖来实现访问控制服务。 2.process_request(request, client_address): 调用finish_request来创建一个RequestHandlerClass()的实例，如果需要该函数可以创建一个新的进程或协程来处理请求。 3.finish_request(request, client_address): 创建一个请求处理实例。调用handle()来处理请求.

4、Request Handlers 。

请求处理程序做的大部分工作接收传入的请求,并决定采取何种行动。处理程序负责实现“协议”上的套接字层(例如,HTTP或xml - rpc)。从传入的请求处理程序读取请求数据通道,流程,和写一个响应。有三个方法可以重写.

1.setup(): 准备请求的请求处理程序, 就是初始化运行在handle之前。 2.handle(): 做真正的请求工作。解析传入的请求，处理数据和返回响应。 3.finish(): 清理任意时间创建的setup().

5、例子 。

下面例子展示了tcp, udp和异步 。

1.TCPServer 例子 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
import SocketServer
 
 
class MyHandler(SocketServer.BaseRequestHandler):
  
   def handle( self ):
     self .data = self .request.recv( 1024 ).strip()
     print '{} wrote:' . format ( self .client_address[ 0 ])
     print self .data
     self .request.sendall( self .data.upper())
 
 
if __name__ = = '__main__' :
   HOST, PORT = 'localhost' , 9999
   server = SocketServer.TCPServer((HOST, PORT), MyHandler)
   server.serve_forever()

2.UDPServr 例子 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import SocketServer
 
 
class MyHandler(SocketServer.BaseRequestHandler):
 
   def handle( self ):
     data = self .request[ 0 ].strip()
     socket = self .request[ 1 ]
     print '{} wrote:' . format ( self .client_address[ 0 ])
     print data
     socket.sendto(data.upper(), self .client_address)
 
 
if __name__ = = '__main__' :
   HOST, PORT = 'localhost' , 9999
   server = SocketServer.UDPServer((HOST, PORT), MyHandler)
   server.serve_forever()

3.异步例子 。

可以通过ThreadingMixIn和ForkingMixIn类来构造异步处理程序.

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
import socket
import threading
import SocketServer
 
 
class MyHandler(SocketServer.BaseRequestHandler):
 
   def handle( self ):
     data = self .request.recv( 1024 )
     curr_thread = threading.current_thread()
     response = '{}: {}' . format (curr_thread.name, data)
     self .request.sendall(response)
 
 
class Server(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
   pass
 
 
def client(ip, port, message):
   sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
   sock.connect((ip, port))
   try :
     sock.sendall(message)
     response = sock.recv( 1024 )
     print 'Received: {}' . format (response)
   finally :
     sock.close()
 
 
if __name__ = = '__main__' :
   HOST, PORT = 'localhost' , 0
 
   server = Server((HOST, PORT), MyHandler)
   ip, port = server.server_address
 
   serer_thread = threading.Thread(target = server.serve_forever)
   server_thread.daemon = True
   server_thread.start()
   print 'Server loop running in thread:' , server_thread.name
 
   client(ip, port, 'Hello World 1' )
   client(ip, port, 'Hello World 2' )
   client(ip, port, 'Hello World 3' )
 
   server.shutdown()
   server.server_close()

4.SocketServer 实现客户端与服务器间非阻塞通信 （1）创建SocketServerTCP服务端 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
#创建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()

（2）创建SocketServerTCP客户端 。

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

最后此篇关于实例讲解Python中SocketServer模块处理网络请求的用法的文章就讲到这里了,如果你想了解更多关于实例讲解Python中SocketServer模块处理网络请求的用法的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

29 4 0
文章推荐： 深入解析Python中的上下文管理器
文章推荐： 详解Python中contextlib上下文管理模块的用法
文章推荐： Python中asyncore异步模块的用法及实现httpclient的实例
文章推荐： python 字典(dict)按键和值排序
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com