12 / 2 页下一页

论坛徽章:: 42

电梯直达

1楼 [收藏(0)] [报告]

发表于 2014-05-08 18:49 |只看该作者 |倒序浏览

本帖最后由 laputa73 于 2014-05-09 14:58 编辑

比如类似mojo的延迟渲染
这样写怎么不行呢？

sub {
my $r = shift;
# loading the env is optional under Feersum. For a "fair" speed
# comparison to app.psgi, uncomment this line:
my $env = $r->env();
my $w = $r->start_streaming("200 OK", [
'Content-Type' => 'text/plain',
'Connection' => 'close',
]);
$w->write("hello");
EV::timer 1, 0, sub {
$w->write("$env->{REMOTE_ADDR}");
$w->write("\n");
$w->close();
};
};

复制代码

文库|博客

laputa73

巨富豪门

论坛徽章:: 42

2楼 [报告]

发表于 2014-05-09 15:02 |只看该作者

参考feersum的chat.feersum例子,这个基本可以了.
需要把handle和timer定义为全局变量.
feersum的文档好少啊.

#!perl
use warnings;
use strict;
use EV;
use Scalar::Util qw/weaken/;
my $clients = 0;
my @handles;
my @timers;
my @html_hdrs = (
'Content-Type' => 'text/html; charset=UTF-8',
'Cache-Control' => 'no-cache, no-store, private',
'Pragma' => 'no-cache',
);
sub start_stream {
my ($r, $client) = @_;
my $w = $r->start_streaming(200, \@html_hdrs);
$handles[$client] = $w;
weaken $w;
$timers[$client] = EV::timer 1,1,sub {
eval{
$w->write(' keep-alive') if $w;
}
if($@) {
$w->close;
undef $timers[$client];
}
};
$w->write(<<EOH);
<html>
<head></head>
<body>
Hello! (connection $client.)
EOH
}
my $app = sub {
my $r = shift;
my $env = $r->env;
my $path = $env->{PATH_INFO};
$clients++;
start_stream($r,$clients);
};

复制代码

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

py

版主

论坛徽章:: 1

3楼 [报告]

发表于 2014-05-09 15:05 |只看该作者

我以前只试过feersum

假设你的回调是传给request_handler的，你这里timer注册的事件不能这么写。见SYNOPSIS：http://search.cpan.org/~audreyt/Feersum-1.401/lib/Feersum.pm

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

laputa73

巨富豪门

论坛徽章:: 42

4楼 [报告]

发表于 2014-05-09 18:02 |只看该作者

回复 3# py

就是feersum的.
feersum可以用psgi,也可以用native mode,还可以写成pl.
就是文档太少,例子也只有几个.
2楼的写法是按照例子写的

feersum的性能确实好.
但是怎么用还需要摸索

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

laputa73

巨富豪门

论坛徽章:: 42

5楼 [报告]

发表于 2014-05-09 18:11 |只看该作者

本帖最后由 laputa73 于 2014-05-09 18:17 编辑

psgi方式的.
还是没搞明白poll_cb这个是怎么调用的.再读读源码吧.

use EV;
use Scalar::Util qw/weaken/;
my $client = 0;
my @handles;
my @timers;
my @html_hdrs = (
'Content-Type' => 'text/html; charset=UTF-8',
'Cache-Control' => 'no-cache, no-store, private',
'Pragma' => 'no-cache',
);
my $app = sub {
my $env = shift;
$client++;
return sub {
my $respond = shift;
my $w = $respond->([
200, \@html_hdrs
]);
$handles[$client] = $w;
weaken $w;
$timers[$client] = EV::timer 1,1,sub {
eval{
$w->write(' keep-alive') if $w;
};
if($@) {
eval{$w->close;};
undef $timers[$client];
}
};
$w->write(<<EOH);
<html>
<head></head>
<body>
Hello! (connection $client.)
EOH
};
};

复制代码

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

laputa73

巨富豪门

论坛徽章:: 42

6楼 [报告]

发表于 2014-05-09 18:23 |只看该作者

配合coro的

use Coro;
use AnyEvent;
use Coro::AnyEvent;
use Scalar::Util qw/weaken/;
my $client = 0;
my @html_hdrs = (
'Content-Type' => 'text/html; charset=UTF-8',
'Cache-Control' => 'no-cache, no-store, private',
'Pragma' => 'no-cache',
);
my $app = sub {
my $env = shift;
$client++;
return sub {
my $respond = shift;
my $w = $respond->([
200, \@html_hdrs
]);
$handles[$client] = $w;
weaken $w;
$w->write(<<EOH);
<html>
<head></head>
<body>
Hello! (connection $client.)
EOH
Coro::AnyEvent::sleep 2;
eval{
$w->write(' keep-alive') if $w;
};
eval{$w->close;};
};
};

复制代码

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

hotsnow

家境小康

论坛徽章:: 0

7楼 [报告]

发表于 2014-07-21 14:06 |只看该作者

回复 5# laputa73

请问poll_cb看懂了吗？看懂了的话，请指教，哈哈

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

laputa73

巨富豪门

论坛徽章:: 42

8楼 [报告]

发表于 2014-07-23 16:10 |只看该作者

回复 7# hotsnow

不好意思,有一阵没看了.
后来不用poll_cb了,反正文档说poll_cb is removed from the preliminary PSGI 1.1 spec
我想要的效果就是可以在feersumsum的app里面使用EV或者AE或者coro的异步事件
这个在native和psgi都可以实现,后续没在继续深入.

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

hotsnow

家境小康

论坛徽章:: 0

9楼 [报告]

发表于 2014-07-25 14:50 |只看该作者

回复 8# laputa73

my $app = sub {
my $req = shift;
my $env = $req->env();
my $w = $req->start_streaming(200, []);
Coro::AnyEvent::sleep 2;
$w->write("regular scalars are OK too\n");
$w->close(); # close off the stream
};

复制代码

native 模式下这个异步会报错，你的native模式是怎么用的？

(in cleanup) DIED: Can't call method "env" on unblessed reference

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

laputa73

巨富豪门

论坛徽章:: 42

10楼 [报告]

发表于 2014-07-25 18:09 |只看该作者

本帖最后由 laputa73 于 2014-07-25 18:29 编辑

回复 9# hotsnow

你启动的时候加 --native了么?
feersum --native ./tsleep.feersum

[root@search2 perl]# feersum  -help
Usage:
   feersum [plackup opts] [--pre-fork=N] [app.psgi]
   feersum --native [--listen host:port] [--pre-fork=N] [app.feersum]

[root@search2 perl]#

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

12 / 2 页下一页

返回列表

Chinaunix › 论坛 › 程序设计 › Perl › 请教feersum的事件怎么写？(已解决)

请教feersum的事件怎么写？(已解决) [复制链接]

浏览过的版块