Red Hat Summit Red Hat Summitサポートコンソール開発者トライアルの開始お問い合わせ

第6章 JMS の使用

HornetQ は JMS 不明メッセージング API を提供しますが、多くのユーザーは JMS をより快適に使用できます。
JMS は非常に人気があるメッセージング用の API 標準であり、ほとんどのメッセージングシステムは JMS API を提供します。
この項では、JMS に対してサーバーを設定し、単純な JMS プログラムを作成する主な手順について説明します。また、JNDI を設定および使用する方法と JNDI を使用せずに HornetQ で JMS を使用する方法についても説明します。

6.1. 単純な注文システム - 設定例
リンクのコピー

この設定例では、OrderQueue という名前の JMS キューが、そのキューに注文メッセージを送信する単一の MessageProducer とともに使用されます。単一の MessageConsumer は、キューからの注文メッセージを消費します。
このキューは durable に設定されます (サーバーの再起動後やクラッシュ後も保持されます)。
また、この例では、クライアントからキューを明示的に作成せずにキューが自動的に作成されるよう、サーバー JMS 設定でキューを指定する方法についても説明します。

6.1.1. JMS サーバー設定
リンクのコピー

サーバークラスパスのファイル hornetq-jms.xml (標準設定 JBOSS_DIST/jboss-as/server/PROFILE/deploy/hornetq/hornetq-jms.xml 内) には、作成し、JNDI を介してルックアップできる JMS キュー、トピック、および ConnectionFactory インスタンスが含まれます。
JMS ConnectionFactory オブジェクトは、サーバーに対する接続を確立するためにクライアントによって使用されます。このオブジェクトは、接続するサーバーの場所と他の多くの設定パラメーターを認識します。ほとんどの場合は、デフォルト値を使用できます。
この例では、サーバーに単一の JMS キューと単一の JMS 接続ファクトリーインスタンスがデプロイされますが、ファイルからデプロイできるキュー、トピック、および ConnectionFactory インスタンスの数に制限はありません。 
<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:hornetq ../schemas/hornetq-jms.xsd ">
   <connection-factory name="NettyConnectionFactory">
      <connectors>
         <connector-ref connector-name="netty"/>
      </connectors>
      <entries>
         <entry name="/ConnectionFactory"/>           
      </entries>
   </connection-factory>
   <queue name="OrderQueue">
      <entry name="queues/OrderQueue"/>
   </queue>
</configuration>
Copy to Clipboard Toggle word wrap
ConnectionFactory という名前の接続ファクトリーがデプロイされ、entry 要素で提供されたように JNDI の １ つの場所でバインドされます。ConnectionFactory インスタンスは JNDI の多くの場所でバインドできます (必要な場合)。

注記

JMS 接続ファクトリーは、netty という名前の connector を参照します。これは、サーバーに実際に接続するために使用されるトランスポートとパラメーターを定義する主要なコア設定ファイル JBOSS_DIST/jboss-as/server/PROFILE/deploy/hornetq/hornetq-configuration.xml でデプロイされた connector オブジェクトの参照です。

6.1.2. 接続ファクトリータイプ
リンクのコピー

JMS API doc は、アプリケーション用の複数の接続ファクトリーを提供します。HornetQ JMS ユーザーは、これらの接続ファクトリーに対してタイプを設定するよう選択できます。各接続ファクトリーは signature 属性と xa パラメーターを持ち、これらの組み合わせによってファクトリーのタイプが決定されます。
属性 signature は 3 つの文字列値 (generic、queue、および topic) を持ちます。
xa はブール値タイプのパラメーターです。以下の表は、さまざまな接続ファクトリーインターフェースに対する設定値を示しています。
Expand
表6.1 接続ファクトリータイプの設定
signature xa 接続ファクトリータイプ
generic (デフォルト値) false (デフォルト値) javax.jms.ConnectionFactory
generic true javax.jms.XAConnectionFactory
queue false javax.jms.QueueConnectionFactory
queue true javax.jms.XAQueueConnectionFactory
topic false javax.jms.TopicConnectionFactory
topic true javax.jms.XATopicConnectionFactory
以下の例では、XAQueueConnectionFactory が設定されます。 
<configuration xmlns="urn:hornetq" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="urn:hornetq ../schemas/hornetq-jms.xsd ">
    
    <connection-factory name="ConnectionFactory" signature="queue">
        <xa>true</xa>
        <connectors>
           <connector-ref connector-name="netty"/>
        </connectors>
        <entries>
            <entry name="/ConnectionFactory"/>           
        </entries>
    </connection-factory>
</configuration>
Copy to Clipboard Toggle word wrap

6.1.3. コード
リンクのコピー

この例のコードは以下で利用可能です。
最初の手順では JMS オブジェクトをルックアップする JNDI 初期コンテキストを作成します。 
InitialContect ic = new InitialContext();
Copy to Clipboard Toggle word wrap
次の手順では、接続ファクトリーをルックアップします。 
ConnectionFactory cf = (ConnectionFactory)ic.lookup("/ConnectionFactory");
Copy to Clipboard Toggle word wrap
次に、キューをルックアップします。 
Queue orderQueue = (Queue)ic.lookup("/queues/OrderQueue");
Copy to Clipboard Toggle word wrap
次に、接続ファクトリーを使用して JMS 接続を作成します。 
Connection connection = cf.createConnection();
Copy to Clipboard Toggle word wrap
AUTO_ACKNOWLEDGE 承認モードで非トランザクション JMS セッションを作成します。 
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Copy to Clipboard Toggle word wrap
キューに注文を送信する MessageProducer を作成します。 
MessageProducer producer = session.createProducer(orderQueue);
Copy to Clipboard Toggle word wrap
キューから注文を消費する MessageConsumer を作成します。 
MessageConsumer consumer = session.createConsumer(orderQueue);
Copy to Clipboard Toggle word wrap
接続を開始するようにしてください。開始しないと、配信が実行されません。 
connection.start();
Copy to Clipboard Toggle word wrap
単純な TextMessage を作成し、送信します。 
TextMessage message = session.createTextMessage("This is an order");
producer.send(message);
Copy to Clipboard Toggle word wrap
メッセージを消費します。 
TextMessage receivedMessage = (TextMessage)consumer.receive();
System.out.println("Got order: " + receivedMessage.getText());
Copy to Clipboard Toggle word wrap

警告

JMS 接続、セッション、プロデューサー、およびコンシューマーが再使用されるよう設計されます。
生成または消費する各メッセージに対して新しい接続、セッション、プロデューサー、およびコンシューマーを作成することは不適切です。これを行うと、アプリケーションのパフォーマンスが大幅に低下します。この詳細については、43章パフォーマンスチューニング を参照してください。
トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat