带有 mq 消息的 WebSphere MQ 检查字符串

Question

我想从队列中读取第一条 MQ 消息（不删除它）并将这条消息保存到我的数据库中。然后，如果一切都完成了，我需要将此消息从 MQ 队列中永久删除。我所知道的只是删除队列中的第一条消息。但是我如何知道我保存到数据库中的同一条消息是否与我将从 MQ 中删除的同一条消息相同？

谢谢， 迈克尔

编辑： 现在尝试在 C#（控制台应用程序）中使用 TransactionScope 处理操作：

using (TransactionScope scope = new TransactionScope){
    //MQ Connection ( read message of queue)
    Hashtable properties = new Hashtable();
    properties.Add(MQC.HOST_NAME_PROPERTY, _settings.MQServer);
    properties.Add(MQC.PORT_PROPERTY, _settings.MQPort);
    properties.Add(MQC.CHANNEL_PROPERTY, _settings.MQChannelName);
    properties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_XACLIENT);
    MQQueueManager _MQHandler = new MQQueueManager(_settings.MQManager, properties);

    MQQueue = _MQHandler.AccessQueue(ReceiveQueueName,
    MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING);
    MQQueueMessage = new MQMessage();
    MQQueueMessage.Format = MQC.MQFMT_STRING;
    MQQueueGetMessageOptions = new MQGetMessageOptions();
    MQQueueGetMessageOptions.Options += MQC.MQGMO_SYNCPOINT;     //new
    MQQueue.Get(MQQueueMessage, MQQueueGetMessageOptions);

    //DB Connection (save message in database)

    if ( DBsuccess ) {
        _MQHandler.Commit();
        scope.Complete();   
    }else{
        _MQHandler.Backout();
    }           

}

这似乎是我想要的:) 但有些问题： - 如果我在 Put/Get 处创建一个同步点，然后调用 Backout()，MQ 是否只会回滚到该同步点？ - 如果消息是工作单元，MQ 是否被其他 MQ 管理器阻塞？

Answer 1

所以为了澄清一些术语，消息在队列上，而不是通道上 - 通道只是让您访问队列管理器。因此，实际上您想要“获取”第一条消息（在使用 GMO_SYNCPOINT 的工作单元内），将其存储到数据库中，如果存储有效，则从队列中删除消息（通过提交）。为此，您将在一个工作单元中从队列中获取消息，并且同时仅“提交”获取（即使其发生）和数据库更新。一般来说，您将使用事务协调来确保数据库更新和获取都发生（提交）或都不发生（回滚）。希望您可以使用 o/s DTC（分布式事务协调器）使 MQ 和数据库都参与同一个事务 - 您还需要查看是否需要托管或非托管连接，因为它们是不同的实现 - 请参阅信息中心http://www-01.ibm.com/support/knowledgecenter/SSFKSJ_8.0.0/com.ibm.mq.dev.doc/q029290_.htm