spring整合ActiveMQ异步接收研究

今天应用Spring JMS整合ActiveMQ时发现了这样一个问题，搞了几个小时的时间，终于是明白了，随手记录一下，也给用到的朋友一个参考。

 

关于Spring JMS和ActiveMQ的用法在这里就不说了，推荐一篇文章，对快速的理解很有帮助

 

http://blog.csdn.net/buyaore_wo/article/details/7093589

 

好了，进入正题。我们知道，对于向Queue发送消息，如果没有消费者在监听，会将消息持久化，接收jms消息时可以是事务性的和非事务性的。对于事务性的接收，当成功提交之后才会发送确认接收回执无论是receive同步接收还是onMessage这样的异步接收，对于非事务性的接收要根据createSession时定义的标识方式进行确认签收默认是AUTO_ACKNOWLEDGE也就是在onMessage方法成功返回后即确认签收。

 

比如现在有这样一个需求的场景，我们希望向Queue中发送消息，发送时消费者不在线，当消费者非事务性的连接后，可以接收到它离线时没有接收到的消息。应用Spring的jmsTelement发送消息，用DefaultMessageListenerContainer监听Queue时发现，即使在监听器的onMessage()中抛出异常消息仍然被成功的签收了。消费者再次连接......还是没有消息过来，怎么办呢？看源码吧。

 

原来是这样啊......DefaultMessageListenerContainer其实是是用轮询的方式，调用session.receive()接收消息，然后再回调注入的监听器的onMessage()，而在非事务性接收的情况下，receive之后就会发送确认签收的回执，已经持久化的消息随即消失，所以在onMessage()中，无论怎么折腾，其实都是对已成功签收的Message进行的操作，怪不得。

 

既然这样，那把DefaultMessageListenerContainer的sessionTransacted改为true，并且同样在onMessage()中抛出个异常试试，理论上抛出异常后应该回滚了，而且消息会被持久化，结果呢......和理论一样，原因呢......上边已经说了。

 

好了，汇报完毕，请指示。