转:https://www.cnblogs.com/80X86/p/5557801.html

功能需求,用到了队列,用的时候出了很多问题,现在总结一下,希望能对有需要的人提供帮助。

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

    一般情况下,使用MSMQ,要先安装消息服务,这个直接百度就行;

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

   首先、创建队列:根据我的需求,我要通过Socket通信将信息发送至数据转发服务器,因此为了避免并发访问问题的产生,消息队列应当建立在数据转发服务器上;

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

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

相关文章: