C++ 中的 MSMQ 示例？答案

【问题标题】：MSMQ samples in C++?C++ 中的 MSMQ 示例？
【发布时间】：2010-09-12 07:15:40
【问题描述】：

谁能给我一些工作示例，说明如何通过 C++ API 创建、添加消息、读取和销毁私有消息队列？我尝试了 MSDN 的代码片段，但我无法让它们正常工作。

谢谢

【问题讨论】：

您对 MSDN 示例代码有什么问题？如果您发布了错误，我们可能会有更多机会帮助您。
我同意 Seb，你能澄清一下你的问题吗？

【解决方案1】：

不太确定您将如何创建或销毁消息队列。 Windows 应该为每个线程创建一个。

如果您使用 MFC，任何 CWinThread 和 CWnd 派生类都有一个易于访问的消息队列（使用 PostMessage 或 PostThreadMessage 和 ON_COMMAND 宏）。要使用 windows API 做类似的事情，我认为您需要编写自己的消息泵，例如 CWinApp 的 run 方法。

MSG msg;
BOOL bRet; 
while( (bRet = GetMessage( &msg, NULL, 0, 0 )) != 0)
{ 
    if (bRet == -1)
    {
        // handle the error and possibly exit
    }
    else
    {
        TranslateMessage(&msg); 
        DispatchMessage(&msg); 
    }
}

...是 MSDN 文档中的示例。这是你用的吗？什么不起作用？

【讨论】：

他指的是 MSMQ，而不是 Window Proc。

【解决方案2】：

其实这是我感兴趣的代码：

#include "windows.h"
#include "mq.h"
#include "tchar.h"


HRESULT CreateMSMQQueue(
                        LPWSTR wszPathName, 
                        PSECURITY_DESCRIPTOR pSecurityDescriptor,
                        LPWSTR wszOutFormatName,
                        DWORD *pdwOutFormatNameLength
                        )
{

  // Define the maximum number of queue properties.
  const int NUMBEROFPROPERTIES = 2;


  // Define a queue property structure and the structures needed to initialize it.
  MQQUEUEPROPS   QueueProps;
  MQPROPVARIANT  aQueuePropVar[NUMBEROFPROPERTIES];
  QUEUEPROPID    aQueuePropId[NUMBEROFPROPERTIES];
  HRESULT        aQueueStatus[NUMBEROFPROPERTIES];
  HRESULT        hr = MQ_OK;


  // Validate the input parameters.
  if (wszPathName == NULL || wszOutFormatName == NULL || pdwOutFormatNameLength == NULL)
  {
    return MQ_ERROR_INVALID_PARAMETER;
  }



  DWORD cPropId = 0;
  aQueuePropId[cPropId] = PROPID_Q_PATHNAME;
  aQueuePropVar[cPropId].vt = VT_LPWSTR;
  aQueuePropVar[cPropId].pwszVal = wszPathName;
  cPropId++;

  WCHAR wszLabel[MQ_MAX_Q_LABEL_LEN] = L"Test Queue";
  aQueuePropId[cPropId] = PROPID_Q_LABEL;
  aQueuePropVar[cPropId].vt = VT_LPWSTR;
  aQueuePropVar[cPropId].pwszVal = wszLabel;
  cPropId++;



  QueueProps.cProp = cPropId;               // Number of properties
  QueueProps.aPropID = aQueuePropId;        // IDs of the queue properties
  QueueProps.aPropVar = aQueuePropVar;      // Values of the queue properties
  QueueProps.aStatus = aQueueStatus;        // Pointer to the return status



  WCHAR wszFormatNameBuffer[256];
  DWORD dwFormatNameBufferLength = sizeof(wszFormatNameBuffer)/sizeof(wszFormatNameBuffer[0]);
  hr = MQCreateQueue(pSecurityDescriptor,         // Security descriptor
                     &QueueProps,                 // Address of queue property structure
                     wszFormatNameBuffer,         // Pointer to format name buffer
                     &dwFormatNameBufferLength);  // Pointer to receive the queue's format name length



  if (hr == MQ_OK || hr == MQ_INFORMATION_PROPERTY)
  {
    if (*pdwOutFormatNameLength >= dwFormatNameBufferLength)
    {
      wcsncpy_s(wszOutFormatName, *pdwOutFormatNameLength - 1, wszFormatNameBuffer, _TRUNCATE);

      wszOutFormatName[*pdwOutFormatNameLength - 1] = L'\0';
      *pdwOutFormatNameLength = dwFormatNameBufferLength;
    }
    else
    {
      wprintf(L"The queue was created, but its format name cannot be returned.\n");
    }
  }
  return hr;
}

这大概会创建一个队列...但是缺少一些部分以使其正常工作，这就是为什么我需要一个有效的简单示例。

【讨论】：

哪一部分不起作用？ MQCreateQueue 是返回错误，还是问题进一步发生？