电脑MESSAGE信息

MSMQ

1.建立MQ服务

 MessageQueue myQueue = new MessageQueue(string path);

Path路径格式

Queue type

Syntax

Public queue

MachineName\QueueName

公用队列

Private queue

MachineName\Private$\QueueName

专用队列

Journal queue

MachineName\QueueName\Journal$

Machine journal queue

MachineName\Journal$

系统队列--日志

Machine dead-letter queue

MachineName\Deadletter$

系统队列--死信信息

Machine transactional dead-letter queue

MachineName\XactDeadletter$

系统队列--事务性死信信息

 个人添加

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