perl AnyEvent简单介绍和入门知识88bf必发娱乐

这几天看了下perl的事件编程框架AnyEvent,重点参考了一下几篇文章:

什么是面向事件的编程(事件驱动的编程):

http://search.cpan.org/~mlehmann/AnyEvent-7.05/lib/AnyEvent.pm

编程中所有的程序是由事件决定 –
可以是由用户操作(键盘,鼠标),也可以是由其他程序和流的到达或者操作系统事件(如网络数据包到达)来触发执行.

http://search.cpan.org/~mlehmann/AnyEvent-7.05/lib/AnyEvent/Intro.pod

面向事件编程可以也被定义为,写一个计算机程序,在其中的代码(通常程序的功能的头部)被明确分配应用程序的主回路,其代码本身由两部分组成方法:事件和事件处理的代码。

//www.jb51.net/article/55278.htm

面向事件的编程通常被应用在三种情况下:

1、什么是事件编程?

1.创建用户界面的控制(包括图形)
2.创建一个基于服务器的应用程序
3.游戏编程时多个对象的管理

举个简单的例子,你浏览网页的时候,你点击一个图片,蹭的弹出一个东西,你不点,那就在那里,等待一个人来点它。如果你写过js,其实就是,你注册了很多的时间比如click,dbclick,keybord,submit等,那么浏览器就起到帮我们去监听这些事件的发生(Loop)。当有对应的事件发生的时候,我们也一般也设置了callback,比如onclick,onsubmit等,去响应这些事件,这基本就是事件编程的一个缩影了。

我们系统管理时,这种应用在服务器的应用程序中使用面向事件的编程很多,比如用于服务器应用解决10,000个并发连接(所谓
C10k 问题)

2、perl AnyEvent中的watcher

AnyEvent 是一个性能非常好的基于事件驱动的程序,有人使用它来解决
C10k
的问题,象平时我们写的程序,都是基于过程.我们都是先做完事件1->
然后做事件2->然后做事件3 .这种方式.

在AnyEvent中有5中watcher,分别是IO,timer,signal, child, idle.

但基于事件就完全不一样了,在主流程中你基本只有一个主体框架,程序的动作触发都是由事件来驱动.比如我们使用的窗口程序.点最大化最小化,都是基于事件,当接收到了最大化的事件做最大化事件那部分的程序开始运行.不在从头到尾部来执行.所以我们读基于事件的程序,最好是画成思维导图来帮助我们理解.

2.1 io watcher

基于事件的程序常用到的最大好处是用来做异步,例如,我们要下载 100
个文件,下载完后对这些文件进行处理.可能给每个下载和处理的过程写成事件,这些事件可以同步运行(关键在于网络连接和进行文件的读写
IO 时要等待,事件是给这些等待复用起来).
不知大家了解 Perl 中的 select
这个功能不,就是等到句柄可以读或者写的时候,做不同的读或者写的操作.事件循环也是一样.

复制代码 代码如下:

在整个 AnyEvent 入门中,我们只要关注二个点就行, WATCHERS(监控者) 和
条件变量.

#!/usr/bin/perl
 
use AnyEvent;
my $cv = AnyEvent->condvar;
 
#open my $file , ‘<‘ , ‘test.txt’ or die “$!” ;
open F , ‘<‘ , ‘test.txt’ or die “$!” ;
my $io_watcher = AnyEvent->io (
      fh   => *F,
      poll => ‘r’,
      cb   => sub {
         chomp (my $input = sysread F ,my $buf ,1024); # read a line
 
         warn “read: $buf\n”  if $input >0 ;       # output what
has been read
         #$cv->send if /quit/ ; # quit program if /quit/i
      },
   );
 
$cv->recv; # wait until user enters /quit/i

WATCHERS(监控者)

timer watcher

在 select 中,有个角色叫”监控者”,就是 select 函数本身.
在 AnyEvent 中不但可以监控 IO
还可以监控别的一些事件.来做不同的处理.我们可以看成这是不断的盯着某件事情的人
有如下几个基本的内置的可以用来盯着的事情(“监控者”).
TIMER : 监控时间,到了一定的条件,然后对不同的时间做不同的事件
I/O: 这个是监控到 IO 是否可以读写,然后做相应的事件
IDLE: 空闲时做什么事件
SIGNAL : 监控观查到不同的信息,调用相应的事件
CHILD PROCESS: 对子程序的状态来调用相应的处理事件

