JMS 点对点接口

QueueConnectionFactory 是从 JNDI 中检索的受管理对象，它创建了到提供者的连接。它包含 createQueueConnection() 方法，该方法返回一个 QueueConnection 对象。

QueueConnection 封装了链接到提供者的活动连接。它的一些方法包括：

createQueueSession(boolean, int)：返回一个 QueueSession 对象。boolean 参数指出 QueueSession 是否被处理，int 指出确认模式（请参阅 确认）。

start() （从 Connection 继承）：激活提供者发送消息。

stop() （从 Connection 继承）：临时停止发送消息，可以用 start() 重新开始发送。

close() （从 Connection 继承）：关闭到提供者的链接，并释放它占有的所有资源。


QueueSession 是发送和接收 PTP 消息的单线程上下文。它的一些方法包括：

createSender(Queue)：返回 QueueSender来向指定的 Queue 发送消息。


createReceiver(Queue)：返回 QueueReceiver 对象来接收来自指定的 Queue 的消息。


createBrowser(Queue) （从 Session 继承）：返回一个 QueueBrowser 对象来浏览指定 Queue 上的消息。


commit() （从 Session 继承）：提交当前事务中所有已经使用或者产生的消息。


rollback() （从 Session 继承）：回滚当前事务中所有已使用或者已产生的消息。


create<MessageType>Message(...) （从 Session 继承）：返回 <MessageType>Message 的各种方法——例如 MapMessage、TextMessage 等。

Queue 封装了点对点目的地。它是一个从 JNDI 中检索的受管理对象。

QueueSender 被用来发送点对点消息。它的一些方法包括：

send(Message)：发送指示的 Message。


setDeliveryMode(int) （从 MessageProducer 继承）：设置后续消息发送的发送模式，有效值为 DeliveryMode.PERSISTENT 和 DeliveryMode.NON_PERSISTENT。


setPriority(int) （从 MessageProducer 继承）：设置后续消息发送的优先级，有效值为 0 到 9。


setTimeToLive(long) （从 MessageProducer 继承）：设置后面发送的消息失效前的持续时间，以毫秒为单位。


QueueReceiver 被用来接收点对点消息。它的一些方法包括：

receive() （从 MessageConsumer 继承）：返回到达的下一个消息，这个方法会阻塞，直到下一个消息可用为止。


receive(long) （从 MessageConsumer 继承）：接收在 long 毫秒内到达的下一个消息，如果在时间期限内没有消息到达，则返回 null。


receiveNoWait （从 MessageConsumer 继承）：如果当前有一条消息，则接收下一条消息，如果没有消息，则返回 null。


setMessageListener(MessageListener) （从 MessageConsumer 继承）：设置 MessageListener，MessageListener 对象在消息到达时接收它们，即异步方式接收消息。

用 QueueReceiver 接收消息时，在接收消息后从队列中删除她们。用 QueueBrowser 可以查看队列中的消息而不删除它们。完成这项操作的方法是 getEnumeration()，它返回一个可以用来扫描队列中消息的java.util.Enumeration，队列的变化（消息到达或失败）可能是可见的，也可能是不可见的。


例子：

QSender.java 
import java.io.*;
import javax.jms.*;
import javax.naming.*;

public class QSender {

    public static void main(String[] args) {

        new QSender().send();
    }

    public void send() {

        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

        try {
            //Prompt for JNDI names
            System.out.println("Enter QueueConnectionFactory name:");
            String factoryName = reader.readLine();
            System.out.println("Enter Queue name:");
            String queueName = reader.readLine();

            //Look up administered objects
            InitialContext initContext = new InitialContext();
            QueueConnectionFactory factory =
                (QueueConnectionFactory) initContext.lookup(factoryName);
            Queue queue = (Queue) initContext.lookup(queueName);
            initContext.close();

            //Create JMS objects
            QueueConnection connection = factory.createQueueConnection();
            QueueSession session =
                connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            QueueSender sender = session.createSender(queue);

            //Send messages
            String messageText = null;
            while (true) {
                System.out.println("Enter message to send or 'quit':");
                messageText = reader.readLine();
                if ("quit".equals(messageText))
                    break;
                TextMessage message = session.createTextMessage(messageText);
                sender.send(message);
            }

            //Exit
            System.out.println("Exiting...");
            reader.close();
            connection.close();
            System.out.println("Goodbye!");

        } catch (Exception e) {
            e.printStackTrace();
            System.exit(1);
        }
    }
}

QReceiver.java 
import java.io.*;
import javax.jms.*;
import javax.naming.*;

public class QReceiver implements MessageListener {

    private boolean stop = false;

    public static void main(String[] args) {

        new QReceiver().receive();
    }

    public void receive() {

        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

        try {
            //Prompt for JNDI names
            System.out.println("Enter QueueConnectionFactory name:");
            String factoryName = reader.readLine();
            System.out.println("Enter Queue name:");
            String queueName = reader.readLine();
            reader.close();

            //Look up administered objects
            InitialContext initContext = new InitialContext();
            QueueConnectionFactory factory =
                (QueueConnectionFactory) initContext.lookup(factoryName);
            Queue queue = (Queue) initContext.lookup(queueName);
            initContext.close();

            //Create JMS objects
            QueueConnection connection = factory.createQueueConnection();
            QueueSession session =
                connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            QueueReceiver receiver = session.createReceiver(queue);
            receiver.setMessageListener(this);
            connection.start();

            //Wait for stop
            while (!stop) {
                Thread.sleep(1000);
            }

            //Exit
            System.out.println("Exiting...");
            connection.close();
            System.out.println("Goodbye!");

        } catch (Exception e) {
            e.printStackTrace();
            System.exit(1);
        }
    }

    public void onMessage(Message message) {

        try {
            String msgText = ((TextMessage) message).getText();
            System.out.println(msgText);
            if ("stop".equals(msgText))
                stop = true;
        } catch (JMSException e) {
            e.printStackTrace();
            stop = true;
        }
    }
}