技术开发 频道

消息队列


【IT168技术文档】

1// Send Message 2private voidbtnSendMessage_Click(objectsender, System.EventArgse) 3{ 4 // Open queue 5 System.Messaging.MessageQueuequeue= newSystem.Messaging.MessageQueue(".\\Private$\\MSMQDemo"); 6 7 // Create message 8 System.Messaging.Messagemessage= newSystem.Messaging.Message(); 9 message.Body= txtMessage.Text.Trim(); 10 message.Formatter= newSystem.Messaging.XmlMessageFormatter(newType[] {typeof(string)}); 11 12 // Put message into queue 13 queue.Send(message); 14} 15 16// Receive Message 17private voidbtnReceiveMessage_Click(objectsender, System.EventArgse) 18{ 19 // Open queue 20 System.Messaging.MessageQueuequeue= newSystem.Messaging.MessageQueue(".\\Private$\\MSMQDemo"); 21 22 // Receive message, 同步的Receive方法阻塞当前执行线程,直到一个message可以得到 23 System.Messaging.Messagemessage= queue.Receive(); 24 message.Formatter= newSystem.Messaging.XmlMessageFormatter(newType[] {typeof(string)}); 25 txtReceiveMessage.Text= message.Body.ToString(); 26}
0
相关文章