AnyEvent 的timer的一部分其实像javascript的setInterval :

TIMER WATCHERS

复制代码 代码如下:

基本语法

#!/usr/bin/perl
 
use 5.016;
use AnyEvent ;
 
my $cv = AnyEvent->condvar ;
 
my $w = AnyEvent->timer(
    after => 0 ,  #多少秒之后触发事件
    interval => 2 ,  #多少秒触发事件
    cb => sub {
        say AnyEvent->time ,” “,AnyEvent->now ;
 
    }
);
 
$cv->recv;

复制代码 代码如下:

signal watcher

AnyEvent->timer(
after => $seconds, # 多久之后做相应的操作.
interval => $seconds, # 在上面条件生效后,每格多久进行一次
callback.
cb => $cb, # cb 是 callback
的简写,所以知道了吧,只要到了前面的条件,就会运行 cb => 指向的函数.
);

前面我们在的文章中写到了perl中对于信号的处理
perl信号处理简单学习》,这里主要是AnyEvent中对于这些事件的处理。

使用实例:

复制代码 代码如下:

下面的例子是,5 秒后,每 2 秒进行一次 callback 中的事件,直到 $w
这个注册的事件被 undef 为止(也就是 $count > 10 次).这个中的 undef $w
是取消掉这种 watcher 的方法.

#!/usr/bin/perl
 
use 5.016;
use AnyEvent ;
#say for keys %SIG; 看一下又多少信号
my $cv = AnyEvent->condvar ;
 
my $w = AnyEvent->signal(
    signal => ‘INT’,
    cb => sub {
        say AnyEvent->time ,” “,AnyEvent->now ;
        exit 1 ;
 
    }
);
 
$cv->recv;

复制代码 代码如下:

child watcher

#!/usr/bin/perl
use strict;
use AnyEvent;

复制代码 代码如下:

my $cv = AnyEvent->condvar;

#!/usr/bin/perl
use AnyEvent;
   my $done = AnyEvent->condvar;
 
   my $pid = fork or exit 5;
 
   my $w = AnyEvent->child (
      pid => $pid,
      cb  => sub {
         my ($pid, $status) = @_;
         warn “pid $pid exited with status $status”;
         $done->send;
      },
   );
 
   # do something else, then wait for process exit
   $done->recv;

my $count = 0;
my $w; $w = AnyEvent->timer(
after => 5,
interval => 2,
cb => sub {
$count++;
warn “这是第 $count 次调用”;
if ($count >= 10) {
undef $w;
}
}
);
$cv->recv;

idle watcher

I/O WATCHERS

就是如果main loop在空闲的时候做些什么呢?

基本语法

复制代码 代码如下:

复制代码 代码如下:

#!/usr/bin/perl
use AnyEvent;
   my @lines; # read data
   my $idle_w;
   $cv = AnyEvent->condvar;
   my $io_w = AnyEvent->io (fh => \*STDIN, poll => ‘r’, cb
=> sub {
      push @lines, scalar <STDIN>;
 
      # start an idle watcher, if not already done
      $idle_w ||= AnyEvent->idle (cb => sub {
         # handle only one line, when there are lines left
         if (my $line = shift @lines) {
            print “handled when idle: $line”;
         } else {
            # otherwise disable the idle watcher again
            undef $idle_w;
         }
      });
   });
 
   $cv->recv;

my $fh = ….; # 打开一个句柄

您可能感兴趣的文章:

my $io; $io = AnyEvent->io(
fh => $fh, # 上面打开的句柄,也可以是标准输入和输出
poll => “w”, # 这个地方可以选择 r 和 w 来表示读和写的 IO 事件
cb => sub {
syswrite( $fh, “写入的内容” );
undef $io;
}
);

使用实例:

下面的例子,是使用 io 监控到可以读,就调用 cb 的函数,直接读文件
test.txt,每次一个字节,直到读完这个文件就通过 undef 消掉这个事件.

复制代码 代码如下:

#!/usr/bin/perl
use strict;
use AnyEvent;

my $cv = AnyEvent->condvar;

open my $fh, “<test.txt” or die “不能打开文件句柄 $!”;
my $io; $io = AnyEvent->io(
fh => $fh,
poll => “r”,
cb => sub {
my $len = sysread( $fh, my $buf, 1 );
if ($len > 0) {
print “read ‘$buf’\n”;
}
else {
undef $io;
die “读出错: $!”;
}
});

$cv->recv;

IDLE WATCHERS

