消息队列的简单处理
private?void?發送ToolStripMenuItem_Click(object?sender,?EventArgs?e){System.Messaging.MessageQueue?queue;if?(MessageQueue.Exists(".\\Private$\\MSMQDemo"))queue?=?new?MessageQueue(".\\Private$\\MSMQDemo");elsequeue?=?MessageQueue.Create(".\\Private$\\MSMQDemo");//?Open?queuequeue?=?new?System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");//?Create?messageSystem.Messaging.Message?message?=?new?System.Messaging.Message();message.Body?=?"hello";message.Formatter?=?new?System.Messaging.XmlMessageFormatter(new?Type[]?{typeof(string)});//?Put?message?into?queuequeue.Send(message);}private?void?接收ToolStripMenuItem_Click(object?sender,?EventArgs?e){//?Open?queueSystem.Messaging.MessageQueue?queue?=?new?System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");//?Receive?message,?同步的Receive方法阻塞當前執行線程,直到一個message可以得到?System.Messaging.Message?message?=?queue.Receive();message.Formatter?=?new?System.Messaging.XmlMessageFormatter(new?Type[]?{?typeof(string)?});//txtReceiveMessage.Text?=?message.Body.ToString();MessageBox.Show(message.Body.ToString());}
總結
- 上一篇: 今天的我家有12口人的即时通讯
- 下一篇: sqlserver2008 安装时需要重