我的体验和理解：使用微软MSMQ (MessageQueue)

最编程 2024-08-06 17:20:34

...

Label

Label:TheLabel

利用标签，写入（标签唯一），目前试出公共队列可以使用标签，其他使用不了

FormatName

1.FormatName:Direct=TCP:ip\\private$\\myqueue

2.FormatName:Direct=OS:machinename\\private$\\queuename

3.FormatName:DIRECT=http://222.10.xx.xx/msmq/Private$/test

1.FontName是区分大小写的

2.如果远程服务器为域中的服务器则可使用Direct=OS:machinename\Private$\...的形式发送消息。

3.如果远程服务器为非域中的服务器，则可以使用TCP或http的形式发送。

5.在代码中创建的队列实例对象的事务性属性，必须与要发送的目标队列的属性相匹配。前面的例子中发送的消息为非事务型消息，如果要发送消息到事务型的队列，代码为：

MessageQueue rmTxnQ = new MessageQueue

("FormatName:Direct=OS:machinename\\private$\\queue");

rmTxnQ.Send("sent to Txn queue - Atul", MessageQueueTransactionType.Single);

如果事务型属性不匹配，消息将无法传递。系统不会返回任何错误，但该条消息却会丢掉。

MessageQueueTransactionType

// Operation will not be transactional.

None = 0,

// Summary:

// A transaction type used for Microsoft Transaction Server (MTS) or COM+ 1.0

// Services. If there is already an MTS transaction context, it will be used

// when sending or receiving the message.

Automatic = 1,

// Summary:

// A transaction type used for single internal transactions.

Single = 3,

2.通过MQ传出的信息，如果远程MQ服务器，断掉了。如图中，系统的传出队

对于队列信息，可以手动清除

标签

5.MessageQueue.Receive();这个接收MSMQ信息的方法，是实时的

需要

MessageQueue queueJournal = new

MessageQueue(".\\myQueue");

while (true)

{

Message journalMessage = queueJournal.Receive();

// Process the journal message.

journalMessage.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });

if (journalMessage != null)

Console.WriteLine("" + journalMessage.Body);

}

//new Message(object body);

//赋值 body

//更改body 信息

// m.Body = "HY_Public queue by path name.";

Message.Formatter 解析body的格式

Gets or sets the formatter used to serialize an object into or deserialize

an object from the message body.

MessageQueue.Send发送信息到MSMQ

MessageQueue.receive实时接收信息

8.获取MQ数据方法

a. 声明 MessageQueue myQueue = new MessageQueue(".\\myAsyQueue");

b. //这里使用了委托,当接收消息完成的时候就执行MyReceiveCompleted方法

myQueue.ReceiveCompleted += new ReceiveCompletedEventHandler(MyReceiveCompleted);

myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });

3. 等待接收第一个MQ信息

//通知一个或多个正在等待的线程已发生事件

3.1类声明变量 static ManualResetEvent signal = new ManualResetEvent(false);

3.2 MessageQueueTransaction myTransaction = new MessageQueueTransaction();//用途不明确

myTransaction.Begin();

myQueue.BeginReceive();//启动一个没有超时时限的异步操作

signal.WaitOne();//等待接收线程的信息

myTransaction.Commit();

3.3 方法

private static void MyReceiveCompleted(Object source, ReceiveCompletedEventArgs asyncResult)

{

try

{

MessageQueue myQueue = (MessageQueue)source;

myQueue.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });

//完成指定的异步接收操作

Message message = myQueue.EndReceive(asyncResult.AsyncResult);

//处理信息

signal.Set();//设置线程信息

string book = message.Body.ToString();

Console.WriteLine("收到" + book);

myQueue.BeginReceive();//开始接收下个信息

}

catch (MessageQueueException me)

{

}

获取或设置一个值，该值指示是否由应用程序维护连接缓存。

public static bool EnableConnectionCache { get; set; }

1.peek方法（获取信息，但是不移除）

Peek()

返回，但不移除（查看）在队列中的第一个消息引用的 MessageQueue。 Peek 方法是同步的因此阻止当前线程，直至有消息变为可用。

2.reflash方法

Refresh 同步的属性 MessageQueue 与其相关联的消息队列服务器资源。如果任何属性，如 Label 或 Category, ，次后，在服务器上发生更改 MessageQueue 已创建，请 Refresh 更新 MessageQueue 使用新的信息。

4.delete方法

删除消息队列服务器上的队列。

6. 清除某个队列的数据

MessageQueue myQueue = new MessageQueue(".\\myAsyQueue");

myQueue.Purge();

上一篇： C# MSMQ: 实现进程间通信的利器

下一篇：试试看PDDL演示

我的体验和理解：使用微软MSMQ (MessageQueue)

使用PyTorch实现的UNet-3D：我的理解和代码实践

我的体验和理解：使用微软MSMQ (MessageQueue)