activemq事务与ack消息确认

深藏阁楼爱情的钟 2022-06-13 07:40 215阅读 0赞

事务型消息发送端（生产端）  
  
此处其它代码与普通式消息发送代码相似，只在以下几处有不同，首先在取得session时会声明事务开启“true”。  
session = conn.createSession(true, Session.AUTO\_ACKNOWLEDGE);    
  
然后在发送时会有一个动作：  
producer.send(message);    
System.out.println("send......" + Thread.currentThread().getId());    
session.commit();    
  
  
相应的在catch(Exception)时需要  
catch (Exception e) \{    
                        e.printStackTrace();    
    try \{    
        session.rollback();    
    \} catch (Exception ex) \{    
    \}    
\}     
  
  
事务型消息接收端（消费端）  
  
在我们的接收端的createSession时也需要把它设为“事务开启”，此时请注意，生产和消费是在一个事务边界中的。  
session = conn.createSession(true, Session.AUTO\_ACKNOWLEDGE);    
  
然后在接收时会有一个动作：  
try \{    
    TextMessage tm = (TextMessage) message;    
    System.out.println("TranQConsumer receive message: " + tm.getText());    
    session.commit();    
    
\} catch (Exception e) \{    
    e.printStackTrace();    
    try \{    
        session.rollback();    
    \} catch (Exception ex) \{    
    \}

队列和订阅都是支持事务的。

在创建Session时,开发者不能指定除ACK\_MODE列表之外的其他值.如果此session为事务类型,用户指定的ACK\_MODE将被忽略,而强制使用"SESSION\_TRANSACTED"类型;如果session非事务类型时,也将不能将 ACK\_MODE设定为"SESSION\_TRANSACTED",毕竟这是相悖的.

ACK\_MODE有四种

*  AUTO\_ACKNOWLEDGE = 1    自动确认
 *  CLIENT\_ACKNOWLEDGE = 2    客户端手动确认   
 *  DUPS\_OK\_ACKNOWLEDGE = 3    自动批量确认
 *  SESSION\_TRANSACTED = 0    事务提交并确认

欢迎加入我们的技术讨论群425783133