本連載では第一線のPerlハッカーが回替わりで執筆していきます。第2回は、Japan Perl Association代表理事の牧大輔さんで、テーマはAnyEventです。 はじめに 昨今のPerl界で最も熱い話題がイベント駆動プログラミングです。イベント駆動プログラミングはいわゆる「リアルタイムWeb」などと呼ばれる、大量のデータや接続をさばきつつも更新通知の速さが重要となるアプリケーションでは必須技術で、今後のエンジニアにとって最も重要な知識の一つと言えるでしょう。 イベント駆動プログラミング自体はPerlでも以前からさまざまな用途に使われてきましたが、それがまた見直されているのは、従来のイベント駆動プログラミング用ツールキットの使いやすさをはるかに凌駕するAnyEventというモジュールが成熟期を迎えたためです。 イベント駆動プログラミングとは AnyEventの解説に入る前に、簡単
ChirpUserStreamsを簡単に使えるようにしてみました レポジトリ GitHub - punytan/AnyEvent-Twitter-Chirp: DEPRECATED INSTALLATION % git clone git://github.com/punytan/AnyEvent-Twitter-Chirp.git % cd AnyEvent-Twitter-Chirp/ % perl Makefile.PL % make % make test % sudo make install ChirpUserStreamsって何?という方はこちらを Twitterの新しいStreaming API「ChirpUserStreams」がすごすぎる件 - すぎゃーんメモ これを簡単に使えるようにしたモジュールです ドキュメント % perldoc AnyEvent::Twitte
ただ作ってみたくなったので実装してみました。発言されたURLのタイトルとContent-Typeを返すボットです。 GitHub - punytan/mobijiro: IRC bot 名前はアレを真似てつけました。 レスポンスの文字コード AnyEvent::HTTP::http_get で取得すると、 UTF-8 だったり、 EUC-JP であったりと、 body の文字コードが何か検討がつかない。 なので、 HTTP::Message の decoded_content を使うことでそのあたりの処理を楽にしています。 その役割を担うのが Tatsumaki::HTTPClient で、説明はこちら(Tatsumaki::HTTPClientというモジュールの紹介 - punitan (a.k.a. punytan) のメモ)を参照ください。 ソース use strict; use w
よく知らないまま、はじめてplackupを使ってみていたのだけど、ちょっと困っていたので何気なく呟いてみたら… sugyan plackup -R が若干負荷が高くて膝の上にMacBook載せて作業するには熱くなりすぎる…！ 2010/04/03(土) 15:38:34 miyagawa @sugyan try plackup -L Shotgun instead 2010/04/03(土) 15:41:13 miyagawa @sugyan or install Mac::FSEvents 2010/04/03(土) 15:44:43 sugyan @miyagawa ありがとうございます！ さっそくいれてみます 2010/04/03(土) 15:48:00 sugyan そっか、Filesys::Notify::Simpleってのが中でMac::FSEvents(もしくはLinux::
以前、AMQP と RabbitMQ を学ぶために RabbitFoot という名前の Perl 版のクライアントライブラリを作成したのですが、非同期化して欲しいと要望を頂いたので、AnyEvent と Coro を利用してみました。 AnyEvent と Coro は、今回、初めての利用となるため、識者からの厳しいツッコミがあると嬉しいです。 cooldaemon's RabbitFoot at master - GitHub Consume 用の Channel を五つ、Publish 用の Channel を一つ開き、Channel 間でメッセージを送受信する例は、下記の通りです。 use Coro; use RabbitFoot; my $rf = RabbitFoot->new()->load_xml_spec( '/path/to/fixed_amqp0-8.xml', )->
サキとは彼女の自宅近く、湘南台駅前のスーパーマーケットで待ち合わせをした。彼女は自転車で後から追いつくと言い、僕は大きなコインパーキングへ車を停めた。煙草を一本吸ってからスーパーマーケットへ向かうと、ひっきりなしに主婦的な女性かおばあちゃんが入り口を出たり入ったりしていた。時刻は午後5時になる。時計から目を上げると、待たせちゃったわねと大して悪びれてない様子でサキが手ぶらでやってきた。 お礼に料理を作るとはいえ、サキの家には食材が十分足りていないらしく、こうしてスーパーマーケットに寄ることになった。サキは野菜コーナーから精肉コーナーまで、まるで優秀なカーナビに導かれるように無駄なく点検していった。欲しい食材があると、2秒間程度それらを凝視し、一度手に取ったじゃがいもやら豚肉やらを迷うことなく僕が持っているカゴに放り込んだ。最後にアルコール飲料が冷やされている棚の前へ行くと、私が飲むからとチ
AnyEvent はじめ そろそろAnyEventでもやってみようと思ったので AntEvent::Handle いわゆるIOまわりの面倒を色々便利にやってくれる君。イベントベースなIOと言うよりかはevent queueなIOみたいな捉え方するとすんなり。 read/writeの処理はqueue的な感じで登録できるの。 ->push_read() で、どんどんqueueにreadイベントを登録してく。fhがreadableになったらread queueがどんどん処理されるってわけ。 ->unshift_read() だと、queueの先頭に突っ込んでく。 そう、まさしくperlのarrayへのpush/unshiftそのもの。AnyEvent::Introを読むとその辺の命名に関する思いが読める。 ->push_write() だと、writeイベントを登録してく。writeできるように
オススメCPANモジュールその1。 AnyEvent というわけで、俺の独断と偏見によるオススメモジュールのコーナーです。 AnyEvent は poll/select/kqueue/epoll(4) などのイベントループを抽象化するライブラリです。似たような目的のものとして Danga::Socket, POE などがありますが、ライブラリ全体のインターフェースの完成度や速度などの点から AnyEvent を僕は一番押しています。 Pure Perl で利用できますし、インターフェースも安定しています。まだバリバリ開発されてますが、backward incompat な変更はされないようです。 作者が mlehmann 氏ということで、ドキュメントは丁寧ですが攻撃的な文章が目立ちますし、バグレポートすると異常な長文がかえってきたりするのでうっとーしかったりしますが、コードの品質はたかいの
社内で Shibuya.pm*1でmiyagawaさんのTatsumakiの話を聞く上での予備知識のつもりな勉強会をするので、利用するスライドだけ貼っておきます。 AnyEvent and PlackView more documents from hiratara. *1:自分は行けなくなりましたが・・・orz
Tatsumaki is a non-blocking web framework for Perl built on Plack and AnyEvent. It allows building asynchronous applications that can handle thousands of concurrent connections. Tatsumaki uses psgi.streaming to enable asynchronous responses. It includes a non-blocking HTTP client and pure Perl message queue for building real-time applications like chat and comet. The framework is in a beta stage b
全裸botが規制されてから、２週間。復活の兆しは見えない。 ということで、我慢しきれず全裸bot2(@zenra_bot2)というアカウントを作成した。 GAEで動かしていたヤツでそのままアカウントだけ変更して動かしてもよかったのだけど、それだけだとあまりにも能が無いかなー、と思いPerlで作り直してみた。 Twitter botというと、普通は定期的に呟いたりするので、大抵はcronとかそれと同等の機能を持つサービスなんかを利用すると思う。 今回はそれを使わずに1つのスクリプトだけで完結するよう、Coro::AnyEventを使って複数の処理を定期的に動かすようにしてみた。 http://search.cpan.org/~mlehmann/Coro-5.2/Coro/AnyEvent.pm use strict; use warnings; use Coro; use Coro::Any
それってHamakiなんですが、試しに作ってみたので一応。ただし、Tatsumakiは、 This is considered as alpha quality software. Most of the stuff are undocumented since it's considered unstable and will likely to change. You should sometimes look at the source code or example apps in eg directory to see how this thing works. Tatsumaki なので自己責任で:-p 後、このエントリより eg/chat を見た方が勉強になりますｗ Tatsumaki概要 TatsumakiはPlackとAnyEventをベースにしたTornadoっぽくWE
諸事情により、AnyEvent::TwitterのWassrバージョンが欲しかったので、作ってみた。 AnyEvent::Twitter - search.cpan.org 基本的にはこのAnyEvent::Twitterのパクリ。じゃっかんインターフェースを自分好みに変更してたりもするけれど。 ドキュメントは無いですゴメンナサイ！！ いちおう特徴 認証はBASIC認証一択 friends_timelineとrepliesを取得可能 内部でAnyEvent::HTTPを使ってAPIアクセス、AnyEventのtimerを使って自動繰り返し weightによる取得頻度の調整はAnyEvent::Twitterと同様 APIの使用回数制限は無いので、intervalで指定した秒数毎に取得(デフォルトは60秒とした) Twitter APIでは指定idより新しいもの、という指定が出来たけどWas
自分専用TwitterのWeb UI 「Hamaki」 ミニブログサービスで先行するTwitterと差別化を図った上で新たなサービスを出すのは面倒くさいので、id:miyagawa氏のコードを丸々パクった上でTwitter支援ツール、Hamakiを機能の夜からちょこちょこと開発しました（本当はTwitter以上に色々できるんですが、そのあたりはまださわってない） もう自分がやりたい事はだいたいできるようになったのでとりあえず公開です。 まず前提としてTwitterを使ってていくつか不満な点があったわけです： Twitterで特定のアプリの発言がちょっぴり気になるので自分のTLに表示したくないかといって上記アプリの発言している人たちの他の発言は読みたいので、それらの人をremoveするのもしたくない。あと、全般的にtwitterをリロードするような事をしていると非常に効率が悪いかといって、今
前回のエントリでは簡単なクローラの作り方を説明した。しかしこのクローラには欠点があり、取得したいURLが何千何万とある場合、一度にhttp_getが走ってしまい、リソースを使い切ったり同じサーバーへのアクセスを待つ間にタイムアウトしたりと都合が悪かった。そこで今回はAnyEventに加えCoroを使うことにより、並列を使ってリソースへの同時アクセス制限を行うクローラの書き方を解説する。 これは前回のエントリの改良版になるので、初めてこれを読む方は当該エントリを先に読んで頂きたい。 まず、前回はAnyEventを使い、condvarとsend-recvを使ってイベントの監視をしていたが、Coroと同時に使う場合これでは都合が悪い。イベントループを回す場合、一般的にAnyEventはrecvを、Coroはjoinを使うが、これらはどちらもイベントループが終わるまでブロックするのでどちらかし
Twitermで、AnyEvent::Twitterを使っているのだけど、これはBASIC認証のみ対応していて、現時点ではOAuthは使えない。 でも個人的にはPOST時にクライアント名を表示させたいし、OAuthをまだほとんど使ったことがなかったので使い方を学びたい。 ということで、下記を参考にしながらパッチモジュールを書いてみた。 404 Blog Not Found:perl - パッチなしでパッチする package AnyEvent::Twitter::EnableOAuth; use strict; use warnings; use base qw/Object::Event/; use AnyEvent::HTTP; use Carp 'croak'; use Encode 'encode_utf8'; use Digest::SHA; use JSON 'decode_j
Terminal上で動作するTwitter閲覧ツール「Twiterm」を作った - すぎゃーんメモにて、初めてAnyEvent::Twitterというモジュールを使ってみたのだけど、使い方を激しく勘違いしていたので、正しい使い方をメモっておく。 AnyEvent::Twitter - search.cpan.org バージョン 2009年9月末時点では最新は0.26。 最も簡単なサンプル use strict; use warnings; use AnyEvent; use AnyEvent::Twitter; # ユーザー名、パスワードを引数から取得 my ($username, $password) = @ARGV; my $twitty = AnyEvent::Twitter->new( username => $username, password => $password, );
POEからAnyEventに移すのはどんな感じか、試しにやってみます。 最初にまとめ 恐らく問題となるのはPOEのイベント呼び出しとAnyEventのコールバックの仕組みのギャップですが、AnyEventではメソッドを呼び出すコールバックを渡すことでPOEのイベント呼び出しが表現できます*1。 特にpostやyieldに関しては、POE::Sessionの持つHEAPをオブジェクトにして、AE::timerでメソッドを遅延呼び出しすれば同等の処理を表現できます。 0. 題材 以下のような単純なPOEのコードをAnyEventにしましょう。 use strict; use warnings; use POE; POE::Session->create( inline_states => { _start => sub { print "Started.\n"; $_[HEAP]->{coun
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
