永仁网站建设,网站建设远洋国际,网站设置路由器,制作营销网站模板写在前面
Microsoft Message Queuing (MSMQ) 是在多个不同的应用之间实现相互通信的一种异步传输模式#xff0c;相互通信的应用可以分布于同一台机器上#xff0c;也可以分布于相连的网络空间中的任一位置。
使用消息队列可以实现异步通讯#xff0c;无需关心接收端是否在…写在前面
Microsoft Message Queuing (MSMQ) 是在多个不同的应用之间实现相互通信的一种异步传输模式相互通信的应用可以分布于同一台机器上也可以分布于相连的网络空间中的任一位置。
使用消息队列可以实现异步通讯无需关心接收端是否在线只需发出后就可以继续处理后续的任务通讯双方也可以是不同的物理平台该机制还可以用来实现故障恢复。
在使用前需要先确认该功能是否安装和启用如未安装可以参考以下操作步骤
进入控制面板\所有控制面板项\程序和功能点击启用或关闭Windows功能勾选Microsoft消息队列确认并安装。 消息队列分为以下几种每种队列的路径表示形式如下
公用队列 MachineName\QueueName
专用队列 MachineName\Private$\QueueName
日记队列 MachineName\QueueName\Journal$
计算机日记队列 MachineName\Journal$
计算机死信队列 MachineName\Deadletter$
计算机事务性死信队列 MachineName\XactDeadletter$
代码实现 需要引用 System.Messaging 类库 using System.Messaging; 发送端 public partial class Form1 : Form{MessageQueue queue;string path .\\Private$\\testQueue;public Form1(){InitializeComponent();CreateMessageQueue();}private void button1_Click(object sender, EventArgs e){SendMessage(this.textBox1.Text);}private void CreateMessageQueue(){if(MessageQueue.Exists(path)){queue new MessageQueue(path);}else{queue MessageQueue.Create(path);}}private void SendMessage(string str){var message new System.Messaging.Message();message.Formatter new XmlMessageFormatter(new Type[]{ typeof(string)});message.Body str;queue.Send(message);MessageBox.Show(消息发送成功);}private void SendMessage(Image image){var message new System.Messaging.Message();message.Formatter new BinaryMessageFormatter();message.Body image;queue.Send(message);MessageBox.Show(图像发送成功);}private void button2_Click(object sender, EventArgs e){OpenFileDialog open new OpenFileDialog();open.Filter 图像文件|*.jpg;*.bmp;*.png;open.InitialDirectory Environment.GetFolderPath(Environment.SpecialFolder.MyPictures);if(open.ShowDialog() DialogResult.OK){Image image Bitmap.FromFile(open.FileName);SendMessage(image);}}private void button3_Click(object sender, EventArgs e){MessageBox.Show(queue.GetAllMessages().Length.ToString());}private void button4_Click(object sender, EventArgs e){queue.Purge();}}
接收端 public partial class Form1 : Form{MessageQueue queue;string path .\\Private$\\testQueue;public Form1(){InitializeComponent();CreateMessageQueue();}private void button1_Click(object sender, EventArgs e){RecvStringMessage();}private void button2_Click(object sender, EventArgs e){RecvImageMessage();}private void CreateMessageQueue(){if (MessageQueue.Exists(path)){queue new MessageQueue(path);}else{queue MessageQueue.Create(path);}}public void RecvStringMessage(){if (queue.GetAllMessages().Length 0){MessageBox.Show(消息队列为空);return;}var message queue.Receive();message.Formatter new XmlMessageFormatter(new Type[] {typeof(string) });MessageBox.Show(message.Body.ToString());}public void RecvImageMessage(){if (queue.GetAllMessages().Length 0){MessageBox.Show(消息队列为空);return;}var message queue.Receive();message.Formatter new BinaryMessageFormatter();Image image (Image)message.Body;Form form new Form();form.Width 1024;form.Height 768;PictureBox pbox new PictureBox();pbox.Width 1024;pbox.Height 768;pbox.SizeMode PictureBoxSizeMode.Zoom;pbox.Image image;form.Controls.Add(pbox);form.ShowDialog();}}
调用示例 可以在计算机管理中查看到消息队列的详细信息还未被接收的消息会在队列消息中看到被接收并消费后即自动删除。 源码主体来自以下链接
https://www.cnblogs.com/zhaotianff/p/8203619.html
