www.javainfo.com.cn 上干货 欢迎收藏

签收可以由ActiveMQ发起，也可以由客户端发起，取决于Session签收模式的设置。

在带事务的Session中，签收自动发生在事务提交时。如果事务回滚，所有已经接收的消息将会被再次传送。

在不带事务的Session中，一条消息何时和如何被签收取决于Session的设置。

1．Session.AUTO_ACKNOWLEDGE

当客户端从receive或onMessage成功返回时，Session自动签收客户端的这条消息的收条。在AUTO_ACKNOWLEDGE的Session中，同步接收receive是上述三个阶段的一个例外，在这种情况下，收条和签收紧随在处理消息之后发生。

2．Session.CLIENT_ACKNOWLEDGE

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

3．Session.DUPS_OK_ACKNOWLEDGE

   此选项指示Session不必确保对传送消息的签收。它可能引起消息的重复，但是降低了Session的开销，所以只有客户端能容忍重复的消息，才可使用（如果ActiveMQ再次传送同一消息，那么消息头中的JMSRedelivered将被设置为true）。

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

 

对队列来说，如果当一个Session终止时它接收了消息但是没有签收，那么ActiveMQ将保留这些消息并将再次传送给下一个进入队列的消费者。

对主题来说，如果持久订阅用户终止时，它已消费未签收的消息也将被保留，直到再次传送给这个用户。对于非持久订阅，AtiveMQ在用户Session关闭时将删除这些消息。

如果使用队列和持久订阅，并且Session没有使用事务，那么可以使用Session的recover方法停止Session，再次启动后将收到它第一条没有签收的消息，事实上，重启后Session一系列消息的传送都是以上一次最后一条已签收消息的下一条为起点。如果这时有消息过期或者高优先级的消息到来，那么这时消息的传送将会和最初的有所不同。对于非持久订阅用户，重启后，ActiveMQ有可能删除所有没有签收的消息。

如有疑问 请留言 欢迎提供建议