12、Python-网络编程

1、套接字
1.1 socket模块
套接字是网络编程中的一个基本组件，一般包括服务器端套接字和客户端套接字。

创建服务器端过程如下：

 import socket

 s = socket.socket()

 host = socket.gethostname()

 port = 1234

 try:

     s.bind((host, port))

 except Exception, e:

     print e

     s.close()

 s.listen(5)

 while True:

     c, addr = s.accept()

     print 'Got connection from', addr

     c.send('Thank you for connecting')

 c.close()

创建客户端过程如下：

 import socket, time

 s = socket.socket()

 host = socket.gethostname()

 port = 1234

 s.connect((host, port))

 print s.recv(1024)

 while True:

     command = 'hello\n'

     s.send(command)

 time.sleep(1)

该过程的通讯方式是一问一答的形式，所以又称为阻塞或者同步网络编程。
1.2 SocketServer和它的朋友们
　　SocketServer模块是标准库中很多服务器框架的基础，这些服务器框架包括BaseHTTPServer、SimpleHTTPServer、CGIHTTPServer、SimpleXMLRPCServer和DocXMLRPCServer，所有的这些服务器框架都为基础服务器增加了特定的功能。
　　SocketServer包含4个基本的类：针对TCP套接字流的TCPServer；针对UDP数据报套接字的UDPServer；以及针对性不强的UnixStreamServer和UnixDatagramServer。
　　在使用SocketServer服务器框架时，每当服务器收到一个请求，就会实例化一个请求处理程序，并且它的各种处理方法（handler methods）会在处理请求时被调用。基本的BaseRequestHandler类把所有的操作都放到了处理器的一个叫做handle的方法中，这个方法会被服务器调用。然后在这个方法内就可以访问属性self.request中的客户端套接字。如果使用的是流（TCPServer），那么可以使用StreamRequestHandler类，创建它的两个属性，self.rfile（用于读取）和self.wfile（用于写入）。

 from SocketServer import TCPServer, StreamRequestHandler

 class Handler(StreamRequestHandler):

     def handle(self):

         addr = self.request.getpeername()

         print 'Got connection from', addr

         self.wfile.write('Thank you for connecting')

 server = TCPServer(('', 1234), Handler)

 server.serve_forever()

2、多连接
　　同时可以有多个客户机连接服务端进行请求处理。有3个主要的方法能实现这个目的：分叉（forking）、线程（threading）以及异步I/O（asynchronous I/O）。它们有各自的缺点：分叉占资源，如果有太多的客户端时，分叉不能很好地分叉；线程处理能导致同步问题。
　　什么是分叉：当分叉一个进程（一个运行的程序）时，基本上是复制了它，并且分叉后的两个进程都从当前的执行点继续运行，并且每个进程都有自己的内存副本（比如变量）。一个进程（原来的那个）成为父进程，另一个（复制的）成为子进程。因为分叉的进程是并行运行的，客户端之间不必相互等待。但分叉有点消耗资源（每个分叉出来的进程都需要自己的内存），这就存在了另一个选择：线程。
　　什么是线程：线程是轻量级的进程或子进程，所有的线程都存在于相同的（真正的）进程中，共享内存。资源消耗的下降伴随着一个缺陷：因为线程共享内存，所以必须确保它们的变量不会冲突，或者是在同一时间修改同一内容，这就会造成混乱。
使用SocketServer框架创建分叉或者线程服务器太简单了，几乎不需要解释。注意，Windows不支持分叉。
使用分叉技术的服务器：

 from SocketServer import TCPServer, ForkingMixIn, StreamRequestHandler

 class Server(ForkingMixIn, TCPServer): pass

 class Handler(StreamRequestHandler):

     def handle(self):

         addr = self.request.getpeername()

         print 'Got connection from', addr

         self.wfile.write('Thank you for connecting')

 server = Server(('', 1234), Handler)

 server.serve_forever()

使用线程处理的服务器：

from SocketServer import TCPServer, ThreadingMixIn, StreamRequestHandler

class Server(ThreadingMixIn, TCPServer): pass

class Handler(StreamRequestHandler):

    def handle(self):

        addr = self.request.getpeername()

        print 'Got connection from', addr

        self.wfile.write('Thank you for connecting')

server = Server(('', 1234), Handler)

server.serve_forever()

　　什么是异步I/O：当一个服务器与一个客户端通信时，来自客户端的数据可能是不连续的。如果使用分叉或线程处理，那就不是问题。当一个程序在等待数据，另一个并行的程序可以继续处理它们自己的客户端。另外的处理方法是只处理在给定时间内真正要进行通信的客户端。
　　这是asyncore/asynchat框架采用的方法，这种功能的基础是select函数，如果poll函数可用，那也可以是它，这两个函数都来自select模块。其中poll函数的伸缩性要更好，但只能用在UNIX系统中。
　　Select函数有3个序列作为它的必选参数，还有一个可选的超时时间作为第4个参数。这3个序列是套接字文件描述符，用于输入、输出以及异常情况。如果没有给定超时时间，select会阻塞，处于等待状态，直到一个文件描述符已经为行动做好了准备；如果给定超时时间，select最多阻塞给定的超时时间；如果给定的超时时间是0，select就不阻塞。Select的返回值是3个序列，一个长度为3的元组，每个代表相应参数的一个活动子集。

 import socket, select

 s = socket.socket()

 host = socket.gethostname()

 port = 1234

 s.bind((host, port))

 s.listen(5)

 inputs = [s]

 while True:

     rs, ws, es = select.select(inputs, [], [])

     for r in rs:

         if r is s:

             c, addr = s.accept()

             print 'Got connection from', addr

             inputs.append(c)

         else:

             try:

                 data = r.recv(1024)

                 disconnected = not data

             except socket.error:

                 disconnected = True

             if disconnected:

                 print r.getpeername(), 'disconnected'

                 inputs.remove(r)

             else:

                 print data

　　poll方法使用起来比select简单。在调用poll时，会得到一个poll对象。然后使用poll对象的register方法注册一个文件描述符（或者是带有fileno方法的对象）。注册后可以使用unregister方法移除注册的对象。注册完套接字对象之后可以调用poll方法（带有一个可选的超时时间参数）并得到一个（fd, event）格式列表（可能是空的），其中fd是文件描述符，event则告诉你发生了什么。event对象是一个位掩码，可以使用按位与操作来判断事件的类型.
select模块中的polling事件常量
事件名     　　描述
POLLIN     　　读取来自文件描述符的数据
POLLPRI     　读取来自文件描述符的紧急数据
POLLOUT     　文件描述符已经准备好数据，写入时不会发生阻塞
POLLERR        与文件描述符有关的错误情况
POLLHUP   　　挂起，连接丢失
POLLNVAL 　　无效请求，连接没有打开

 import socket, select

 s = socket.socket()

 host = socket.gethostname()

 port = 1234

 s.bind((host, port))

 fdmap = {s.fileno(): s}

 s.listen(5)

 p = select.poll()

 p.register(s)

 while True:

     events = p.poll()

     for fd, event in events:

         if fdmap[fd] is s:

             c, addr = s.accept()

             print 'Got connection from', addr

             p.register(c)

             fdmap[c.fileno()] = c

         elif event & select.POLLIN:

             data = fdmap[fd].recv(1024)

             if not data: # No data -- connection closed

                 print fdmap[fd].getpeername(), 'disconnected'

                 p.unregister(fd)

                 del fdmap[fd]

             else:

                 print data

巴特西

12、Python-网络编程

最新文章

热门文章