AnyEventに関する写経用サンプルプログラムリンク集(Tatsumaki含む) - メメメモモ
AnyEvent(Tatsumaki)の勉強で写経するのに良さそうなサンプルプログラムがあるページを集めました。 第13回 AnyEvent：イベント駆動モジュールの方言を吸収する(モダンPerlの世界へようこそ) Hello World的な短いサンプルプログラム AnyEventでechoサーバ - すぎゃーんメモ AnyEvent::Socket, AnyEvent::Handleを用いたechoサーバ AnyEvent::Twitterの使い方 - すぎゃーんメモ AnyEvent::Twitterの使い方 A simple chat server in AnyEvent - unknownplace.org チャットサーバ AnyEventでの簡単なFIFOキューの作り方 - D-6 相変わらず根無し AnyEvent で plagger-ircbot 的なのかいた IRCのpro
mala氏の Studying HTTP with Perl を見ながら書いたノートの清書 - ku ryze denik ●〜*
リクエストを 5000/sec とかするときのための 200/secでよければ別にLWP使ってればいいよマジで、実際便利だし。 非並列なhttpアクセス LWP::RobotUA robots.txt見たりするので行儀が良い URI::Fetch キャッシュとかする、インターフェースがいい HTTP::Lite 依存モジュールなし、どこでも使えるよ LWPx::ParanoidAgent ローカルIPは弾く、WEB魚拓的サービスに 並列なhttpアクセス AnyEvent::HTTP 簡単 Coro::LWP コルーチン、黒魔術(なにをしてるか理解して使おう) AnyEvent::Curl curlのオプションを覚えなくてはダメ Coro::LWPはLWPをcoro使用に全て置き換えるから注意。 coroそのものを知りましょう Curlって cURLのこと、Cpan記法だからCurlだけど
Data::Monad::CondVar をリリースしました - Pixel Pedals of Tomakomai
YAPC Asia 2011で話をする予定のモジュールをCPANへアップしました。 Data::Monad::CondVarはJSDeferred みたいなもんです。 use AnyEvent; use AnyEvent::HTTP; sub random_choice { my ($data, $headers, $cb) = @_; my (@url) = $data =~ m{href="(http:[^"]+)}g; http_get +(shuffle @url)[0], $cb; } my $cv = AE::cv; http_get "http://yapcasia.org/2011/", sub { random_choice @_ => sub { random_choice @_ => sub { random_choice @_ => sub { my ($data,
Asynchronous programming with AnyEvent
Asynchronous programming with AnyEvent - Download as a PDF or view online for free
Plack ベースで作った Web サービスとそのシステムアーキテクチャ - Craftworks Tech Blog - Branch
本日、TVTalk という Web サービスをリリースしました。 Twitter 上で、テレビ局のハッシュタグが付いているツイートを拾って、放送中の番組情報と紐付けるという、アグリゲーターサービスです。リアルタイムにタイムラインを追うにも、放送済み番組の内容をチェックするのにも使えますので、みなさんぜひ使ってみてください。ブックマークやいいね！も良かったらお願いします！ 今日は、この Web サービスの裏側のシステム構成を紹介したいと思います。 構成 EC2 Route53 （DNS) ELB （Load Balancer） MySQL 5.5.11 nginx 0.7.65 Starman Twiggy Tatsumaki AnyEvent::Twitter::Stream Airy (自作フレームワーク) Web サーバー Web はフロントに nginx をおいて、静的ファイルは n
はてなグループの終了日を2020年1月31日(金)に決定しました - はてなの告知
はてなグループの終了日を2020年1月31日(金)に決定しました 以下のエントリの通り、今年末を目処にはてなグループを終了予定である旨をお知らせしておりました。 2019年末を目処に、はてなグループの提供を終了する予定です - はてなグループ日記 このたび、正式に終了日を決定いたしましたので、以下の通りご確認ください。 終了日: 2020年1月31日(金) エクスポート希望申請期限:2020年1月31日(金) 終了日以降は、はてなグループの閲覧および投稿は行えません。日記のエクスポートが必要な方は以下の記事にしたがって手続きをしてください。 はてなグループに投稿された日記データのエクスポートについて - はてなグループ日記 ご利用のみなさまにはご迷惑をおかけいたしますが、どうぞよろしくお願いいたします。 2020-06-25 追記 はてなグループ日記のエクスポートデータは2020年2月28
AnyEventサンプルその６ - 気ままに書いてみました日記
AnyEvent::JSONRPC::Liteから要点を抜き出す。サーバ内部のcondvarをrecvしている箇所。 サーバ側 use strict; use warnings; use AnyEvent; use AnyEvent::Handle; use AnyEvent::Socket; use Data::Dumper; tcp_server '127.0.0.1', 8888, sub { my ($fh) = @_ or die; my $handle = AnyEvent::Handle->new( fh => $fh, on_error => sub { shift->destroy; warn "ON ERROR $!"; }, on_eof => sub { shift->destroy; warn "ON EOR $!"; }, ); $handle->on_read
AnyEventサンプルその５ - 気ままに書いてみました日記
AnyEvent::Handleの扱いに苦労した。 ioやtimerのヲチャー変数のようにundefでも行けた。参照カウントが残っているとどうもよくないのかしらね。AnyEvent::JSONRPC::Liteでもweaken $handleとやっている部分がどうも今ひとつ理解できずにいたのだが、大事だよということはよくわかった。 サーバ側 use strict; use warnings; use AnyEvent; use AnyEvent::Handle; use AnyEvent::Socket; use Data::Dumper; tcp_server '127.0.0.1', 8888, sub { my ($fh) = @_ or die; my $handle = AnyEvent::Handle->new( fh => $fh, on_error => sub { shi
AnyEventサンプルその４ - 気ままに書いてみました日記
いろいろと書き方がある？ので苦労する。$handle->destroyするということはソケット接続を切るということでもあるので、どの時点できるのかをきちんと通信を頭の中に思い浮かべないといけない。 サーバ側 use strict; use warnings; use AnyEvent; use AnyEvent::Handle; use AnyEvent::Socket; use Data::Dumper; $|++; tcp_server '127.0.0.1', 8888, sub { my ($fh) = @_; my $handle = AnyEvent::Handle->new( fh => $fh, on_error => sub { shift->destroy; warn "ON_ERROR $!" }, on_eof => sub { shift->destroy; wa
AnyEventサンプルその３ - 気ままに書いてみました日記
AnyEvent::HandleやAnyEvent::Socketを使う。今回はtelnetを使わないでtcp_connectを使ってみた。 サーバ側がエコーバックする時に改行文字を入れないとデッドロックしてしまう部分ではまった。line形式のデータのやり取りでは改行が必須なのかな。 サーバ側 use warnings; use AnyEvent; use AnyEvent::Handle; use AnyEvent::Socket; use Data::Dumper; tcp_server '127.0.0.1', 8888, sub { my ($fh) = @_ or die; my $handle = AnyEvent::Handle->new( fh => $fh, on_error => sub { shift->destroy; warn "ON ERROR $!" }, o
Perl で WebSocket クライアント(AnyEvent)&サーバ(psgi) - Practice of Programming
こんなんでいいかなぁ。その2。 forkじゃアレなんで、AnyEventで書いてみた(https://gist.github.com/1000223)。 追記: 以下、to_stringですが、Protocol-WebSocket-0.00906 では、Protocol::WebSocket::Handshake は to_bytes に変わっているようです。 #!/usr/bin/perl use utf8; use strict; use warnings; use AnyEvent; use Protocol::WebSocket::Frame; use Protocol::WebSocket::Handshake::Client; use IO::Socket; use constant {READ => 0, WRITE => 1}; $| = 1; run(); sub run
AnyEventのサンプルその２ - 気ままに書いてみました日記
AnyEvent::Handleを使って対話するサーバを書く サーバを立ち上げてtelnetでアクセスすると名前を聞かれるので答える。次に年齢まで聞いてくるので答えます。それで対話が終了しサーバの方から接続を切ってきます。味噌はIO監視の中でさらに監視をしているというところなのだが、本当に問題のない書き方なのかが少し心配。。 use strict; use warnings; use AnyEvent; use AnyEvent::Strict; use AnyEvent::Handle; use AnyEvent::Socket; $|++; my $cv = AE::cv; tcp_server '127.0.0.1', 8888, sub { my ($fh) = @_ or die; my $handle; $handle = AnyEvent::Handle->new( fh =
AnyEventのサンプル - 気ままに書いてみました日記
最近何も書いていなかったのでAnyEventの復習でお茶を濁す。 AnyEvent::Introにも載っているサンプル。 普通に標準入力からの入力を待ち受けるスクリプトとどう違うの？というような疑問を持ってしまうサンプル。 use strict; use warnings; use AnyEvent; use AnyEvent::Strict; $|++; print "Enter Your Name: "; my $cv = AE::cv; my $watcher; $watcher = AnyEvent->io( fh => \*STDIN, poll => 'r', cb => sub { my $str = <STDIN>; chomp $str; undef $watcher; $cv->send($str); } ); print $cv->recv, "\n"; AnyEve
備忘録：AnyEventとData::MessagePack - D-6 [相変わらず根無し]
備忘録：AnyEventとData::MessagePack 2011年3月 8日 18:38 D | ブログ記事のURL | コメント(0) | トラックバック(0) ちょっとだけ躓いたりしたので、備忘録のため。AnyEventでData::MessagePackを受け取るサーバー use strict; use AnyEvent; use AnyEvent::Socket; use Data::MessagePack; use Data::Dumper; main(); sub main { my $host = undef; my $port = 8888; my $guard = tcp_server $host, $port, sub { my ($fh) = @_; handle($fh); }; my $cv = AE::cv; my $w; $w = AE::signal
はてなグループの終了日を2020年1月31日(金)に決定しました - はてなの告知
はてなグループの終了日を2020年1月31日(金)に決定しました 以下のエントリの通り、今年末を目処にはてなグループを終了予定である旨をお知らせしておりました。 2019年末を目処に、はてなグループの提供を終了する予定です - はてなグループ日記 このたび、正式に終了日を決定いたしましたので、以下の通りご確認ください。 終了日: 2020年1月31日(金) エクスポート希望申請期限:2020年1月31日(金) 終了日以降は、はてなグループの閲覧および投稿は行えません。日記のエクスポートが必要な方は以下の記事にしたがって手続きをしてください。 はてなグループに投稿された日記データのエクスポートについて - はてなグループ日記 ご利用のみなさまにはご迷惑をおかけいたしますが、どうぞよろしくお願いいたします。 2020-06-25 追記 はてなグループ日記のエクスポートデータは2020年2月28
AnyEventでの簡単なFIFOキューの作り方 - D-6 [相変わらず根無し]
AnyEventでの簡単なFIFOキューの作り方 まぁ考えてみれば単純な話ですけど、いわゆるGuardを使うとよいです。参考はAnyEvent::HTTP コールバック$cbの最初の引数をguard変数にしておき、キューの１スロットを使用している間はこのguard変数をundefしないようにしておく感じです。 use strict; use AnyEvent; use AnyEvent::Util; my @q; # 実際にコールバックを入れておくところ my $ACTIVE = 0; # 現在の使用中スロット my $MAX_ACTIVE = 1; # 最大何個のコールバックを「同時」に行うか（もちろん本当に同時じゃないよ！） sub drain_queue { while ( @q && $ACTIVE < $MAX_ACTIVE ) { if (my $cb = shift @q)
ブロッキングする処理を外部プロセスに任せる - AnyEvent::Workerを使ってみた - download_takeshi’s diary
AnyEventを使う場合に、どうしてもブロッキングしてしまうような処理があるとして、それを外部プロセスとして切り出しつつ、メインのイベントループの中に取り込みたいんだよな、と。 そんな時はAnyEvent::Workerがよさそうです。 AnyEvent::Worker - Manage blocking task in external process http://search.cpan.org/~mons/AnyEvent-Worker/ POEで言うところのPOE::Component::Genericのようなものらしいです。使いこなせるようになるといろいろと便利！ use strict; use warnings; use AnyEvent; use AnyEvent::Worker; $|++; print _timestamp(), "開始しまーす\n"; my $cv =
AnyEvent and Plack
This document discusses AnyEvent, a module for asynchronous programming in Perl using non-blocking I/O. It provides an overview of how AnyEvent works and can be used to build event-driven applications. The document also covers Plack and PSGI, describing them as standards for building web applications in Perl using a common interface that can run on different web servers via middleware like Plack.R
Perl 非同期プログラミング
1. 非同期プログラミング with Perl 2010/08/07 Japan Perl Association 代表理事 株式会社ライブドア 牧 大 輔 (@lestrrat) 3. 普通の書き方 use strict; use LWP::UserAgent; my @urls = qw( http://www.livedoor.com/ http://www.dena.jp/ http://mixi.jp/ http://www.gaiax.co.jp/ ); my $ua = LWP::UserAgent->new(); foreach my $url (@urls) { my $res = $ua->get( $url ); ... }
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
AnyEventのサンプル。イベントループの中にイベントループを持つ。 - KJ blog