IBM MQ - 消息读取和调用下线服务事务

Question

我正在处理 IBM MQ 消息的消费者，我希望在阅读并确认后使每条消息处理都具有事务性。

从 IBM MQ 读取每条消息后，我需要调用大约 4 到 5 个不同的休息服务。通过服务在不同的表中将有大约 1500 - 2000 次插入。

如果任何服务因任何原因失败，我想回滚之前在处理该特定消息时发生的插入并将消息留在队列中。

我怎样才能达到同样的效果？我对 IBM MQs/Jms 很陌生

我打算通过使用浏览消息来做到这一点

QueueBrowser queueBrowser = context.createBrowser(queue, "JMSCorrelationID='ID:c9d5e2d7c5c3e3c9d6d54040404040404040404040404040c9d5e2d7c5c3e3c9d6d54040404040404040404040404040'");

Answer 1

如果所有这些队列都在同一个 MQ 队列管理器上，您应该为此使用“本地 JMS 事务”。因此，创建您的 IBM MQ JMS 连接并处理您的会话（第一个参数设置为 true）：

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

注意：如果第一个参数为真，则忽略第二个参数。

创建您的 JMS 队列和接收器，然后读取您的第一条消息，例如：

Message msg = msgConsumer.receive(100);

如果当前没有事务，这会在收到的第一条消息上隐式启动 MQ 事务。

接下来进行处理，如果一切顺利，调用 commit。

如果没有，则回滚事务，您将再次看到所有回滚消息。所以它可以像这样工作：

Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
MessageConsumer msgConsumer = session.createConsumer(destination, null);
while( !isStopped() ) {

  try {

    Message msg = msgConsumer.receive(100);
    if( msg!=null ) { 
      ... call your REST services ...
      session.commit();
    }
    ... test for end condition ...
  }
  catch (Exception e) {
    ... error handling ...
    session.rollback();
  }
}