python之高性能网络编程并发框架eventlet实例

http://blog.csdn.net/mingzznet/article/details/38388299

前言：

虽然 eventlet 封装成了非常类似标准线程库的形式，但线程和eventlet在实际并发执行流程仍然有明显区别。在没有出现 I/O 阻塞时，除非显式声明，否则当前正在执行的 eventlet 永远不会把 cpu 交给其他的 eventlet，而标准线程则是无论是否出现阻塞，总是由所有线程一起争夺运行资源。所有 eventlet 对 I/O 阻塞无关的大运算量耗时操作基本没有什么帮助。

 

Eventlet 的基础是 greenlet,这是实现 "协程(Coroutine)" 的基础.协程又被称作 "微线程“,简单点说就是在一个原生线程上通过 "拷贝" 和 "切换" 堆栈帧数据来实现执行多个工作绪.看上去和传统的 "单CPU,多线程(Threading)" 执行方式差不多. swpan() 启动一个 GreenThread 执行目标函数，wait() 返回函数执行结果。

 

1 2 3 4

import  eventlet pool = eventlet.GreenPool() while  True:       pool.spawn(func,args )

上面这段代码,几乎就是使用eventlet的范式：

GreenPool 用来实现协程,保证并行;

Spawn 用来调用相应的函数,完成具体业务

每个func之间切换，实施“你运行一会、我运行一会”，并且在进行切换时必须指定何时切换以及切换到哪，当出现阻塞时，就显式切换到另一段没有被阻塞的代码段执行，直到原先的阻塞状况消失以后，再人工切换回原来的代码段继续处理.

首先需要安装eventlet的相关模块

我们先简单跑一个demo ！

他的用法其实和threading差不多的，都可以指定pool和函数的。（有点废话）

为啥叫他网络编程框架，因为他支持很多底层的东西，比如http，比如socket啥的。

 

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

#! /usr/bin/env python # -*- coding: UTF- 8  -*- from eventlet  import  api def httpd(writer,reader):      req= ''      while  True:          chunk=reader.readline()          if  not chunk:              break          req+=chunk          if  chunk== '\r\n' :              break      data= 'Hello world!\r\n'      writer.write( 'HTTP/1.1 200 OK\r\nContent-Length: %d\r\n\r\n%s' %(len(data),data))      writer.close()      reader.close()      return def main():      try :          server=api.tcp_listener(( '0.0.0.0' , 3000 ))          print  'Server started!'          while  True:              conn,addr=server.accept()              #print  'client %s connected!' %repr(addr)              writer=conn.makefile( 'w' )              api.spawn(httpd,writer,conn.makefile( 'r' ))      except KeyboardInterrupt:          pass      return if  __name__== '__main__' :      main()

咱们来测试下这个用eventlet实现的http吧！

客户端访问下

下面是利用wait（）堵塞行为，保证他是同步的运行。