ActiveMQ——4.Spring-JmsTemplate之发送与接收

布满荆棘的人生 2021-09-26 09:22 451阅读 0赞

## 发送 ##

## 概述 ##

--------------------

JmsTemplate提供了3组\*3，共计9个发送用的方法。

发送的方法有3组：

1.  基本的发送
2.  转换并发送
3.  转换、后处理再发送

## 必需的资源 ##

--------------------

必需的资源有：

*  javax.jms.ConnectionFactory  
    ConnectionFactory是客户端编程的开始，由它依次获取Connection、Session、Message、MessageProducer或MessageConsumer，从而做好了发送或接收的准备。
 *  javax.jms.Destination  
    Destination是发送的目的地，或者接收的源

实际上，我们提供了上述的资源之后，我们就是做了这样的指令：让JmsTemplate连接到Destination，从我们提供的ConnectionFactory中获取连接资源。

## 1.ConnectionFactory资源 ##

我们如何提供ConnectionFactory给JmsTemplate？凭借 JmsTemplete提供的构造器或setter方法：

*  public JmsTemplate(ConnectionFactory connectionFactory)
 *  public void setConnectionFactory(ConnectionFactory connectionFactory)  
    \# 继承自org.springframework.jms.support.JmsAccessor

## 2.Destination资源 ##

我们如何提供 Destination给JmsTemplate？

我们有两个机会做这件事，第一次是在初始化的时候提供一个默认的Destination，第二次是在发送的时候提供一个明确的Destination。相关的方法：

*  public void setDefaultDestination(Destination destination)  
    设置默认的Destination
 *  public void send(Destination destination, MessageCreator messageCreator)  
    将消息发送到指定的Destination  
    MessageCreator接口用来提供创建消息的回调方法，后面再讲。

JmsTemplate还提供了另一种获取Destination的方式：基于Destination解析器、Destination类型、Destination名字的获取。你可以使用下面的代码来指定解析器、Destination类型：

// jt is instance of JmsTemplate
    jt.setDestinationResolver(new DynamicDestinationResolver()); // set Destination解析器
    jt.setPubSubDomain(false); // set Destinantion类型

Destination解析器要实现org.springframework.jms.support.destination.DestinationResolver接口。解析器有默认的值，就是DynamicDestinationResolver，除非你要使用其他的解析器，否则不必调用setDestinationResolver。所以，第2行代码是多余的。

Destination类型有2个：false-Queue类型，true-Topic类型；默认为false。所以，第3行代码是多余的。

设置了解析器、类型，或者直接使用默认的值，之后，就可以设置destination的name。JmsTemplate提供了两个方法：

*  public void setDefaultDestinationName(String destinationName)  
    设置defaultDestination。这个方法和setDefaultDestination(Destination destination)做同样的事情，只是这个方法依赖于解析器和类型。
 *  public void send(String destinationName, MessageCreator messageCreator)  
    将消息发送到指定的Destination。这个方法和send(Destination destination, MessageCreator messageCreator)做同样的事情，只是这个方法依赖于解析器和类型。

P.S.如何根据destinationName创建Destination实例？

javax.jms.Session提供了两个方法，分别创建两种类型的Destination：

*  Queue createQueue(java.lang.String queueName)  
    根据name创建Queue类型的Destination
 *  Topic createTopic(java.lang.String topicName)  
    根据name创建Topic类型的Destination

我们看下DynamicDestinationResolver的源码：

public class DynamicDestinationResolver implements DestinationResolver {
        @Override
        public Destination resolveDestinationName(Session session, String destinationName, boolean pubSubDomain)
                throws JMSException {
            Assert.notNull(session, "Session must not be null");
            Assert.notNull(destinationName, "Destination name must not be null");
            if (pubSubDomain) {
                return resolveTopic(session, destinationName);
            }
            else {
                return resolveQueue(session, destinationName);
            }
        }
        protected Topic resolveTopic(Session session, String topicName) throws JMSException {
            return session.createTopic(topicName);
        }
        protected Queue resolveQueue(Session session, String queueName) throws JMSException {
            return session.createQueue(queueName);
        }
    }

根据这份源码，可以帮助理解pubSubDomain的机制，以及将JMS的api和Spring的Destination解析器这两个知识点连接起来。

## 1.基本的发送方法 ##

--------------------

在前文我们已经接触了两个，它们都是在发送的同时指定Destination。现把它们和第3种一起介绍：

*  public void send(Destination destination, MessageCreator messageCreator)  
    将消息发送到指定的Destination
 *  public void send(String destinationName, MessageCreator messageCreator)  
    将消息发送到指定的Destination。这个方法和send(Destination destination, MessageCreator messageCreator)做同样的事情，只是这个方法依赖于解析器和类型。  
    
 *  public void send(MessageCreator messageCreator)  
    将消息发送到defaultDestination。  
    这个方法要求提前设置defaultDestination，你可以调用setDefaultDestination(Destination destination)或者setDefaultDestinationName(String destinationName)来满足这个前提。

在3个基本的发送方法中，都使用MessageCreator来创建消息。

## 使用MessageCreator创建消息 ##

jms中的Message，是以接口javax.jms.Message为首的接口家族，这个家族的图谱是这样的：

javax.jms.Message

|---- BytesMessage

|---- MapMessage

|---- ObjectMessage

|---- StreamMessage

|---- TextMessage

JMS将Message细分为5种类型，并在javax.jms.Session接口中分别定义了创建上述Message的多个方法，通常以create\*Message为名，返回对应的Message类型。

在JMS的api中，只有javax.jms.Session能创建消息。

所以在Spring中，如果我们要创建 Message，就要有Session。但是我们只有现成的ConnectionFactory，我们不应该走一遍从ConnectionFactory到Session的路，否则我们也不需要JmsTemplate帮我们发送了，因为剩下的工作也没多少了——关键是我们并没有从JMS的API中解脱出来。

所以有了 MessageCreator的接口，它定义了一个回调的方法：

*  Message createMessage(Session session)

只要我们把MessageCreator的实例传给JmsTemplate，它就会在合适的时候调用这个方法，并发送返回的消息。

下面给一个例子：

jt.send(DESTINATION_NAME, new MessageCreator() {
        
        public Message createMessage(Session session) throws JMSException {
            String text = "A test for MessageCreator.";
            Message message = session.createTextMessage(text);
            return message;
        }
    });

## 2.转换并发送的方法 ##

--------------------

我们需要将数据装进JMS的Message，然后再发送。JMS的Message有5种具体的类型，不同的类型适合装载不同的数据。如果你不想做这段工作，而是希望能直接把数据丢给谁，然后由它来封装成Message——你只想准备数据，然后发送。那么接下来要介绍的方法，正适合你。

Spring为转换定义了一个接口：org.springframework.jms.support.converter.MessageConverter，这个接口定义了下面的两个方法：

*  Message toMessage(Object object, Session session)  
    发送时用到
 *  Object fromMessage(Message message)  
    接收时用到

一般情况下，我们既不需要为 MessageConverter提供实现，也不需要面向 MessageConverter进行编程，所以我们实在没有必要关注上面的两个方法，扫一眼，有个大概的印象就够了。

说回JmsTemplate，它定义了下面的方法来设置Converter：

*  public void setMessageConverter(MessageConverter messageConverter)

而且在初始化的时候，会自动赋值一个SimpleMessageConverter类型的实例，所以我们甚至也不需要关心 setMessageConverter方法了。

说了这不多，总结一下，如果要用到转换，我们需要多做什么工作？ 答案是不需要！

下面是具有转换功能的发送的方法，与基本的发送的方法进行对比：

这两个系列的方法相似度很高，只是在创建消息的问题上有不同的处理：转换发送隐藏了消息的创建，基本发送需要实现 MessageCreator接口来创建消息。

接下来是一个demo，我们将上面的demo也拿下来，做一个对比：

转换发送：

String message = "a message for test convertAndSend.";
    jt.convertAndSend(DESTINATION_NAME, message);

基本发送：

## 3.转换、后处理再发送的方法 ##

--------------------

javax.jms.Message定义了很多的方法用来为消息添加头部信息或属性。但是如果我们要用转换并发送的方法，我们就接触不到Message类型的消息了，自然也无法为其添加任何信息。JmsTemplate提供了另一套发送的方法，允许我们使用自动转换，还允许我们能接触到转换后的消息，以便我们能做些什么。之后我们会返回处理后的Message，交给JmsTemplate发送。

Spring定义了org.springframework.jms.core.MessagePostProcessor接口来做后处理的事，它定义了一个唯一的方法：

*  Message postProcessMessage(Message message)  
    对消息进行处理，并返回处理后的消息

让我们来看看这些方法，并与前文介绍的方法对比：

再来看看两个demo的对比：

<table style="margin:0px; padding:0px; border-collapse:collapse; border-spacing:0px; max-width:850px; border:1px solid silver; word-break:break-word; color:rgb(51,51,51); font-family:Verdana,Arial,Helvetica,sans-serif; font-size:14px; line-height:25.2000007629395px; width:847px"> 
 <tbody style="margin:0px; padding:0px"> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> <span style="margin:0px; padding:0px">转换、后处理、发送</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <div style="margin:0px; padding:0px"> 
     <div style="margin:5px 0px; padding:5px; border:1px solid rgb(204,204,204); overflow:auto; color:rgb(0,0,0); font-family:'Courier New'!important; background-color:rgb(245,245,245)"> 
      <div style="margin:5px 0px 0px; padding:0px"> 
       <span style="margin:0px; padding:0px 5px 0px 0px; line-height:1.5!important"><a title="复制代码" style="margin:0px; padding:0px; text-decoration:underline; border:none!important" rel="nofollow"><img src="http://common.cnblogs.com/images/copycode.gif" alt="复制代码" style="margin:0px; padding:0px; max-width:800px; border:none!important"></a></span> 
      </div> 
      <pre style="margin-top:0px; margin-bottom:0px; padding:0px; white-space:pre-wrap; word-wrap:break-word; font-family:'Courier New'!important"><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">1</span> String message = "a message for test convertProcessAndSend."<span style="margin:0px; padding:0px; line-height:1.5!important">;
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">2</span> <span style="margin:0px; padding:0px; line-height:1.5!important">jt.convertAndSend(DESTINATION_NAME, message,
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">3</span>         <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">new</span><span style="margin:0px; padding:0px; line-height:1.5!important"> MessagePostProcessor() {
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">4</span>             <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">public</span><span style="margin:0px; padding:0px; line-height:1.5!important"> Message postProcessMessage(Message message)
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">5</span>                     <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">throws</span><span style="margin:0px; padding:0px; line-height:1.5!important"> JMSException {
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">6</span>                 message.setIntProperty("order", 1<span style="margin:0px; padding:0px; line-height:1.5!important">);
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">7</span>                 <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">return</span><span style="margin:0px; padding:0px; line-height:1.5!important"> message;
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">8</span> <span style="margin:0px; padding:0px; line-height:1.5!important">            }
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">9</span>         });<span style="margin:0px; padding:0px; font-family:Verdana,Arial,Helvetica,sans-serif; font-size:10px; line-height:1.5; background-color:rgb(255,255,255)">&nbsp;</span></pre> 
      <div style="margin:5px 0px 0px; padding:0px"> 
       <span style="margin:0px; padding:0px 5px 0px 0px; line-height:1.5!important"><a title="复制代码" style="margin:0px; padding:0px; text-decoration:underline; border:none!important" rel="nofollow"><img src="http://common.cnblogs.com/images/copycode.gif" alt="复制代码" style="margin:0px; padding:0px; max-width:800px; border:none!important"></a></span> 
      </div> 
     </div> 
    </div> </td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td colspan="1" style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> <span style="margin:0px; padding:0px">转换、发送</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td colspan="1" style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <div style="margin:0px; padding:0px"> 
     <div style="margin:5px 0px; padding:5px; border:1px solid rgb(204,204,204); overflow:auto; color:rgb(0,0,0); font-family:'Courier New'!important; background-color:rgb(245,245,245)"> 
      <pre style="margin-top:0px; margin-bottom:0px; padding:0px; white-space:pre-wrap; word-wrap:break-word; font-family:'Courier New'!important"><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">1</span> String message = "a message for test convertAndSend."<span style="margin:0px; padding:0px; line-height:1.5!important">;
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">2</span> jt.convertAndSend(DESTINATION_NAME, message);<span style="margin:0px; padding:0px; font-family:Verdana,Arial,Helvetica,sans-serif; font-size:10px; line-height:1.5; background-color:rgb(255,255,255)">&nbsp;</span></pre> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

在转换、后处理、发送中，我们为Message设置了一个属性：order=1.

**接收**

## 概要 ##

--------------------

JmsTemplate提供了4组\*3，共计12个接收用的方法。

JmsTemplate接收所需要的资源ConnectionFactory和Destination，和发送是一致的。

接收的方法有4组：

1.  基本的接收
2.  接收并转换
3.  带有选择器的接收
4.  选择接收并转换

## 1.基本的接收方法 ##

--------------------

JmsTemplate提供了3个基本的接收方法，与发送的方法进行对比：

接收到消息之后，需要对消息进行转换，再提取消息中的数据：

Message message = jt.receive(DESTINATION_NAME);
     
    // convert
    if (message != null && message instanceof TextMessage) {
        String text = ( (TextMessage) message ).getText();
        System.out.println(text);
    }

## 2.接收并转换的方法 ##

--------------------

与转换并发送的方法相对应，接收的时候也有接收并转换的方法：

*  public Object receiveAndConvert()  
    参考public Message receive()，在此基础上做了转换。
 *  public Object receiveAndConvert(Destination destination)  
    参考public Message receive(Destination destination)，在此基础上做了转换。
 *  public Object receiveAndConvert(String destinationName)  
    参考public Message receive(String destinationName)，在此基础上做了转换。

下面给出使用的示例，并把上面的示例也拿过来，做一下比较：

<table style="margin:0px; padding:0px; border-collapse:collapse; border-spacing:0px; max-width:850px; border:1px solid silver; word-break:break-word; width:847px"> 
 <tbody style="margin:0px; padding:0px"> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse; width:840px"> <span style="margin:0px; padding:0px">convert</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <div style="margin:0px; padding:0px"> 
     <div style="margin:5px 0px; padding:5px; border:1px solid rgb(204,204,204); overflow:auto; font-family:'Courier New'!important; background-color:rgb(245,245,245)"> 
      <pre style="margin-top:0px; margin-bottom:0px; padding:0px; white-space:pre-wrap; word-wrap:break-word; font-family:'Courier New'!important"><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">1</span> Object data =<span style="margin:0px; padding:0px; line-height:1.5!important"> jt.receiveAndConvert(DESTINATION_NAME);
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">2</span>  
<span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">3</span> <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">if</span> (data != <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">null</span> &amp;&amp; data <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">instanceof</span><span style="margin:0px; padding:0px; line-height:1.5!important"> String) {
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">4</span> <span style="margin:0px; padding:0px; line-height:1.5!important">    System.out.println(data);
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">5</span> }<span style="margin:0px; padding:0px; font-family:Verdana,Arial,Helvetica,sans-serif; font-size:10px; line-height:1.5; background-color:rgb(255,255,255)">&nbsp;</span></pre> 
     </div> 
    </div> </td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td colspan="1" style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> <span style="margin:0px; padding:0px">usual</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td colspan="1" style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <div style="margin:0px; padding:0px"> 
     <div style="margin:5px 0px; padding:5px; border:1px solid rgb(204,204,204); overflow:auto; font-family:'Courier New'!important; background-color:rgb(245,245,245)"> 
      <div style="margin:5px 0px 0px; padding:0px"> 
       <span style="margin:0px; padding:0px 5px 0px 0px; line-height:1.5!important"><a title="复制代码" style="margin:0px; padding:0px; text-decoration:underline; border:none!important" rel="nofollow"><img src="http://common.cnblogs.com/images/copycode.gif" alt="复制代码" style="margin:0px; padding:0px; max-width:800px; border:none!important"></a></span> 
      </div> 
      <pre style="margin-top:0px; margin-bottom:0px; padding:0px; white-space:pre-wrap; word-wrap:break-word; font-family:'Courier New'!important"><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">1</span> Message message =<span style="margin:0px; padding:0px; line-height:1.5!important"> jt.receive(DESTINATION_NAME);
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">2</span>  
<span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">3</span> <span style="margin:0px; padding:0px; color:rgb(0,128,0); line-height:1.5!important">//</span><span style="margin:0px; padding:0px; color:rgb(0,128,0); line-height:1.5!important"> convert</span>
<span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">4</span> <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">if</span> (message != <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">null</span> &amp;&amp; message <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">instanceof</span><span style="margin:0px; padding:0px; line-height:1.5!important"> TextMessage) {
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">5</span>     String text =<span style="margin:0px; padding:0px; line-height:1.5!important"> ( (TextMessage) message ).getText();
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">6</span> <span style="margin:0px; padding:0px; line-height:1.5!important">    System.out.println(text);
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">7</span> }<span style="margin:0px; padding:0px; font-family:Verdana,Arial,Helvetica,sans-serif; font-size:10px; line-height:1.5; background-color:rgb(255,255,255)">&nbsp;</span></pre> 
      <div style="margin:5px 0px 0px; padding:0px"> 
       <span style="margin:0px; padding:0px 5px 0px 0px; line-height:1.5!important"><a title="复制代码" style="margin:0px; padding:0px; text-decoration:underline; border:none!important" rel="nofollow"><img src="http://common.cnblogs.com/images/copycode.gif" alt="复制代码" style="margin:0px; padding:0px; max-width:800px; border:none!important"></a></span> 
      </div> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

至少，我们不用再考虑收到的Message具体是哪一种类型的。

## 3.带有选择器的接收方法 ##

--------------------

到目前为止，我们介绍的接收会无差别接收指定的Destination中的消息。如果我们只想接收其中的一部分——基于一个筛选的条件，满足条件的消息快到碗里来，不满足的就留在锅里吧。这种“挑食”的行为就是通过选择器来实现的。

在 [消息的接收方式以及选择器][Link 1]中，我们已经介绍了选择器是什么一回事，并给出了基于JMS API的demo；这里我们直接列出要说的三个方法吧：

*  public Message receiveSelected(String messageSelector)  
    参考public Message receive()，只是加入了筛选条件。
 *  public Message receiveSelected(Destination destination, String messageSelector)  
    参考public Message receive(Destination destination)，只是加入了筛选条件
 *  public Message receiveSelected(String destinationName, String messageSelector)  
    参考public Message receive(String destinationName)，只是加入了筛选条件

然后，再给一个demo：

<table style="margin:0px; padding:0px; border-collapse:collapse; border-spacing:0px; max-width:850px; border:1px solid silver; word-break:break-word; width:847px"> 
 <tbody style="margin:0px; padding:0px"> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse; width:840px"> <span style="margin:0px; padding:0px">发送</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <div style="margin:0px; padding:0px"> 
     <div style="margin:5px 0px; padding:5px; border:1px solid rgb(204,204,204); overflow:auto; font-family:'Courier New'!important; background-color:rgb(245,245,245)"> 
      <div style="margin:5px 0px 0px; padding:0px"> 
       <span style="margin:0px; padding:0px 5px 0px 0px; line-height:1.5!important"><a title="复制代码" style="margin:0px; padding:0px; text-decoration:underline; border:none!important" rel="nofollow"><img src="http://common.cnblogs.com/images/copycode.gif" alt="复制代码" style="margin:0px; padding:0px; max-width:800px; border:none!important"></a></span> 
      </div> 
      <pre style="margin-top:0px; margin-bottom:0px; padding:0px; white-space:pre-wrap; word-wrap:break-word; font-family:'Courier New'!important"><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 1</span> String message = "a message for test convertProcessAndSend."<span style="margin:0px; padding:0px; line-height:1.5!important">;
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 2</span> <span style="margin:0px; padding:0px; line-height:1.5!important">jt.convertAndSend(DESTINATION_NAME, message,
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 3</span>         <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">new</span><span style="margin:0px; padding:0px; line-height:1.5!important"> MessagePostProcessor() {
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 4</span>  
<span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 5</span>             <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">public</span><span style="margin:0px; padding:0px; line-height:1.5!important"> Message postProcessMessage(Message message)
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 6</span>                     <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">throws</span><span style="margin:0px; padding:0px; line-height:1.5!important"> JMSException {
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 7</span>                 message.setIntProperty("order", 1<span style="margin:0px; padding:0px; line-height:1.5!important">);
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 8</span>                 <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">return</span><span style="margin:0px; padding:0px; line-height:1.5!important"> message;
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important"> 9</span> <span style="margin:0px; padding:0px; line-height:1.5!important">            }
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">10</span>         });<span style="margin:0px; padding:0px; font-family:Verdana,Arial,Helvetica,sans-serif; font-size:10px; line-height:1.5; background-color:rgb(255,255,255)">&nbsp;</span></pre> 
      <div style="margin:5px 0px 0px; padding:0px"> 
       <span style="margin:0px; padding:0px 5px 0px 0px; line-height:1.5!important"><a title="复制代码" style="margin:0px; padding:0px; text-decoration:underline; border:none!important" rel="nofollow"><img src="http://common.cnblogs.com/images/copycode.gif" alt="复制代码" style="margin:0px; padding:0px; max-width:800px; border:none!important"></a></span> 
      </div> 
     </div> 
    </div> </td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td colspan="1" style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> <span style="margin:0px; padding:0px">接收</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td colspan="1" style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <div style="margin:0px; padding:0px"> 
     <div style="margin:5px 0px; padding:5px; border:1px solid rgb(204,204,204); overflow:auto; font-family:'Courier New'!important; background-color:rgb(245,245,245)"> 
      <div style="margin:5px 0px 0px; padding:0px"> 
       <span style="margin:0px; padding:0px 5px 0px 0px; line-height:1.5!important"><a title="复制代码" style="margin:0px; padding:0px; text-decoration:underline; border:none!important" rel="nofollow"><img src="http://common.cnblogs.com/images/copycode.gif" alt="复制代码" style="margin:0px; padding:0px; max-width:800px; border:none!important"></a></span> 
      </div> 
      <pre style="margin-top:0px; margin-bottom:0px; padding:0px; white-space:pre-wrap; word-wrap:break-word; font-family:'Courier New'!important"><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">1</span> jt.setReceiveTimeout(3*1000); <span style="margin:0px; padding:0px; color:rgb(0,128,0); line-height:1.5!important">//</span><span style="margin:0px; padding:0px; color:rgb(0,128,0); line-height:1.5!important"> in milliseconds</span>
<span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">2</span>         
<span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">3</span> String messageSelector = "order = 1"<span style="margin:0px; padding:0px; line-height:1.5!important">;
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">4</span> Message message =<span style="margin:0px; padding:0px; line-height:1.5!important"> jt.receiveSelected(DESTINATION_NAME, messageSelector);
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">5</span>  
<span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">6</span> <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">if</span> (message != <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">null</span> &amp;&amp; message <span style="margin:0px; padding:0px; color:rgb(0,0,255); line-height:1.5!important">instanceof</span><span style="margin:0px; padding:0px; line-height:1.5!important"> TextMessage) {
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">7</span>     String text =<span style="margin:0px; padding:0px; line-height:1.5!important"> ((TextMessage) message).getText();
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">8</span> <span style="margin:0px; padding:0px; line-height:1.5!important">    System.out.println(text);
</span><span style="margin:0px; padding:0px; color:rgb(0,128,128); line-height:1.5!important">9</span> }<span style="margin:0px; padding:0px; font-family:Verdana,Arial,Helvetica,sans-serif; font-size:10px; line-height:1.5; background-color:rgb(255,255,255)">&nbsp;</span></pre> 
      <div style="margin:5px 0px 0px; padding:0px"> 
       <span style="margin:0px; padding:0px 5px 0px 0px; line-height:1.5!important"><a title="复制代码" style="margin:0px; padding:0px; text-decoration:underline; border:none!important" rel="nofollow"><img src="http://common.cnblogs.com/images/copycode.gif" alt="复制代码" style="margin:0px; padding:0px; max-width:800px; border:none!important"></a></span> 
      </div> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

消息选择器的语法类似于sql。你可能注意到在接收的时候，有调用 jt.setReceiveTimeout(3\*1000); 这是因为JmsTemplate所有的接收，包括前面讲的和后面要讲的，都是阻塞式的——阻塞线程，等待接收，直到超过了预先设定的receiveTimeout，单位是毫秒。而它的初始值是0，表示无限等待。

## 4.选择接收并转换的方法 ##

--------------------

将选择器和转换进行叠加，我们得到了另外的三个方法：

*  public Object receiveSelectedAndConvert(String messageSelector)
 *  public Object receiveSelectedAndConvert(Destination destination, String messageSelector)
 *  public Object receiveSelectedAndConvert(String destinationName, String messageSelector)

如果你理解了选择器和转换的接收，应该可以轻松了解上面的方法。这里给出一个demo：

jt.setReceiveTimeout(3 * 1000); // in milliseconds
     
    String messageSelector = "order = 1";
    Object data = jt.receiveSelectedAndConvert(DESTINATION_NAME, messageSelector);
     
    if (data != null && data instanceof String) {
        System.out.println(data);
    }

[Link 1]: http://blog.csdn.net/gwd1154978352/article/details/78770427