文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

WCF分布式开发之MSMQ消息队列

2024-04-02 19:55

关注

一、MSMQ简介

MSMQ(微软消息队列)是Windows操作系统中消息应用程序的基础,是用于创建分布式、松散连接的消息通讯应用程序的开发工具。

MSMQ与XML Web Services和.Net Remoting一样,是一种分布式开发技术。但是在使用XML Web Services或.Net Remoting组件时,Client端需要和Server端实时交换信息,Server需要保持联机。MSMQ则可以在Server离线的情况下工作,将Message临时保存在Client端的消息队列中,以后联机时再发送到Server端处理。

1、MSMQ的实现原理

消息的发送者把自己想要发送的信息放入一个容器,然后把它保存到一个系统公用空间的消息队列中,本地或异地的消息接收程序再从该队列中取出发给它的消息进行处理。

消息队列是一个公用存储空间,它可以存在于内存中或物理文件中,因此,消息以两种方式发送,即快递方式和可恢复模式。MSMQ机制类似QQ消息传递机制。下图演示了MSMQ的实现原理。

2、安装

默认情况下安装操作系统是不安装消息队列的,你可以在控制面板中找到添加/删除程序,然后选择添加/删除Windows组件一项,然后选择应用程序服务器,双击它进入详细资料中选择消息队列一项进行安装。

如果服务没有自动启动,需要启动服务: 
这里写图片描述

3、两个概念

一个是消息Message:Message是通信双方需要传递的消息,它可以是文本、图片、视频等。消息包含发送和接收者的标识,只有指定的用户才能取得消息。

另一个是队列Queue:用来保存消息的存储空间,消息对列分为3类:

4、MicroSoft.Message.Queue常用的方法:

二、服务端

首先,实现服务器端。创建一个控制台项目,添加System.Messaging引用,因为消息队列的类全部封装在System.Messaging.dll程序集里。

服务器端代码需要注意的是,公共队列只能在域环境中创建,如果个人电脑没有加入域环境,则不能创建公共队列。

    if (!MessageQueue.Exists(@".\MYFIRSTMSMQ"))
    {
        using (MessageQueue mq = MessageQueue.Create(@".\MYFIRSTMSMQ"))//创建一个公共消息队列
        {
            mq.Label = "myFirstMSMQ";
            Console.WriteLine("已经创建了一个公共队列{0}", mq.Label);
            Console.WriteLine("公共队列{0}的路径为{1}", mq.Label, mq.Path);
            mq.Send("MSMQ 消息", "今天又学到个有趣的知识");
        }
    }
    foreach (MessageQueue mq in MessageQueue.GetPublicQueues())//获取所有公共队列,发送消息
    {
        mq.Send("发送公共消息队列" + DateTime.Now.ToLongTimeString(), "今天又学到个有趣的知识");
        Console.WriteLine("公有消息已经送到{0}", mq.Path);
    }

    if (!MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))
    {
        using (MessageQueue mq = MessageQueue.Create(@".\Private$\MYFIRSTMSMQ"))//创建一个私有消息队列
        {
            mq.Label = "myFirstPrivateMSMQ";
            Console.WriteLine("已经创建了一个私有队列{0}", mq.Label);
            Console.WriteLine("私有队列{0}的路径为{1}", mq.Label, mq.Path);
            mq.Send("MSMQ 私有队列消息" + "今天又学到个有趣的知识");
        }
    }

    if (MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))
    {
        MessageQueue mq = new MessageQueue(@".\Private$\MYFIRSTMSMQ");//找到私有队列,发送消息

        mq.Send("发送私有消息队列" + DateTime.Now.ToLongTimeString() + "今天又学到个有趣的知识");
        Console.WriteLine("私有消息已经送到{0}", mq.Path);
    }

三、客户端

服务器端把消息发送到共享的消息队列中,然后,客户端从这个共享的消息队列中取出消息进行处理。

if (MessageQueue.Exists(@".\MYFIRSTMSMQ"))// 获取公共消息队列
{
    using (MessageQueue mq = new MessageQueue(@".\MYFIRSTMSMQ"))//创建消息队列对象
    {
        mq.Formatter = new XmlMessageFormatter(new string[] { "System.String" });//设置消息队列的格式化器,还有BinaryMessageFormatter,ActiveXMessageFormatter等
        foreach (Message msg in mq.GetAllMessages())
        {
            Console.WriteLine("接收到的消息是:{0}", msg.Body);
        }
        Message firstmsg = mq.Receive();
        Console.WriteLine("收到的第一条消息为:{0}", firstmsg.Body);
    }
}

if (MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))// 获取私有消息队列
{
    using (MessageQueue mq = new MessageQueue(@".\Private$\MYFIRSTMSMQ"))
    {
        //....
    }
}

到此这篇关于WCF分布式开发之MSMQ消息队列的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持编程网。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