快捷導(dǎo)航

實(shí)例講解Python中SocketServer模塊處理網(wǎng)絡(luò)請(qǐng)求的用法

更新時(shí)間：2016年06月28日 15:20:47 作者：cangmean

SocketServer模塊中帶有很多實(shí)現(xiàn)服務(wù)器所能夠用到的socket類和操作方法,下面我們就來(lái)以實(shí)例講解Python中SocketServer模塊處理網(wǎng)絡(luò)請(qǐng)求的用法:

SocketServer創(chuàng)建一個(gè)網(wǎng)絡(luò)服務(wù)框架。它定義了類來(lái)處理TCP,UDP, UNIX streams 和UNIX datagrams上的同步網(wǎng)絡(luò)請(qǐng)求。

一、Server Types

有五個(gè)不同的服務(wù)器類在SocketServer中。

1.BaseServer定義了API, 而且他不是用來(lái)實(shí)例化和直接使用的。
2.TCPServer用作TCP/IP的socket通訊。
3.UDPServer使用datagram sockets。
4.UnixStreamServer和UnixDatagramServer使用Unix-domain sockets而且智能在unix平臺(tái)上使用。

二、Server Objects

構(gòu)建一個(gè)服務(wù)器, 通過(guò)它來(lái)監(jiān)聽(tīng)請(qǐng)求的地址和請(qǐng)求的處理類(not instance)。

1.class SocketServer.BaseServer
這是模塊中所有服務(wù)器對(duì)象的超類，它定義了接口,實(shí)現(xiàn)大多數(shù)都在子類中完成。

2.BaseServer.fileno

返回一個(gè)整數(shù)文件描述符來(lái)表示哪個(gè)服務(wù)器正在監(jiān)聽(tīng)。這個(gè)函數(shù)最常見(jiàn)的傳遞給select.select()，允許監(jiān)控多個(gè)相同處理過(guò)程的服務(wù)。

3.BaseServer.handle_request

處理單一的請(qǐng)求,這個(gè)函數(shù)會(huì)順序調(diào)用接下來(lái)的方法。get_request(),verify_request和proccess_request。
用戶提供handle()方法拋出一個(gè)異常，那么handle_error()方法會(huì)被調(diào)用。
self.timeout的時(shí)間內(nèi)沒(méi)有收到請(qǐng)求，handle_timeout()和handle_request()將返回。

4.BaseServer.serve_forever

BaseServer.serve_forever(poll_interval=0.5)，處理請(qǐng)求一直到明確的shutdown()請(qǐng)求。輪訓(xùn)每隔poll_interval時(shí)間內(nèi)關(guān)閉。忽略self.timeout,如果需要使用定時(shí)任務(wù)，需要使用其他線程。

5.BaseServer.shutdown

告訴serve_forever()循環(huán)停止。

6.BaseServer.RequestHandlerClass

用戶請(qǐng)求處理程序類，為每個(gè)請(qǐng)求創(chuàng)建這個(gè)類的一個(gè)實(shí)例。

三、Implementing a Server

如果你創(chuàng)建一個(gè)服務(wù)器，它通?？梢灾貜?fù)使用現(xiàn)有的類和簡(jiǎn)單的提供一個(gè)自定義請(qǐng)求處理的類。如果不符合需求，有幾種BaseServer方法覆蓋一個(gè)子類。

1.verify_request(reqeust, client_address): 必須返回一個(gè)布爾值，如果返回True,請(qǐng)求將被處理，如果返回False，請(qǐng)求將被拒絕。這個(gè)函數(shù)可以覆蓋來(lái)實(shí)現(xiàn)訪問(wèn)控制服務(wù)。
2.process_request(request, client_address): 調(diào)用finish_request來(lái)創(chuàng)建一個(gè)RequestHandlerClass()的實(shí)例，如果需要該函數(shù)可以創(chuàng)建一個(gè)新的進(jìn)程或協(xié)程來(lái)處理請(qǐng)求。
3.finish_request(request, client_address): 創(chuàng)建一個(gè)請(qǐng)求處理實(shí)例。調(diào)用handle()來(lái)處理請(qǐng)求。

四、Request Handlers

請(qǐng)求處理程序做的大部分工作接收傳入的請(qǐng)求,并決定采取何種行動(dòng)。處理程序負(fù)責(zé)實(shí)現(xiàn)“協(xié)議”上的套接字層(例如,HTTP或xml - rpc)。從傳入的請(qǐng)求處理程序讀取請(qǐng)求數(shù)據(jù)通道,流程,和寫(xiě)一個(gè)響應(yīng)。有三個(gè)方法可以重寫(xiě)。

1.setup(): 準(zhǔn)備請(qǐng)求的請(qǐng)求處理程序, 就是初始化運(yùn)行在handle之前。
2.handle(): 做真正的請(qǐng)求工作。解析傳入的請(qǐng)求，處理數(shù)據(jù)和返回響應(yīng)。
3.finish(): 清理任意時(shí)間創(chuàng)建的setup()。

五、例子

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

1.TCPServer 例子

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 例子

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.異步例子

可以通過(guò)ThreadingMixIn和ForkingMixIn類來(lái)構(gòu)造異步處理程序。

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 實(shí)現(xiàn)客戶端與服務(wù)器間非阻塞通信
（1）創(chuàng)建SocketServerTCP服務(wù)端

#創(chuàng)建SocketServerTCP服務(wù)器： 
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）創(chuàng)建SocketServerTCP客戶端

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()

您可能感興趣的文章: