ActiveMQ——6.Spring-JmsTemplate特性设置

╰+攻爆jí腚メ 2021-09-26 09:26 281阅读 0赞

## 概述 ##

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

这是关于JmsTemplate的最后一篇总结，且只会介绍几个比较重要的特性。

## 消息的递送模式 ##

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

在发送消息给时，可以告知这是持久化的消息，还是非持久化的消息。如果是非持久化的消息，broker会将消息保留在内存，否则就会持久化到磁盘。非持久化：高吞吐，易丢失；持久化：低吞吐，不易丢失。

相关的API：

<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"> <span style="margin:0px; padding:0px">Class&nbsp;org.springframework.jms.core.JmsTemplate</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <ul style="margin:0px 0px 1em 40px; padding:0px"> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public void setDeliveryMode(int deliveryMode)<br style="margin:0px; padding:0px"> 设置是否持久化要发送的消息：1-非持久化；2-持久化</li> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public int getDeliveryMode()<br style="margin:0px; padding:0px"> 获取持久化模式的设置：1-非持久化；2-持久化</li> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public void setDeliveryPersistent(boolean deliveryPersistent)<br style="margin:0px; padding:0px"> 设置是否持久化要发送的消息，true-持久化；false-非持久化</li> 
    </ul> </td> 
  </tr> 
 </tbody> 
</table>

## 消息的优先级 ##

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

在发送时，可以为消息指定优先级，以期高优先级的消息能更快的递送给consumer。在javax.jms.Message\#getJMSPriority()方法，有如下的说明：

JMS API为消息定义了10个优先级，0最低，9最高。0-4作为一般的优先级，5-9作为加速优先级。JMS API不要求实现者能够严格按照消息的优先级的顺序把消息递送给consumer，但是应该尽量的实现加速优先级的消息能在一般优先级的消息的前面，递送给consumer。

下面是JmsTemplate中的API：

<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"> <span style="margin:0px; padding:0px">Class&nbsp;org.springframework.jms.core.JmsTemplate</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <ul style="margin:0px 0px 1em 40px; padding:0px"> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public void setPriority(int priority)<br style="margin:0px; padding:0px"> 为将要发送的消息设置优先级。</li> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public int getPriority()<br style="margin:0px; padding:0px"> 获取优先级</li> 
    </ul> </td> 
  </tr> 
 </tbody> 
</table>

## 消息的存活时间 ##

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

在发送时，可以设置消息的存活时间，默认为永久有效。

<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"> <span style="margin:0px; padding:0px">Class org.springframework.jms.core.JmsTemplate</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <ul style="margin:0px 0px 1em 40px; padding:0px"> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public void setTimeToLive(long timeToLive)<br style="margin:0px; padding:0px"> 设置消息的存活时间，毫秒单位</li> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public long getTimeToLive()<br style="margin:0px; padding:0px"> 获取消息的存活时间，毫秒单位</li> 
    </ul> </td> 
  </tr> 
 </tbody> 
</table>

## 服务质量开关 ##

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

如果不打开服务质量的开关，消息的递送模式、优先级和存活时间的设置就没有作用。

<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"> <span style="margin:0px; padding:0px">Class org.springframework.jms.core.JmsTemplate</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <ul style="margin:0px 0px 1em 40px; padding:0px"> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public void setExplicitQosEnabled(boolean explicitQosEnabled)<br style="margin:0px; padding:0px"> 发送消息的时候，是否使用QOS的值（deliveryMode, priority, timeToLive）</li> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public boolean isExplicitQosEnabled()<br style="margin:0px; padding:0px"> 如果是true，deliveryMode, priority, 和 timeToLive的值将被使用；否则使用默认的值。</li> 
    </ul> </td> 
  </tr> 
 </tbody> 
</table>

P.S.

在JMS API中， 消息的递送模式、优先级和存活时间可以在发送的时候统一设置：

*  javax.jms.MessageProducer\#send(Message message, int deliveryMode, int priority, long timeToLive):void

## 接收等待时间 ##

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

JmsTemplate的接收是阻塞式的接收，默认会一直阻塞等待，直到接收到了消息。也可以设置一个最长的等待时间参数，超过这个时间，接收的方法将得到null的结果。

<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"> <span style="margin:0px; padding:0px">Class org.springframework.jms.core.JmsTemplate</span></td> 
  </tr> 
  <tr style="margin:0px; padding:0px"> 
   <td style="margin:0px; padding:3px; border:1px solid silver; border-collapse:collapse"> 
    <ul style="margin:0px 0px 1em 40px; padding:0px"> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public void setReceiveTimeout(long receiveTimeout)<br style="margin:0px; padding:0px"> 设置接收等待时间，毫秒单位</li> 
     <li style="margin:0px; padding:0px; list-style-type:disc">public long getReceiveTimeout()<br style="margin:0px; padding:0px"> 获取接收等待时间，毫秒单位</li> 
    </ul> </td> 
  </tr> 
 </tbody> 
</table>