« イメチェン | メイン | Slashdot's HW/SW Infrastructure »

Net::Stomp - ActiveMQでMessaging Queueやってみた

'07。10。26のTech-RD MTGでの内容である Net::Stomp - ActiveMQで

Message Queueの話。

もともと、Sennaに気合入れるはずだったのに、なんだかへんだったので

K国のD社のLさんから"Net::Stompをしらべて見たら?"といわれた!

で、CPANで検索して Module Install.

daemonとして、activeMQっていう Apache Software Foundationのものがいいと言われてそれをInstall. ベースはJAVAなんで JDK必須かも(いつのまにかInstallされていたのかな)

1. activeMQを立ち上げて
2. Stomp Clientを書く

#!/usr/bin/perl
# stomp.pl

use Net::Stomp;
my $stomp = Net::Stomp->new( { hostname => 'localhost', port => '61626' });
$stomp->connect( { login => 'rotfl', passcode => 'orzorz' });
$stomp->send({ destination => '/queue/foo', body => "This is Sparta~!!!" });
$stomp->disconnect;

こんなスクリプトを書いて perl stomp.pl やってみると!!!!!
.
.
.
.
なにもでてこない。activeMQにはなにもかわったことないらしいし。

で、CPANのTutorialをみると

#!/usr/bin/perl
# stomp_sub.pl
use Net::Stomp;
my $stomp = Net::Stomp->new( { hostname => 'localhost', port => '61626' });
$stomp->connect( { login => 'rotfl', passcode => 'orzorz' });
$stomp->subscribe(
{ destination => '/queue/foo',
'ack' => 'client',
'activemq.prefetchSize' => 10
});
while(1) {
my $frame = $stomp->receive_frame;
warn $frame->body;
$stomp->ack( { frame => $frame });
}
$stomp->disconnect;

こんなものがあり、なにかと思ったら
前のがMessage Sendで これがMessage Receiveっていう感じ?
/queue/fooでどんどん貯まってる "This is Sparta!!!!!!"がどんどん出て来る!
これで、"あーできるんだ"で終りではないんでしょう?

ちょっとやってみよう!
.
.
.
.
あとで....

トラックバック

このエントリーのトラックバックURL:
http://blog.infomarks.co.jp/cgi-bin/mt3/mt-tb.cgi/54

コメントを投稿

(いままで、ここでコメントしたことがないときは、コメントを表示する前にこのブログのオーナーの承認が必要になることがあります。承認されるまではコメントは表示されません。そのときはしばらく待ってください。)

About

2007年10月26日 21:18に投稿されたエントリーのページです。

ひとつ前の投稿は「イメチェン」です。

次の投稿は「Slashdot's HW/SW Infrastructure」です。

他にも多くのエントリーがあります。メインページアーカイブページも見てください。

Powered by
Movable Type 3.34