What Is POE, And Why Should I Use It?
回顾一下我们每天写的程序，可以发现这些程序大部分都有着基本的结构：启动，执行一系列的动作，然后退出。对于那些在用户和他们的数据之间不需要很多交互的应用中，这样的程序都能工作得很好。然后，如果是如果是碰到了复杂的任务，我想你就需要一个更加好的程序框架理解任务的复杂性，完成这个任务。
所以POE（Perl 对象环境）应运而生了。POE是一个构建Perl程序的框架，以更自然地完成那些需要对外部数据作出反应的任务，比如网络通讯或者用户接口。用POE写的程序完全是非线性的；你只需要建立一些小的子程序，并且定义好它们之间如何相互调用，那么POE就会根据程序处理的输入输出，自动在它们之间切换。说到现在，你可能已经头晕了。如果你习惯于看代码去理解，那么看了下面一个小例子后，你就会恍然大悟了。
POE Design
说POE是一个小的操作系统一点都不夸张，它有它自己的内核，进程，进程间通讯（IPC），驱动等等这些。实际上，它是一个简单的系统，构建了一系列的状态信息。下面对组成POE各个部分的一个简单的描述：
States
POE的基本程序块就是状态，它是一些代码，当事件发生时触发执行。例如，输入的数据到达，一个会话过期，一个会话传递了一条信息给另一个会话。POE里的每件事情都是基于接收和处理各种各样的事件。
The Kernel
POE的内核跟操作系统的内核很象：它守护着后台的所有你的进程和数据，安排你的代码的触发。你能够用POE的内核来为你的进程设置警报，控制你的状态队列和其他一些低级服务，当然，大部分时间你不用直接来跟内核交互。
Sessions
POE里的会话相当于一个真的操作系统里的进程。一个会话就是一个POE程序，当它在运行时不停地在状态之间切换。它能够创建子会话，传递信息给其他的会话等等。每个会话都能通过调用 heap 存储会话特有的数据，这些数据在会话中的各个状态都是可以存取的。
POE有一个简单的协作的多任务处理模块；每个会话在同一个OS进程中执行，不需要任何线程和进程。对于这样的会话，你应该特别注意在POE程序中使用模块化的系统调用。
这些就是POE的最基本的部分，但是在我们开始实际的代码前还需要稍微ie解释一些高级的POE的部分。
Drivers
驱动位于POE最低级的I/O层。目前，只有一个驱动包括在POE的安装中-- POE::Driver::SysRW，它读写文件句柄中的数据。不管怎样，我们都不需要直接使用驱动。
Filters
过滤器，在某个方面来说，是非常有用的。过滤器是一个简单的接口，转换数据块从一个格式成另一个格式。例如，POE::Filter::HTTPD 能够在 HTTP 1.0 requests 之间 HTTP::Request 对象互相转换。POE::Filter::Line 能够见数据流转换成序列化数据行。
Wheels
Wheels包含了每天任务的可重复利用的高级逻辑部分。它们是POE封装有用代码的方法。在POE中你需要处理到的Wheels包括事件驱动的输入输出数据和网络连接的创建。Wheels经常使用过滤器和驱动来处理和传递数据。这个描述太过于含糊了，下面的代码将会给出一个例子来说明这个概念。
Components
组件是一个会话，被设计来受控于其它会话。你的会话能够从它们那里来处理命令和接受事件，这点很象真实操作系统中的通过IPC通讯。一个组件的例子就是POE::Component::IRC，一个创建基于POE的IPC客户端接口，或者是POE::Component::Client::HTTP，一个事件驱动的Perl实现的HTTP用户代理。组件同样是POE非常有用的一个部分。
A Simple Example
在这个例子中，我们会建立一个守护进程服务端，它接受TCP连接，同时打印由它的客户端提交的算术问题的答案。当有人连接它的端口31008，它将打印“Hello,client”。客户端能够提交一个算术表达式，以一个新行结束提交，服务端将送回表达式的答案。够简单吧。
写这样一个POE程序跟写一个Unix下的守护进程的传统方法没有什么很大的不同。我们将有一个服务器会话在端口31008监听TCP连接。每当连接到来时，它将创建一个子会话来处理连接。每个子会话都能跟用户交互，然后在连接断开后安静地死掉。所有这些用Perl简单地实现只需要模块化的72行代码就行了。
这个程序简单地以下面的代码开始：
1 #!/usr/bin/perl -w
2 use strict;
3 use Socket qw(inet_ntoa);
4 use POE qw( Wheel::SocketFactory Wheel::ReadWrite
5 Filter::Line Driver::SysRW );
6 use constant PORT => 31008;
这一段我们导入了脚本所需要的模块以及函数，并定义了监听端口的常量值。”use POE;”后面的 qw()语句一次导入了很多POE::模块。
现在开始本文最酷的部分：
7 new POE::Session (
8 _start => \&server_start,
9 _stop => \&server_stop,
10 );
11 $poe_kernel->run();
12 exit;
这样就已经是一个完整的程序了！我建立了服务端会话，告诉POE内核开始执行事件，并且在事件结束后退出。（当没有任何会话需要管理的时候，POE内核就认为事情做完了，但是既然我们已经打算把服务端会话放在一个无穷的循环中，它将不会以这种发式退出）POE在你写"use POE;"h后，自动输出变量$poe_kernel 到你的名字空间中。
new POE::Session 方法调用需要解释一下。当你创建一个会话时，你给内核一个这个会话将接受事件的列表。在上面的代码中，意味着这个新的会话将通过调用&server_start，&server_stop处理_start和_stop事件。任何一个受到的但没有列举到的事件，将会被会话忽略。_Start和_Stop事件对于一个POE会话来说是一个特殊事件。_start事件是当一个会话创建时第一件要做的事情，当会话将要被摧毁时内核就通知这个会话进入_stop状态。
现在，我们已经写了完整的程序，我们还要写当会话运行时要执行的状态代码。接下来，让我们以&server_start开始。当主要的服务端会话被创建，开始执行程序时，它将会被调用。
13 sub server_start {
14 $_[HEAP]->{listener} = new POE::Wheel::SocketFactory
15 ( BindPort => PORT,
16 Reuse => 'yes',
17 SuccessState => \&accept_new_client,
18 FailureState => \&accept_failed
19 );
20 print "SERVER: Started listening on port ", PORT, ".\n";
21 }
这是一个有关POE状态的很好的例子。首先：看到变量$_[HEAP]了吗？POE有一个特殊的方法来传递参数。@_数组是由许多外部的参数打包在一起的。外部参数包括目前内核，会话和状态名的一个引用，堆栈的引用，以及其它一些东西。我们可以用POE导出的特殊常量来作为这个数组索引，比如 HEAP, SESSION, KERNEL, STATE和ARG0~ARG9（用户提供的参数）。跟POE的大部分设计一样，这样子的安排能够最大化后面的兼容性而又不牺牲速度。上面的例子存储了一个 SocketFactory wheel 在键值 listen 下。
POE::Wheel::SocketFactory wheel是POE里最酷的东西之一。你能够用它创建任何一个流socket（UDP socket还不行），而不需要担心细节。上面的代码将创建一个SocketFactory来监听特殊的TCP端口的新连接。当连接建立时，它将调用&accept_new_client来传递一个新的客户端，如果在这其中发生错误了，它将调用&accept_failed，而不是让我们自己来处理错误。这差不多就是用POE在网络中要做的。
我们存储一个wheel在堆栈中，以防止在状态的最后被Perl的垃圾收集机制意外地消灭掉，——这个方法在会话的每个状态中到处存在。现在我们来看&server_stop 状态的代码：
22 sub server_stop {
23 print "SERVER: Stopped.\n";
24 }这段不需要多解释了。接下来的是我们创建一个新的会话来处理每个新到的连接。 25 sub accept_new_client {
26 my ($socket, $peeraddr, $peerport) = @_[ARG0 .. ARG2];
27 $peeraddr = inet_ntoa($peeraddr);
28 new POE::Session (
29 _start => \&child_start,
30 _stop => \&child_stop,
31 main => [ 'child_input', 'child_done', 'child_error' ],
32 [ $socket, $peeraddr, $peerport ]
33 );
34 print "SERVER: Got connection from $peeraddr:$peerport.\n";
35 }当客户端成功地建立了跟服务端的连接后，我们的 POE::Wheel::SocketFactory将调用这个子例程。我们将socket地址转换成人可读的IP地址，并且建立一个新的会话来跟客户端通讯。这跟前面的 POE::Session 构造器很象，但是有几点在接下来要说明。 @_[ARG0 .. ARG2]是($_[ARG0], $_[ARG1], $_[ARG2])的快捷方式。你会在POE程序中看到很多这样的数组切片。 看31行：好像有点奇怪，其实这是一种很聪明的缩写。它可以用下面的比较长的方法来重写： new POE::Session (
...
child_input => &main::child_input,
child_done => &main::child_done,
child_error => &main::child_error,
...
); 这是一个方便的做法来写出很多的状态名字，这些名字跟事件的名字是一样的。——你可以传递包名或者对象来作为键，或者是任何一个有子例程，方法名组成的数组引用。可以参考POE::Session得到更多的信息。 最后，在POE::Session 构造器参数列表最后的数组引用是我们要手动传递给_start状态的参数列表。 如果POE::Wheel::SocketFactory在创建监听端口或者接受连接时产生了问题，下面的会发生： 36 sub accept_failed {
37 my ($function, $error) = @_[ARG0, ARG2];
38 delete $_[HEAP]->{listener};
39 print "SERVER: call to $function() failed: $error.\n";
40 } 打印错误信息是正常的处理方式，但是我们为什么还要从堆栈中删除SocketFactory wheel呢？答案在于POE管理会话资源的方式。只要会话还能产生和接受事件，那么它就被认为是活动的。如果没有wheel，POE内核会认为会话已经死了，并收集会话的资源。服务端得到事件的唯一方式就是从SocketFactory wheel，如果它被消灭了，POE内核会一直等待，直到所有它的子会话结束，再收集所有占用的资源。在这一点上，既然已经没有剩下的会话需要执行，POE内核将会结束并退出。 所以，基本上来说，这是最通常的结束POE会话的方法：结束所有会话资源，让内核干剩下的工作。现在，我们谈到子会话的细节。 41 sub child_start {
42 my ($heap, $socket) = @_[HEAP, ARG0];
43 $heap->{readwrite} = new POE::Wheel::ReadWrite
44 ( Handle => $socket,
45 Driver => new POE::Driver::SysRW (),
46 Filter => new POE::Filter::Line (),
47 InputState => 'child_input',
48 ErrorState => 'child_error',
49 );
50 $heap->{readwrite}->put( "Hello, client!" );
51 $heap->{peername} = join ':', @_[ARG1, ARG2];
52 print "CHILD: Connected to $heap->{peername}.\n";
53 } 每当新的子会话被创建来处理最新的连接客户端时上面的代码就会被调用。这里我们要介绍一种新的POE wheel：ReadWrite wheel，这是一个由事件驱动的处理I/O任务的wheel。我们把它传递给文件句柄，一个驱动，一个过滤器等等。接着，每当新的数据到达文件句柄时，wheel将发送一个child_input事件给会话，如果有任何错误发生就会发送一个child_error 事件。 我们理解用这个新的wheel来输出字符串”Hello,client”给socket。最后，我们存储在堆栈中的客户端地址和端口，并打印成功信息。 我们省略了 child_stop 的状态讨论。它只有一行长度。现在我们直接看主要的child_input 程序。 57 sub child_input {
58 my $data = $_[ARG0];
59 $data =~ tr{0-9+*/()-}{}cd;
60 return unless length $data;
61 my $result = eval $data;
62 chomp $@;
63 $_[HEAP]->{readwrite}->put( $@ || $result );
64 print "CHILD: Got input from peer: \"$data\" = $result.\n";
65 } 当客户端发送给我们一行数据，我们取得里面简单的算术表达式并eval它，然后把结果或者错误信息发送给客户端。通常情况下，将客户端发送来的不可信任的数据直接就eval是非常危险的，所以我们要确保在eval前，将字符串中所有的非数学字符全部过滤掉。子会话将一直保持接受数据直到客户端断开。 所有事件驱动的应用都是使用POE的好地方。源代码：
阅读(807) | 评论(0) | 转发(0) |
