ActiveMQ：JMS的可靠性机制

女爷i 2022-04-25 04:50 221阅读 0赞

## 持久化消息 ##

默认情况下，生产者发送的消息是持久化的。消息发送到broker以后，producer会等待broker对这条消息的处理情况的反馈。可以设置消息发送端发送持久化消息的异步方式

> connectionFactory.setUseAsyncSend(**true**);

回执窗口大小设置

> connectionFactory.setProducerWindowSize();

非持久化消息

> textMessage.setJMSDeliveryMode(DeliveryMode.NON\_PERSISTENCE);

非持久化消息模式下，默认就是异步发送过程，如果需要对非持久化消息的每次发送的消息都获得broker的回执的话

> connectionFactory.setAlwaysSyncSend();

## **consumer获取消息** ##

默认情况下，mq服务器（broker）采用异步方式向客户端主动推送消息(push)。也就是说broker在向某个消费者会话推送消息后，不会等待消费者响应消息，直到消费者处理完消息以后，主动向broker返回处理结果。

broker端一旦有消息，就主动按照默认设置的规则推送给当前活动的消费者。 每次推送都有一定的数量限制，而这个数量就是prefetchSize。假如prefetchSize=0 . 此时对于consumer来说，就是一个pull模式。

## **消息接收确认** ##

JMS消息只有在被确认之后，才认为已经被成功地消费了。消息的成功消费通常包含三个阶段：客户接收消息、客户处理消息和消息被确认。

事务相关

1、在事务性会话中，当一个事务被提交的时候，确认自动发生。

final Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
        ....
        session.commit();

2、在非事务性会话中，消息何时被确认取决于创建会话时的应答模式（acknowledgement mode）。

该参数有以下三个可选值：

Session.AUTO\_ACKNOWLEDGE：

当客户成功的从receive方法返回的时候，或者从MessageListener.onMessage方法成功返回的时候，会话自动确认客户收到的消息。

final Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
             ...
             MapMessage message = (MapMessage) consumer.receive();

Session.CLIENT\_ACKNOWLEDGE：

客户通过调用消息的acknowledge方法确认消息。

需要注意的是，在这种模式中，确认是在会话层上进行，确认一个被消费的消息将自动确认所有已被会话消费的消息。例如，如果一个消息消费者消费了10个消息，然后确认第5个消息，那么所有10个消息都被确认。

final Session session = connection.createSession(Boolean.FALSE, Session.CLIENT_ACKNOWLEDGE);
           ...
           while(i<3) {
    		MapMessage message = (MapMessage) consumer.receive();
    		System.out.println("收到消息：" + message.getString("nro3---" + i) + ", poperty : " + message.getStringProperty("orderId" + i));
    		if (i == 2) {
    		 message.acknowledge();
    		}

Session.DUPS\_OK\_ACKNOWLEDGE：

该选择只是会话迟钝的确认消息的提交。如果JMSprovider失败，那么可能会导致一些重复的消息。 如果是重复的消息，那么JMSprovider必须把消息头的JMSRedelivered字段设置为true

## 本地事务 ##

在一个JMS客户端，可以使用本地事务来组合消息的发送和接收。JMS Session 接口提供了commit和rollback方法。

JMS Provider会缓存每个生产者当前生产的所有消息，直到commit或者rollback，commit操作将会导致事务中所有的消息被持久存储；rollback意味着JMS Provider将会清除此事务下所有的消息记录。在事务未提交之前，消息是不会被持久化存储的，也不会被消费者消费。事务提交意味着生产的所有消息都被发送。消费的所有消息都被确认；事务回滚意味着生产的所有消息被销毁，消费的所有消息被恢复，也就是下次仍然能够接收到发送端的消息，除非消息已经过期了。