發(fā)送消息

J2EE參考實現(xiàn)預先配有一個隊列連接工廠（名為QueueConnectionFactory）和一個隊列（名為jms/Queue）。如果你使用的是JMS服務器，而不是參考實現(xiàn)，或者如果你想試著更改隊列連接工廠和/或隊列隊列的名稱，請參考配置服務器一節(jié)。

下面是通過一個JMS隊列發(fā)送消息的步驟。從示例程序TestQueue中抽出的代碼片段也穿插在這些步驟中。

通過按名字在JNDI中進行查找，獲得一個指向QueueConnectionFactory 的引用：

    protected static String qfactoryName =3.
            "jms/queue/TechTipsQueueConnectionFactory";4.
         ...
         try {
         // 獲得JNDI上下文
         InitialContext ctx = new InitialContext();
         // 獲得連接工廠
         QueueConnectionFactory qcf =
         (QueueConnectionFactory)ctx.lookup(qfactoryName);

2.從 QueueConnectionFactory獲得一個QueueConnection，再從這個連接獲得一個QueueSession 。按名字在JNDI中查找：

      // 獲得一個到隊列的連接
       qc = qcf.createQueueConnection();
       //從該連接獲得一個會話
       QueueSession qs = qc.createQueueSession(
           false, Session.AUTO_ACKNOWLEDGE);
      // 獲得一個隊列
      Queue q = (Queue)ctx.lookup(queueName);

3. 使用QueueSession創(chuàng)建一個QueueSender，將該隊列作為一個參數(shù)來傳遞。（QueueSender是QueueSession與某個特定隊列之間的一個關(guān)聯(lián)。）：

      // 使用這個會話創(chuàng)建一個QueueSender 
      // and a TextMessage.
      QueueSender qsnd = qs.createSender(q);

現(xiàn)在可以用QueueSender來發(fā)送消息到隊列。

4. 創(chuàng)建一個消息對象（Message的子類），然后使用QueueSender的發(fā)送方法將它們發(fā)送至目的地。示例程序從Session中獲得一個TextMessage對象。接著示例程序?qū)⒚總€程序參數(shù)打包到TextMessage 中，然后使用QueueSender將其發(fā)送至隊列。注意，同一個TextMessage 可以使用多次。

      TextMessage tm = qs.createTextMessage();
       
      // 為第一個參數(shù)之后的每個參數(shù)進行一次循環(huán)
      // 以文本消息的形式發(fā)送參數(shù)字符串
      for (int i = 2; i < args.length; i++) {
          tm.setText(args[i]);
          qsnd.send;
      }

5.關(guān)閉QueueConnection。在try/finally程序塊的最后一條語句中關(guān)閉連接是一個好習慣。這一步很重要：忘記關(guān)閉 QueueConnections 將可能導致服務器上的資源泄漏：

  } finally {
          if (qc != null) {
              qc.close();

          }
      }

要發(fā)送消息到一個消息隊列，可以使用TestQueue程序（在缺省的包中），加上一個參數(shù)“send”，例如：

$ java TestQueue send jms/queue/MyTestQueue a b c d
Java Message Service 1.0.2 Reference
Implementation (build b14)
Sent: 'a'
Sent: 'b'
Sent: 'c'
Sent: 'd'

接收消息

TestQueue程序按照以下步驟接收消息：

和2從一個消息隊列接收消息的起先兩步與發(fā)送消息是一樣的：先是查找連接工廠，再獲得一個QueueConnection，然后查找Queue。
從QueueSession 獲得一個QueueReceiver ：
QueueReceiver qrcv = qs.createReceiver(q);
3.    從Queue接收消息。示例程序進入一個循環(huán)，在這個循環(huán)中從隊列獲取消息并將它們打印到標準輸出設備。

         qc.start();
         Message m = qrcv.receive(10000);
         while (m != null) {

             if (m instanceof TextMessage) {
                 TextMessage tm = (TextMessage)m;
              System.out.println("Received text: '" +
                                 tm.getText() + "'");
          } else {
              System.out.println("Received a " +
                              m.getClass().getName());
          }
          m = qrcv.receive(100);
      } finally {
         if (qc != null) {
             qc.close();
          }
      }

對QueueConnection的啟動方法的調(diào)用將告訴連接開始接收消息。QueueReceiver接收方法帶有一個參數(shù)，該參數(shù)表明了等待一條消息的毫秒數(shù)。如果消息沒有在規(guī)定時間內(nèi)到達，該方法將返回null值。直到消息隊列在100毫秒的時間內(nèi)都保持為空，程序才開始讀取和打印收到的消息。在try/finally程序塊的結(jié)尾有一個finally子句，該子句像前面例子中一樣地關(guān)閉QueueConnection。

要接收消息隊列中的消息，可以使用TestQueue程序，再帶上一個參數(shù)“recy”，例如：

$ java TestQueue recv jms/queue/MyTestQueue
Java Message Service 1.0.2 Reference
Implementation (build b14)
Received text: 'a'
Received text: 'b'
Received text: 'c'
Received text: 'd'

配置服務器

如果你使用的不是參考引用，或者你想更改隊列和/或隊列連接工廠的名字，你就需要通過使用平臺的管理工具配置JMS提供者。隊列或者連接工廠被創(chuàng)建之后，便留在服務器中，直到服務器重新啟動。有些平臺實現(xiàn)可能會為客戶端提供擴展API，以便程序化地創(chuàng)建目的地和連接工廠。

用來在J2EE SDK下創(chuàng)建受管理的對象的工具是。要配置服務器，需：

啟動應用服務器。
Create a message queue, giving it a JNDI name. (Do this only once.) To create a
new message queue in the J2EE SDK, first decide on a name for your message
queue. It can be convenient for administration purposes to choose a name that
indicates that the queue is used by JMS, for example, jms/MyTestQueue. Then
execute the command:創(chuàng)建一個消息隊列，并為它取一個JNDI名。（只做一次。）要用J2EE SDK創(chuàng)建一個新的消息隊列，首先需要為消息隊列決定一個名字。為了便于管理， 應該選擇一個可以表明該隊列是JMS使用的隊列，例如jms/MyTestQueue。然后執(zhí)行命令：
             j2eeadmin -addJmsDestination <queuename> queue

用消息隊列的實際名字替換<queuename> 。

由于連接工廠名QueueConnectionFactory被硬性地放在示例程序中，因此要告訴程序使用一個不同的連接工廠名，就必須修改源代碼，并且重新編譯。例如，在TestQueue.java中：

        // Change this variable's value to change the 
       // connection factory name
       protected static String qfactoryName =
                          "QueueConnectionFactory"

重新編譯之后，使用j2eeadmin（或者你自己的服務器的工具）創(chuàng)建一個connection factory，給它取個JNDI名，如：

j2eeadmin -addJmsFactory jms/MyQueueConnectionFactory

要列出連接工廠，使用：

j2eeadmin -listJmsFactory

要列出目的地，使用：

j2eeadmin -listJmsDestination

對于不是J2EE SDK的平臺，可以在該平臺上使用J2EE產(chǎn)品的部署工具來創(chuàng)建所需的消息隊列和連接工廠。

運行示例代碼

下載這些期的示例存檔。這個JAR文件包含了示例程序的完整源代碼，包括Java程序文件和HTML格式的文件。你可以使用命令jar xvf ttmar2003.jar 將示例jar中的內(nèi)容解壓縮到你的工作目錄下。在運行示例程序前，要確保J2EE服務器正在運行。

多次運行示例程序。試著發(fā)送一些成批的消息，但是不接收這些消息，檢查一下輸出的順序。