C# 使用消息队列，包括远程访问

    近期作一个小的功能需求，用到了队列，用的时候出了不少问题，如今总结一下，但愿能对有须要的人提供帮助。

    个人需求很简单，就是多个客户端链接到个人一个小型的数据转发服务器上，开始使用的是Socket通讯实现这个功能，一旦数据服务器接收到来自不一样客户端发来的消息，就对这些消息进行处理（我这里是将数据接收到后再转发到另外一个服务器上），但考虑到客户端是每隔一个很短的时间周期向服务器发送信息，而且链接客服端数量比较多的时候，担忧会产生并发访问的问题，也但愿避免 数据转发服务器 频繁地从多个不一样线程获取信息而出现其余未知问题，因此在处理客户端向数据转发服务器发送信息的时候采起队列的方式。

    通常状况下，使用MSMQ，要先安装消息服务，这个直接百度就行；

    在VS里添加 Messaging引用，就可使用MessageQueue这个类了；接下来就要思考清楚你的数据（消息）的流向问题，以前由于本身对队列的错误认识，对到底在哪建立队列，队列的消息又由谁去发送和接收没有弄清除，还有参考的一些写得不是太清晰地博文，绕了好大一圈，因此今天在这里以我本身的项目需求为例子，说明 一、如何建立队列 二、如何向队列发送消息 三、 如何获取队列中的消息

   首先、建立队列：根据个人需求，我要经过Socket通讯将信息发送至数据转发服务器，所以为了不并发访问问题的产生，消息队列应当创建在数据转发服务器上；

　　　　　　　MessageQueue myqueue = null;
　　　　　　　string queuepath = @".\private$\queuedemo";

            if (!MessageQueue.Exists(queuepath))
            {
                myqueue = MessageQueue.Create(queuepath);
            }
            myqueue = new MessageQueue(queuepath);

    这样就在数据转发服务器端建立了一个名为queuedemo的消息队列；从客户端要发送的消息就保存在这个队列里，你能够经过计算机管理->服务和应用下的消息队列中看到你建立的queuedemo队列，private$关键字是说明队列为专用队列，若是没有这个关键字还要配置域服务器，仍是挺麻烦，这个仍是借助百度吧，前面的“.”表明建立的队列目录是本机，这个队列一旦建立成功，就是系统的事了，接下来要作的就是你怎么去把消息写进这个队列，或者读取队列的值 这里要特别注意，不要将queuepath路径字符串写成

string queuepath = @"FormatName:Direct=TCP:192.168.1.153\private$\queuedemo";

这样写的话是用于远程计算机对这个队列进行访问的，由于MessageQueue的Create()和Exisit()方法是没办法去识别上述FormatName格式的,还有要确保Create()函数要被执行了以后再用MessageQueue实例去引用；这样服务器端队列的建立就完成了；

     在客户端中，向队列发送信息；

    

string s = "客户端往队列里发送的信息");
            System.Messaging.Message msg = new System.Messaging.Message();
            msg.Body = s;
            msg.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
            MessageQueue mq = new MessageQueue(@"FormatName:Direct=TCP:192.168.1.153\private$\queuedemo");
            mq.Send(msg);

在客户端中，用一个MessageQueue实例指向服务器本机上建立的队列路径，这时，MessageQueue实例的构造函数里的路径就必定要用FormatName格式，指明是TCP通讯仍是HTTP仍是Machine如我上面代码所示，而后调用Send()方法，将消息写进队列，这个要求发送的对象要以序列化的方式写进去，因此要设置formatter,这里用的是XmlMessageFormatter 还有BinaryMessageFormatter等等 注意保存你消息的 消息体Body是Object类型的 所以能够将你写的任何一个类的对象发送至消息队列

    在服务器中接收消息队列

MessageQueue mq = new MessageQueue(@".\private$\queuedemo");

            mq.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
            Thread th = new Thread(() =>
                {
                    while (true)
                    {
                        System.Messaging.Message msg = mq.Receive();
                        if (msg != null)
                        {
                            MessageBox.Show(msg.Body.ToString());
                        }

                    }
                });
            th.IsBackground = true;
            th.Start();

在本机上能够新建立一个队列实例指向本机的队列，而后按照以前约定的序列化格式反序列化消息体因此将新的队列实例的foarmatter属性赋值为发送时的formatter属性如代码所示，这个时候就直接用Receive()获得消息体，而后对消息体里的信息作处理，我这里是开启一个线程显示队列的消息，只要有新的消息写入，我就在消息框中输出

 

    这个时候可能客户端没法向远程服务器成功发送消息，缘由基本权限问题 服务器的消息队列的权限没有对未验证的客户端开放  你要在服务器队列里分配对应权限 若是你想读取队列的内容 还须要加系统变量

 

 问题解决办法

1. 服务器端

• 服务器上消息队列权限设置：给ANONYMOUS LOGON赋予全部权限；
  
  
• 修改服务器的注册表，容许非验证客户端访问
  
  • 注册表新增HKLM\Software\Microsoft\MSMQ\Parameters\security\AllowNonauthenticatedRpc项，设置其DWORD值为1
  • 注册表新增HKLM\Software\Microsoft\MSMQ\Parameters\security\NewRemoteReadServerDenyWorkgroupClient项，设置其DWORD值为1
    
    MSMQ的安全访问控制说明参见：http://msdn.microsoft.com/en-us/library/4108f68e-80f5-40e1-b3df-b713cc4dff79(prot.20).aspx

 

这样客户端就能够读取服务器里的队列信息了 固然通常业务逻辑上不这么作 由于他只负责发送消息 ，综上，就是使用消息队列 跨服务器读写的 最基本的用法