基本语法

复制代码 代码如下:

my $w = AnyEvent->idle (cb => sub { … });

使用实例:

下面的例子,当整个程序中,没有其它事件在运行时,就会运行 idle
.它就是当其它事件都在等待和空着的时候,所调用的.

复制代码 代码如下:

#!/usr/bin/perl
use strict;
use AnyEvent;

my $cv = AnyEvent->condvar;

my $t; $t = AnyEvent->timer(
after => 1,
interval => 1,
cb => sub { print time().”\n” }
);

my $w; $w = AnyEvent->idle(
cb => sub {
warn “idle”;
# undef $w;
}
);

$cv->recv;

SIGNAL WATCHERS

基本语法如下,就是当接收到 POSIX signal 的时候,运行 callback 中的事件.

复制代码 代码如下:

my $w = AnyEvent->signal (signal => “TERM”, cb => sub { …
});

CHILD PROCRSS WATCHERS

基本语法如下

复制代码 代码如下:

# child process exit
my $w = AnyEvent->child (pid => $pid, cb => sub {
my ($pid, $status) = @_;

});

条件变量(多个条件时)

这个是 AnyEvent 学习上面几种事件监控后必须要了解的.大家都见到上面有
AnyEvent->condvar; 和 $cv->recv这二个,condvar 是 condition
variable 的简写.是指当什么样的条件成立时的变量

其实就是条件,当达到什么条件时退出事件循环.所以 AnyEvent
中没有传统事件中的 loop 函数.所以使用条件变量就相当于让事件这个转起来.

基本的 $cv->recv 是和 $cv->send 成对出现的,当事件调用 send
时,就一定要有 recv 收到这个调用,才会退出事件.

下面的 $cv->begin 和 $cv->end 也基本是这个意思.send
是单个条件.begin 和 end
是多个条件成立时退出,换个语来讲,就是这些事件都成对的完成后,才退出事件.

复制代码 代码如下:

#!/usr/bin/perl
use strict;
use AnyEvent;

my $cv = AnyEvent->condvar( cb => sub {
warn “调用结束”;
});

for my $i (1..10) {
$cv->begin;
my $w; $w = AnyEvent->timer(after => $i, cb => sub {
warn “finished timer $i”;
undef $w;
$cv->end;
});
}

$cv->recv;

默认的 condvar 会对事件建一个条件为假的变量,所以直接有 send 和 begin
send
之类才会变成真,然后退出事件循环.可以给这个地方看成一个信号量来理解就好了.y
如果条件不成立,在 AnyEvent 中事件会一直 loop .所以上面的例子中没有 send
.

有关 AnyEvent 其它,大家入门后可以玩玩象 AnyEvent::HTTP,twiggy
之类.看看这些应用和项目.

另外,在 AnyEvent 中我们常常使用 EV .他是一个 C 的 libev 的 Perl
接口,有非常高的性能.看完上面,在看看下面 EV
的使用,非常容易吧,基本不变.只是没出现条件变量,
使用的传统的 EV::loop; 来使这个运行起来.

复制代码 代码如下:

use EV;

# TIMERS

my $w = EV::timer 2, 0, sub {
warn “is called after 2s”;
};

my $w = EV::timer 2, 2, sub {
warn “is called roughly every 2s (repeat = 2)”;
};

undef $w; # destroy event watcher again

my $w = EV::periodic 0, 60, 0, sub {
warn “is called every minute, on the minute, exactly”;
};

# IO

my $w = EV::io *STDIN, EV::READ, sub {
my ($w, $revents) = @_; # all callbacks receive the watcher and event
mask
warn “stdin is readable, you entered: “, <STDIN>;
};

# SIGNALS

my $w = EV::signal ‘QUIT’, sub {
warn “sigquit received\n”;
};

# CHILD/PID STATUS CHANGES

my $w = EV::child 666, 0, sub {
my ($w, $revents) = @_;
my $status = $w->rstatus;
};

# STAT CHANGES
my $w = EV::stat “/etc/passwd”, 10, sub {
my ($w, $revents) = @_;
warn $w->path, ” has changed somehow.\n”;
};

# MAINLOOP
EV::loop; # loop until EV::unloop is called or all watchers stop
EV::loop EV::LOOP_ONESHOT; # block until at least one event could be
handled
EV::loop EV::LOOP_NONBLOCK; # try to handle same events, but do not
block

注:本文中大部分内容来自日本的@lestrrat