如何使用.NET TransactionScope从MQ执行事务获取？

Question

使用（TransactionScope范围=new TransactionScope（））{q.put（putMsg,pmo）；scope.complete（）；}

Q.关闭（）；qmgr.disconect（）；}

在我的代码中，这看起来像：

  // mq properties
  properties = new Hashtable();
  properties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_MANAGED);
  properties.Add(MQC.HOST_NAME_PROPERTY, HOSTNAME);
  properties.Add(MQC.PORT_PROPERTY, PORTNUMBER);
  properties.Add(MQC.CHANNEL_PROPERTY, CHANNELNAME);

  _queueManager = new MQQueueManager(queueManagerName, properties);
  _queue = _queueManager.AccessQueue(queueName, MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING);
  _gmo = new MQGetMessageOptions();
  _gmo.Options |= MQC.MQGMO_WAIT;
  _gmo.Options |= MQC.MQGMO_SYNCPOINT;
  _gmo.WaitInterval = 1000;  // 1 seconds wait

  // in a loop
  using (TransactionScope t = new TransactionScope())
  {

  var message = new MQMessage();
  try
  {
     _queue.Get(message, _gmo);
  }
  catch (MQException mqe)
  { 
     message = null;
     if (mqe.ReasonCode == 2033)
     {
          Console.WriteLine("No message available");
     }
     else
     {
          throw;
      }
   }
   t.Complete();
 }

//Afterwards:

  if (_queue != null)
   {
  _queue.Close();
  _queue = null;
  }
  if (_queueManager != null)
  {
  _queueManager.Disconnect();
  _queueManager.Close();
  _queueManager = null;
  }

null

null

Answer 1

那么，您至少需要安装WebSphereMQV7.1客户端和队列管理器，以便使用TransactionScope在完全管理模式下运行全局事务。在这种情况下，MS DTC将是事务处理协调器。您发布的InfoCenter链接实际上指向WebSphereMQV7.1。

更新:
在MQV7.1之前，只有以MTS作为事务协调器的非托管模式才支持XA事务。下面是非托管模式下分布式事务的示例代码。您将需要安装一个附加组件，扩展事务客户端（XTC）。根据最新的公告，XTC是免费的。可以在MQ服务器安装映像中找到可安装的。

当MQ连接断开时（基本上调用了MQDISC)，事务中任何未提交的消息都将回滚。因此，消息将重新出现在队列中。