Tweet

非同期処理と疎結合ができる「メッセージング」の常識

■受信側アプリケーション（SampleReceiver.java）

　受信側のアプリケーションであるSampleReceiver.javaは、testQueueトピックへテキストメッセージを受信するプログラムです。

　まず、JNDIを用いて接続先を取得します（図5の【1】）。

// JNDIイニシャルコンテキストを取得します。
context = new InitialContext();
// 接続ファクトリを取得します。
ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("ConnectionFactory");

　次に、取得した接続先に対して接続を行います（図5の【2】）。

// 接続を作成します。
conn = connectionFactory.createConnection();
// 宛先をルックアップします。
Queue queue = (Queue) context.lookup("/queue/testQueue");
// セッションを作成します。
Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

　接続を行ったら、メッセージを受信します。メッセージが受信できるまでは終了せずに、待ち受け状態になります（図5の【6】）。

// メッセージを受信します。
MessageConsumer msgConsumer = session.createConsumer(queue);
conn.start();
TextMessage msg = (TextMessage) msgConsumer.receive();

　メッセージを受信すると、受信したメッセージをコンソールに出力するので、受信したメッセージを確認できます。

if (msg == null) {
    System.out.println("受信NG");
} else {
    System.out.println("受信OK: [" + msg.getText() + "]");
}

■送信側アプリケーション（SampleSender.java）

　送信側のアプリケーションであるSampleSender.javaは、testQueueトピックからテキストメッセージを送信するプログラムです。

　まず、JNDIを用いて接続先を取得しています（図5の【3】）。

// JNDIイニシャルコンテキストを取得します。
context = new InitialContext();
// 接続ファクトリを取得します。
ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("ConnectionFactory");

　接続が完了したらメッセージを送信します。送信するメッセージは、「Hello World!!!」としています（図5の【5】）。

// メッセージ送信します。
MessageProducer msgProducer = session.createProducer(queue);
msgProducer.send(session.createTextMessage("Hello World!!!"));

　メッセージが送信されると、受信側の応答を待つことなく終了します。

■設定ファイル（jndi.properties）

　jndi.propertiesは、JavaVMがどのJNDIサーバを使うのかを設定する設定ファイルです。今回は、ローカル環境のサーバを用いるのでローカル環境への接続が設定されています。

java.naming.provider.url=jnp://localhost:1099

　これらのファイルを、それぞれ以下のように配置します。

図17　サンプルプログラムの配置

　また、以下のようにJARファイルをビルド・パスに含めてください。

図18　ビルド・パスの追加

　以上で、サンプルの実行環境が整いました。

メッセージングをサンプルで体感してみよう

　それでは、実行してみましょう。C:\jboss-4.2.3.GA\bin\run.batを実行し、サーバを立ち上げます。SampleReceiverを実行すると、メッセージの受信待ち状態になります。

図19　SampleReceiverのメッセージ受信待ち状態

　SampleSenderを実行し、メッセージを送信してください。送信されるテキストは「Hello World!!!」です。送信が完了すると、SampleSenderは終了します。

図20　SampleSenderのメッセージ送信

　受信待ちのSampleReceiverのコンソールにSampleSenderが送信したメッセージが受信されています。

図21　SampleReceiverのメッセージ受信完了

　以上で、JBoss Messagingの動作確認は終了です。

　今回の動作確認では、受信側のアプリケーションを先に実行していますが、受信側のアプリケーションを実行していなくても、送信側のアプリケーションは問題なくメッセージを送信できます。その場合、メッセージは受信側のアプリケーションを実行した時点で受信可能です。

メッセージングとも関連する「Webサービス」の常識

　今回は、メッセージングについて説明しました。今後、読者の皆さんがメッセージングの構築に携わることになったら、ここでの知識を少しでも生かしていただければと思います。

　次回は、今回のメッセージングとも関連性が強い「Webサービスの常識」について解説します。Webサービスとは、一体どういうものなのかに焦点を当てたいと思います。

■ ＠IT関連記事

イロイロな分散処理技術とイマドキのWebサービス いま再注目の分散処理技術（中編）　昔からある分散処理技術は実は、SOAPやRESTなど現在流行している“Webサービス”へと連なる。いろいろな“分散”の形を見てみよう 「Java Solution」フォーラム 2008/9/16

J2EEと外部システムを連携する方法 [連載]Java初心者のためのWebシステム入門(7)　J2EEがサポートする接続方法は多様だ。今回はJ2EEと外部のシステムとの連携方法を解説する 「Java Solution」フォーラム 2002/7/23

Javaのメッセージング・サービスを速くするには？ WebSphereサーバ・チューニング入門（7）　今回はJMSについて、デリバリー・モードやデータバッファ、処理の並列度などの点から、パフォーマンスチュ−ニングを試みます 「Java Solution」フォーラム 2008/8/7

1-2-3-4

Index

第5回　非同期処理と疎結合ができる「メッセージング」の常識   Page1 君に届け、「メッセージング」とは何か？ メッセージ指向ミドルウェアのJava標準API「JMS」とは   Page2 JMSのAPIを実装した代表的なミドルウェア JBoss Messagingを使うための環境を構築   Page3 JBoss Messagingは、こうやって実装する！   Page4 メッセージングをサンプルで体感してみよう メッセージングとも関連する「Webサービス」の常識

Java Solution全記事一覧

＠ITメールマガジン　新着情報やスタッフのコラムがメールで届きます（無料）

RSSフィード