首页 > 代码库 > MSMQ学习笔记二——创建Message Queue队列
MSMQ学习笔记二——创建Message Queue队列
一、创建Message Queue队列的主要流程
1、定义MQQUEUEPROPS 结构;
2、设置消息队列属性;
3、初始化MQQUEUEPROPS 结构;
4、调用MQCreateQueue创建队列。
下面对MSDN上的创建Message Queue队列示例函数:
HRESULT CreateMSMQQueue( LPWSTR wszPathName, PSECURITY_DESCRIPTOR pSecurityDescriptor, LPWSTR wszOutFormatName, DWORD *pdwOutFormatNameLength ) { // Define the maximum number of queue properties. const int NUMBEROFPROPERTIES = 2; const int BUFLEN = 256; // 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; } // Set queue properties. 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++; // Initialize the MQQUEUEPROPS structure. 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 // Call MQCreateQueue to create the queue. WCHAR wszFormatNameBuffer[BUFLEN]; DWORD dwFormatNameBufferLength = BUFLEN; 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 in Unicode characters not bytes. // Return the format name if the queue is created successfully. if (hr == MQ_OK || hr == MQ_INFORMATION_PROPERTY) { if (*pdwOutFormatNameLength >= dwFormatNameBufferLength) { wcsncpy_s(wszOutFormatName, *pdwOutFormatNameLength - 1, wszFormatNameBuffer, _TRUNCATE); // ************************************ // You must copy wszFormatNameBuffer into the // wszOutFormatName buffer. // ************************************ wszOutFormatName[*pdwOutFormatNameLength - 1] = L‘\0‘; *pdwOutFormatNameLength = dwFormatNameBufferLength; } else { wprintf(L"The queue was created, but its format name cannot be returned.\n"); } } return hr; }
注意:需要包含头文件windows.h、mq.h、stdio.h和lib库mqrt.lib。
二、示例
以下为测试示例:
int _tmain(int argc, _TCHAR* argv[]) { wchar_t name[]=L".\\PRIVATE$\\ZHXL.121"; DWORD bufferLength = 256; wchar_t formattedQueueName[256]; HRESULT returnValue = CreateMSMQQueue(name,NULL,formattedQueueName,&bufferLength); if(returnValue != MQ_OK) wprintf(L"Creating a Queue failed\n"); else { wprintf(L"Queue was successfully created..Formatted QueueName =%s\n",formattedQueueName); wprintf(L"BufferLength returned is %d\n", bufferLength); } return 0; }
运行结果为:
三、补充
1、MQQUEUEPROPS结构体
该结构体定义为:
typedef struct tagMQQUEUEPROPS { DWORD cProp; __field_ecount(cProp) QUEUEPROPID* aPropID; __field_ecount(cProp) MQPROPVARIANT* aPropVar; __field_ecount_opt(cProp) HRESULT* aStatus; } MQQUEUEPROPS;
cProp:属性总个数;
aPropID:属性标识符,Message Queue必需属性的标识符有PROPID_Q_PATHNAME和PROPID_Q_LABEL两个,分别为指定队列的路径和描述性标签;
aPropVar:消息队列属性的值;
2、消息队列创建之后一直存在,创建同名消息队列会失败,需要用到指定队列时所需操作为打开制定队列,利用完事后关闭队列。
MSMQ学习笔记二——创建Message Queue队列
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。