阅读量:0
在C#中实现MSMQ的持久化可以通过设置消息队列的属性来实现。以下是一个简单的示例:
using System; using System.Messaging; class Program { static void Main() { // 创建一个消息队列 MessageQueue queue = new MessageQueue(".\\private$\\MyQueue"); // 设置消息队列的属性,使得消息持久化 queue.DefaultPropertiesToSend.Recoverable = true; // 发送消息 Message message = new Message(); message.Body = "Hello, World!"; queue.Send(message); // 接收消息 Message receivedMessage = queue.Receive(); Console.WriteLine("Received message: " + receivedMessage.Body); // 关闭消息队列 queue.Close(); } }
在上面的示例中,通过设置Recoverable
属性为true
,实现了消息的持久化。这样即使在消息队列服务重启之后,消息依然会被保留下来。同时,使用Send
方法发送消息,使用Receive
方法接收消息。