MQ 系列之 JMSTemplate

超、凢脫俗 2023-03-06 03:47 18阅读 0赞

## 1.1 简介 ##

### 1.1.1 概述 ###

JMSTemplate 是由 Spring 提供的一个 JMS 消息发送模板(与 JDBCTmplate 类似)，可以用来方便地进行消息的发送，消息发送方法 convertAndSend 的第一个参数是消息队列，第二个参数是消息内容，@JmsListener 注解则表示相应的方法是一个消息消费者。  
![在这里插入图片描述][20200805095806842.png]

### 1.1.2 整合 JMSTemplate ###

☞ Spring 整合 JMSTemplate  
[☞ SpringBoot 整合 JMSTemplate][SpringBoot _ JMSTemplate]

## 1.2 JMSTemplate 的使用 ##

### 1.2.1 常用方法 ###

消息接收可以使用消息监听的方式替代模板方法，但是发送的时候是无法代替的，必须使用 Spring 提供的 JmsTemplate 中的方法来进行发送操作。浏览只是针对 Queue 的概念，Topic 没有浏览。浏览是指获取消息而消息依然保持在 broker 中，而消息的接收会把消息从 broker 中移除。

<table> 
 <thead> 
  <tr> 
   <th align="left">方法</th> 
   <th align="left">描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">void send(Destination destination，MessageCreator messageCreator)</td> 
   <td align="left">将消息发送到指定的 Destination</td> 
  </tr> 
  <tr> 
   <td align="left">void send(String destinationName，MessageCreator messageCreator)</td> 
   <td align="left">将消息发送到指定的 Destination<br>这个方法和send(Destination destination，MessageCreator messageCreator) 做同样的事情，只是这个方法依赖于解析器和类型</td> 
  </tr> 
  <tr> 
   <td align="left">void send(MessageCreator messageCreator)</td> 
   <td align="left">将消息发送到默认的 Destination，这个方法要求提前设置 defaultDestination<br>可以调用 setDefaultDestination(Destination destination) 或者 setDefaultDestinationName(String destinationName) 来满足这个前提</td> 
  </tr> 
  <tr> 
   <td align="left">void convertAndSend(Destination destination，Object message)</td> 
   <td align="left">将 message 转换成 JMS 的 Message，并发送到指定的 Destination</td> 
  </tr> 
  <tr> 
   <td align="left">void convertAndSend(String destinationName，Object message)</td> 
   <td align="left">将 message 转换成 JMS 的 Message，并发送到指定的 Destination</td> 
  </tr> 
  <tr> 
   <td align="left">void convertAndSend(Object message)</td> 
   <td align="left">将 message 转换成 JMS 的 Message，并发送到默认的 Destination</td> 
  </tr> 
  <tr> 
   <td align="left">Message receive(Destination destination)</td> 
   <td align="left">从指定的 Destination 接收消息并返回</td> 
  </tr> 
  <tr> 
   <td align="left">Message receive(String destinationName)</td> 
   <td align="left">从指定的 Destination 接收消息并返回</td> 
  </tr> 
  <tr> 
   <td align="left">Message receive()</td> 
   <td align="left">从默认的 Destination 接收消息并返回</td> 
  </tr> 
  <tr> 
   <td align="left">Object receiveAndConvert()</td> 
   <td align="left">参考 Message receive()，在此基础上做了转换</td> 
  </tr> 
  <tr> 
   <td align="left">Object receiveAndConvert(Destination destination)</td> 
   <td align="left">参考 Message receive(Destination destination)，在此基础上做了转换</td> 
  </tr> 
  <tr> 
   <td align="left">Object receiveAndConvert(String destinationName)</td> 
   <td align="left">参考 Message receive(String destinationName)，在此基础上做了转换</td> 
  </tr> 
  <tr> 
   <td align="left"> T browse(BrowserCallback action)</td> 
   <td align="left">从默认的 Queue 中浏览消息，要求设置了默认的 Destination，且类型为 Queue<br>action 是一个回调对象，它负责浏览消息，并返回浏览的结果</td> 
  </tr> 
  <tr> 
   <td align="left"> T browse(Queue queue，BrowserCallback action)</td> 
   <td align="left">从指定的 Queue 中浏览消息</td> 
  </tr> 
  <tr> 
   <td align="left"> T browse(String queueName，BrowserCallback action)</td> 
   <td align="left">从指定 name 的 Queue 中浏览消息</td> 
  </tr> 
  <tr> 
   <td align="left">T doInJms(Session session, QueueBrowser browser)</td> 
   <td align="left">浏览队列中的消息，并返回浏览的结果<br>这是一个回调方法，Spring 会为我们提供 QueueBrowser 对象，我们可以据此获取消息，并自由的转换。最后以我们希望的类型返回</td> 
  </tr> 
  <tr> 
   <td align="left">void setDeliveryMode(int deliveryMode)</td> 
   <td align="left">设置是否持久化要发送的消息：1-非持久化；2-持久化</td> 
  </tr> 
  <tr> 
   <td align="left">int getDeliveryMode()</td> 
   <td align="left">获取持久化模式的设置：1-非持久化；2-持久化</td> 
  </tr> 
  <tr> 
   <td align="left">void setDeliveryPersistent(boolean deliveryPersistent)</td> 
   <td align="left">设置是否持久化要发送的消息，true-持久化；false-非持久化</td> 
  </tr> 
  <tr> 
   <td align="left">void setPriority(int priority)</td> 
   <td align="left">为将要发送的消息设置优先级</td> 
  </tr> 
  <tr> 
   <td align="left">int getPriority()</td> 
   <td align="left">获取优先级</td> 
  </tr> 
  <tr> 
   <td align="left">void setTimeToLive(long timeToLive)</td> 
   <td align="left">设置消息的存活时间，毫秒单位</td> 
  </tr> 
  <tr> 
   <td align="left">long getTimeToLive()</td> 
   <td align="left">获取消息的存活时间，毫秒单位</td> 
  </tr> 
  <tr> 
   <td align="left">void setReceiveTimeout(long receiveTimeout)</td> 
   <td align="left">设置接收等待时间，毫秒单位</td> 
  </tr> 
  <tr> 
   <td align="left">long getReceiveTimeout()</td> 
   <td align="left">获取接收等待时间，毫秒单位</td> 
  </tr> 
 </tbody> 
