返回目录

解读Twisted的reactor(3)

解读Twisted的reactor(3)

看了Twisted的标准reactor的使用，会有许多人在说它的考虑不过如此，只是与的复杂了点而已。有没有更强的地方呢？
今天的工作，让我感觉到挖到了Twisted的金矿！一起走进Twisted为daemon的高效开发而准备的超强reactor们。

select

做为缺省的实现，它支持足够多的平台，具有足够不多的个性化特性。但是它已经是Twisted为了性能进行了充分的考虑后的稳定的选择了。如果你不考虑特殊平台上的应用方法，它就是一个非常好的选择了。

• 支持：TCP SSL UDP Threading Processes（限Unix） Scheduling
• 支持平台：Unix Win32
• 使用方法：

   1 from twisted.internet import reactor

另一种是显式的调用：

   1 from twisted.internet import default
   2 default.install()

poll

可以说poll被大多数人认为在高并发的情况下它能够有更好的性能而会被推荐成为Unix下的缺省reactor。

• 支持：TCP SSL UDP Threading Processes Scheduling
• 支持平台：Unix
• 使用方法：

   1 from twisted.internet import pollreactor
   2 pollreactor.install()

KQueue

FreeBSD的core Team对python的偏爱在Twisted中也体现出来。Twisted可以通过KQueue来进行基于FreeBSD的Kqueue的事件调度。在FreeBSD来认为，KQueue会让你的应用在高并发下以更快的速度处理用户的请求。

• 支持：TCP SSL UDP Threading Processes Scheduling
• 支持平台：FreeBSD
• 使用方法：

   1 from twisted.internet import kqreactor
   2 kqreactor.install()

• 安装事项：

系统需要安装PyKQueue模块，同时在编译完要打以下补丁

--- PyKQueue-1.3/kqsyscallmodule.c      Sun Jan 28 21:59:50 2001
+++ PyKQueue-1.3/kqsyscallmodule.c.new  Tue Jul 30 18:06:08 2002
@@ -137,7 +137,7 @@
 }
 
 statichere PyTypeObject KQEvent_Type = {
-  PyObject_HEAD_INIT(NULL)
+  PyObject_HEAD_INIT(&PyType_Type)
   0,                             // ob_size
   "KQEvent",                     // tp_name
   sizeof(KQEventObject),         // tp_basicsize
@@ -291,13 +291,14 @@
 
   /* Build timespec for timeout */
   totimespec.tv_sec = timeout / 1000;
-  totimespec.tv_nsec = (timeout % 1000) * 100000;
+  totimespec.tv_nsec = (timeout % 1000) * 1000000;
 
   // printf("timespec: sec=%d nsec=%d
", totimespec.tv_sec, totimespec.tv_nsec);
 
   /* Make the call */
-
+  Py_BEGIN_ALLOW_THREADS
   gotNumEvents = kevent (self->fd, changelist, haveNumEvents, triggered, wantNumEvents, &totimespec);
+  Py_END_ALLOW_THREADS
 
   /* Don't need the input event list anymore, so get rid of it */
   free (changelist);
@@ -361,7 +362,7 @@
 statichere PyTypeObject KQueue_Type = {
        /* The ob_type field must be initialized in the module init function
         * to be portable to Windows without using C++. */
-       PyObject_HEAD_INIT(NULL)
+       PyObject_HEAD_INIT(&PyType_Type)
        0,                      /*ob_size*/
        "KQueue",                       /*tp_name*/
        sizeof(KQueueObject),   /*tp_basicsize*/

其实除了这些reactor之外，Twisted还提供了一系列与GUI进行集成时使用的reactor，包括Win32、GTK+、Cocoa、Qt等。但是我这里更关注于daemon的开发，所以这些大家自己挖掘罢。

返回目录