# JMS 点对点消息示例

> 原文： [https://howtodoinjava.com/jms/jms-point-to-point-message-example/](https://howtodoinjava.com/jms/jms-point-to-point-message-example/)

在 [JMS 教程](//howtodoinjava.com/jms/jms-java-message-service-tutorial/)中，您了解了 JMS 消息传递域 Point to Point Domain 和 [Publish Subscribe Domain](//howtodoinjava.com/jms/jms-publish-subscribe-message-example) 。 在此示例中，我们将通过点对点消息传递域进行示例。 在点对点消息中，发送方将消息传递到队列，**单个接收方从队列**中取出消息。 接收者在发送消息时不需要监听队列。

![Point to point JMS Messaging](img/bc73b3600c6fbf951c9ae14c7b6445b3.png)

Point to point JMS Messaging



## 点对点消息发布者应用程序流程

下面给出了发送方应用程序的典型点对点消息传递示例。 该应用程序的以下步骤是 –

1.  首先，我们将获取 JMS 服务器的 Initial Context 对象。
2.  之后，使用初始上下文对象查找队列对象。
3.  同样，我们将使用初始上下文对象来查找队列连接工厂。
4.  然后，使用队列连接工厂来创建队列连接，因为它表示 JMS 服务器的物理连接。
5.  创建队列连接工厂后，我们将创建队列会话，其中第一个参数将决定会话是否被事务处理。 但是，我们将使用非交易会话。
6.  此后，为队列创建一个队列发件人，然后创建一条消息。
7.  然后将诸如“ Hello World”之类的消息发送到队列对象。
8.  关闭队列连接后，关闭队列连接后，它将自动关闭会话和队列发送者。

让我们看下面的例子：

```java
package pointToPoint;                                                                      
import javax.naming.InitialContext;

import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.QueueSender;
import javax.jms.DeliveryMode;
import javax.jms.QueueSession;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;

public class Sender
{
    public static void main(String[] args) throws Exception
    {
       // get the initial context
       InitialContext context = new InitialContext();

       // lookup the queue object
       Queue queue = (Queue) context.lookup("queue/queue0");

       // lookup the queue connection factory
       QueueConnectionFactory conFactory = (QueueConnectionFactory) context.lookup ("queue/connectionFactory");

       // create a queue connection
       QueueConnection queConn = conFactory.createQueueConnection();

       // create a queue session
       QueueSession queSession = queConn.createQueueSession(false, Session.DUPS_OK_ACKNOWLEDGE);

       // create a queue sender
       QueueSender queSender = queSession.createSender(queue);
       queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

       // create a simple message to say "Hello World"
       TextMessage message = queSession.createTextMessage("Hello World");

       // send the message
       queSender.send(message);

       // print what we did
       System.out.println("Message Sent: " + message.getText());

       // close the queue connection
       queConn.close();
    }
}

```

## 点对点消息传递订户应用程序流程

接收方的大多数步骤与发送方应用程序相同 – 除了它将侦听消息而不是发送 JMS 消息外。

```java
package pointToPoint;
import javax.naming.InitialContext;                                                                        
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.QueueSession;
import javax.jms.QueueReceiver;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;

public class Receiver
{
    public static void main(String[] args) throws Exception
    {
       // get the initial context
       InitialContext context = new InitialContext();

      // lookup the queue object
       Queue queue = (Queue) context.lookup("queue/queue0");

       // lookup the queue connection factory
       QueueConnectionFactory conFactory = (QueueConnectionFactory) context.lookup ("queue/connectionFactory");

       // create a queue connection
       QueueConnection queConn = conFactory.createQueueConnection();

       // create a queue session
       QueueSession queSession = queConn.createQueueSession(false,   
       Session.AUTO_ACKNOWLEDGE);

       // create a queue receiver
       QueueReceiver queReceiver = queSession.createReceiver(queue);

       // start the connection
       queConn.start();

       // receive a message
       TextMessage message = (TextMessage) queueReceiver.receive();

       // print the message
       System.out.println("Message Received: " + message.getText());

       // close the queue connection
       queConn.close();
    }
}

```

在上面的代码中，接收方将接收来自发送方的消息并进行打印，即 Hello World。 但是，如果未启动连接，则方法接收器将被阻塞，直到其他任何线程启动连接为止。

学习愉快！