当前位置：首页 > news >正文

C# 消息队列 (MSMQ) 进程之间的通信

news 2025/7/10 4:24:01

2个程序之间使用消息队列进行通信。
该代码只适用.NET Framework 版本，如果是.NET Core 请使用其他第三方消息队列框架，因为.NET Core 对System.Messaging 已经不支持呢。

进程1用于创建消息队列，然后发送消息。
代码如下:

using System;
using System.Messaging;namespace App1
{internal class Program{static void Main(){// 消息队列路径string queuePath = @".\Private$\MyQueue";// 创建或获取消息队列MessageQueue queue;if (MessageQueue.Exists(queuePath))queue = new MessageQueue(queuePath);elsequeue = MessageQueue.Create(queuePath);// 持续发送消息while (true){Console.WriteLine("Enter the message to send (or 'exit' to quit):");string input = Console.ReadLine();if (input.ToLower() == "exit")break;// 发送消息Message message = new Message(input);queue.Send(message);Console.WriteLine("Message sent from Process 1.");}Console.ReadLine();}}
}

注：
1.string queuePath = @".\Private$\MyQueue";MyQueue是自己取的队列名称，前面的可以当成默认写法。
2.使用Send去发送数据，数据可以是任何类型。

进程2用于接收消息队列中的消息。
代码如下:

using System;
using System.Messaging;
using System.Text;
using System.Threading;namespace App2
{internal class Program{static void Main(string[] args){// 消息队列路径string queuePath = @".\Private$\MyQueue";// 创建或获取消息队列MessageQueue queue;if (MessageQueue.Exists(queuePath))queue = new MessageQueue(queuePath);else{Console.WriteLine("No messages available.");Console.ReadLine();return;}try{// 不断接收和处理消息while (true){// 接收消息，设置超时时间为1秒// Message message = queue.Receive(TimeSpan.FromSeconds(1));Message message = queue.Receive();// 读取消息内容using (var reader = new System.IO.StreamReader(message.BodyStream, Encoding.UTF8)){string messageBody = reader.ReadToEnd();Console.WriteLine("Message received in Process 2: " + messageBody);}Thread.Sleep(1000);}}catch (MessageQueueException ex){// 如果等待超时或发生其他消息队列异常，则打印错误信息Console.WriteLine("Error receiving message: " + ex.Message);}Console.ReadLine();}}
}