ActiveMQ 消息确认

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

ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.174.104:61616");

        Connection connection = connectionFactory.createConnection();

        connection.start();

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

        Destination queue=session.createQueue("my-queue1");

        MessageConsumer  consumer = session.createConsumer(queue);

        int i=0;

        while (i<3){

            TextMessage message=(TextMessage) consumer.receive();

            System.out.println(message.getText());

            session.commit();

        }        

        session.close();

        connection.close();

    }

　　如果事务性会话中，不执行 session.commit()，消息不会创建或被消费。

二、在非事务性会话中：消息何时被确认取决于创建会话时的应答模式（acknowledgement mode）。该参数有以下三个可选值：

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

Session session=connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

Session.CLIENT_ACKNOWLEDGE：客户通过调用消息的acknowledge方法确认消息。需要注意的是，在这种模式中，确认是在会话层上进行，确认一个被消费的消息
将自动确认所有已被会话消费的消息。例如，如果一个消息消费者消费了10 个消息，然后确认第5 个消息，那么所有10 个消息都被确认。

ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.174.104:61616");

        Connection connection = connectionFactory.createConnection();

        connection.start();

        Session session=connection.createSession(Boolean.FALSE, Session.CLIENT_ACKNOWLEDGE);

        Destination queue=session.createQueue("my-queue2");

        MessageConsumer  consumer = session.createConsumer(queue);

        int i=0;

        while (i<3){

            TextMessage message=(TextMessage) consumer.receive();

            //System.out.println(message.getStringProperty("queue"));

            System.out.println(message.getText());

            //session.commit();

            if(i==2){

                message.acknowledge();

            }

            i++;

        }        

        session.close();

        connection.close();

    }

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

巴特西

ActiveMQ 消息确认

最新文章

热门文章