C#使用Microsoft消息队列(MSMQ)的示例详解

更新时间：2024年01月05日 08:42:50 作者：rjcql

Microsoft Message Queuing (MSMQ) 是在多个不同的应用之间实现相互通信的一种异步传输模式,本文主要介绍了C#如何使用Microsoft消息队列,需要的可以了解下

写在前面

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();
        }
    }

调用示例

可以在计算机管理中查看到消息队列的详细信息，还未被接收的消息会在队列消息中看到，被接收并消费后即自动删除。

源码参考：C#消息队列MSMQ

以上就是C#使用Microsoft消息队列(MSMQ)的示例详解的详细内容，更多关于C# Microsoft消息队列的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

C#中const,readonly和static关键字的用法介绍
这篇文章介绍了C#中const,readonly和static关键字的用法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-08-08
关于C#中的字体别名问题
在C#中使用Graphics对象的DrawString方法绘制文本时,可以通过设置TextRenderingHint属性来控制字体混叠效果,对于14号或更大的字体,建议使用AntiAliasGridFit；对于8到14点之间的字体,建议使用AntiAlias；对于小于8点的字体,建议使用ClearTypeGridFit
2025-01-01
C#简单的加密类实例
AesManaged - 高级加密标准(AES) 对称算法的管理类
2013-03-03
轻松学习C#的装箱与拆箱
轻松学习C#的装箱与拆箱，在之前的文章简单的提到了轻松学习C#的装箱与拆箱，本文带着大家更加详细的介绍轻松学习C#的装箱与拆箱，感兴趣的小伙伴们可以参考一下
2015-11-11
WinForm实现读取Resource中文件的方法
这篇文章主要介绍了WinForm实现读取Resource中文件的方法,很实用的一个功能,需要的朋友可以参考下
2014-08-08
深入理解C#窗体关闭事件
很多初学者都想把默认的C#关闭按钮事件弄明白，本文就介绍一下C#窗体关闭事件，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-10-10
C#实现实时监控文件夹变化
在开发各种应用程序时,我们经常需要对文件系统中的文件或文件夹进行实时监测,下面就跟随小编一起来看看具体如何使用C#实现这一功能吧
2024-03-03
C#序列化与反序列化集合对象并进行版本控制
这篇文章介绍了C#序列化与反序列化集合对象并实现版本控制的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-09-09
RSA密钥--JAVA和C#的区别及联系
这篇文章主要介绍了关于RSA密钥事件JAVA和C#的区别及联系，文章从RSA语法介绍开始展开详细介绍了C#转JAVA及JAVA转C#,需要的小伙伴可以可以参考一下
2021-10-10
C#实现五子棋游戏
这篇文章主要为大家详细介绍了C#实现五子棋游戏，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-01-01