ActiveMQ事务与三种签收方式

【ActiveMQ添加事务】

添加事务主要注意两点：

1.修改Session配置，启用事务

/**
 * 3.通过Connection对象创建Session会话（上下文环境对象），用于接收消息。
 *   参数1：是否启用事务 
 *   参数2：签收模式，一般设置为自动签收
 */
Session session = connection.createSession(Boolean. **TRUE** , Session.AUTO_ACKNOWLEDGE);

2.代码最后提交事务（必须要提交事务，不然在MQ上无法得到发送的消息）

//提交事务
session. **commit()** ;

[ session设置启用事务，但不加session.commit()，执行代码之后，这里不会改变 ]

[ 加了session.commit()，执行代码之后，MQ上就会有对应的消息 ]

【三种签收方式】

[ Session. AUTO_ACKNOWLEDGE ]

当客户端从receiver或onMessage成功返回时，Session自动签收客户端的这条消息的收条。

[ Session. CLIENT_ACKNOWLEDGE ]

客户端通过调用消息(Message)的acknowledge方法签收消息。在这种情况下，签收发生在Session层面：签收一个已经消费的消息会自动地签收这个Session所有已消费的收条。

[ Session. DUPS_OK_ACKNOWLEDGE ]

Session不必确保对传送消息的签收，这个模式可能会引起消息的重复，但是降低了Session的开销，所以只有客户端能容忍重复的消息，才可使用。

【 Session. CLIENT_ACKNOWLEDGE 签收方式】

[ 修改Send.java ]

/**
 * 3.通过Connection对象创建Session会话（上下文环境对象），用于接收消息。
 *   参数1：是否启用事务 **启用事务**
 *   参数2：签收模式， **修改为 客户端确认签收** */
Session session = connection.createSession(Boolean.TRUE, Session. **CLIENT_ACKNOWLEDGE** );

[ 修改 Receiver.java ]

消费者的session与生产者的session签收模式保持一致，注意， 生产者启用事务了，但是消费者这里事务不要启用，不然会一直消费

/**
 * 3.通过Connection对象创建Session会话（上下文环境对象），用于接收消息。
 *   参数1：是否启用事务 **消费者不启用事务**
 *   参数2：签收模式， **修改为 客户端确认签收** */
Session session = connection.createSession(Boolean. **FALSE** , Session. **CLIENT_ACKNOWLEDGE** );


**消费者获取消息时添加一行： msg.acknowledge();**


/**
 * 7.最后，使用JMS规范的TextMessage形式创建数据（通过Session对象），
 *   发送端使用MessageProducer的Send方法发送数据。
 *   接受端使用receive方法接收数据。
 */
while(true){
    TextMessage msg = (TextMessage)messageConsumer.receive();
    //消费者手工去签收消息，另起一个线程（TCP）去通知MQ服务确认消息签收
**msg.acknowledge();** if(msg==null) 
        break;
    System.out.println("【消费者接收】"+msg.getText());
}

原文链接：https://www.cnblogs.com/HigginCui/p/8465760.html

ActiveMQ事务与三种签收方式

热门标签