</table>

### 1.2.2 发送消息 ###

/** * Created with IntelliJ IDEA. * * @author Demo_Null * @date 2020/8/5 * @description JMS 发送消息 */
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest()
    public class MyMQTest { 
    
        @Autowired
        private JmsTemplate jmsTemplate;
    
        @Test
        public void jms() { 
            jmsTemplate.convertAndSend(new ActiveMQQueue("myTest"), "测试消息");
        }
    }

### 1.2.3 接收消息 ###

**☞ 普通方式**

/** * Created with IntelliJ IDEA. * * @author Demo_Null * @date 2020/8/5 * @description AMQ 接收消息 */
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest()
    public class MyMQTest { 
    
        @Autowired
        private JmsTemplate jmsTemplate;
    
        @Test
        public void recevie() { 
            Object myTest = jmsTemplate.receiveAndConvert("myTest");
    
            if (!Objects.isNull(myTest)) { 
                System.out.println(myTest);
            }
        }
    }

![在这里插入图片描述][20200805151334290.png]

**☞ 监听消息**

/** * Created with IntelliJ IDEA. * * @author Demo_Null * @date 2020/8/5 * @description AMQ 监听消息 */
    @Component
    public class MyMQListener { 
    
        @Autowired
        private JmsTemplate jmsTemplate;
    
        @JmsListener(destination = "myTest")
        // 可监听多个队列
        // @JmsListeners(value = {@JmsListener(destination = "T1"), @JmsListener(destination = "T2")})
        public void listener(String msg) { 
            if (!Objects.isNull(msg)) { 
                System.out.println(msg);
           }
        }
    }

[20200805095806842.png]: /images/20230208/625d843f7bc14ec9957bd2f5017a3825.png
[SpringBoot _ JMSTemplate]: https://blog.csdn.net/Demo_Null/article/details/107808924
[20200805151334290.png]: /images/20230208/aedf4ab21b8c48458177a575569bc62e.png