你的位置:首页 > 软件开发 > ASP.net > 工业物联网或系统集成中应用消息队列(ActiveMQ,C#的demo)的场景全面分析

工业物联网或系统集成中应用消息队列(ActiveMQ,C#的demo)的场景全面分析

发布时间:2016-05-19 17:00:09
1.[连载]《C#通讯(串口和网络)框架的设计与实现》2.[开源]C#跨平台物联网通讯框架ServerSuperIO(SSIO)介绍2.应用SuperIO(SIO)和开源跨平台物联网框架ServerSuperIO(SSIO)构建系统的整体方案3.C#工业物联网和集成系统解决方案的 ...

1.[连载]《C#通讯(串口和网络)框架的设计与实现》

2.[开源]C#跨平台物联网通讯框架ServerSuperIO(SSIO)介绍

2.应用SuperIO(SIO)和开源跨平台物联网框架ServerSuperIO(SSIO)构建系统的整体方案

3.C#工业物联网和集成系统解决方案的技术路线(数据源、数据采集、数据上传与接收、ActiveMQ、Mongodb、WebApi、手机App)

5.ServerSuperIO开源地址:https://github.com/wxzz/ServerSuperIO

 

目       录

工业物联网或系统集成中应用消息队列(ActiveMQ)的场景全面分析... 1

前言... 1

第一章           终端/交互场景... 3

1.1           终端设备... 3

1.2           通讯机制... 3

第二章           ActvieMQ应用场景... 4

2.1           发布/订阅(Publish/Subscribe)... 4

2.2           生产者/消费者(Producer/Consumer)... 7

2.3           请求/应答(Request/Response)... 10

第三章           假定场景分析... 16

3.1           通讯层... 16

3.2           数据业务层... 16

3.3           综述... 16

 

前言

     互联网技术已经发展的很成熟了,各种开源的代码、框架和解决方案等。鉴于互联网技术的通用性,势必向其他领域延展。不管是工业4.0,还是互联网+  工业,互联网技术向工业领域传导也是必然的。

     所以,对于工业方面的应用场景的技术储备和技术线路调研也是日常工作很重要的一部分,为公司的横向和纵向发展提供技术平台和保障,当然也取决于领导的视野。

第一章     终端/交互场景

    任何技术都是为业务服务,而业务是有特定的应用场景。离开了实现环境去谈技术是没有实际意义的,解决实际问题而又能保证相当长时间内的稳定性是我们努力实现的目标。同时要从多个角度来考虑问题,以及做出平衡。

1.1    终端设备

(1)    终端种类:嵌入式硬件/传感器、PC机(监测站、大型监控设备等)、手机终端等。

(2)    交互方式:单向交互,数据上传,可能服务端会有返回确认信息,证明数据已经收到了;双向交互,服务端不仅仅会返回确认信息,同时还要主动下发给指定终端命令信息,例如:控制硬件设备机械动作命令、修改硬件设备参数命令、以及补传相关数据信息命令等等。

(3)    设备管理:这里指的设备管理是说设备的状态,包括两个方面:设备IO状态和设备通讯状态。设备IO状态包括:IO打开和IO关闭。设备通讯状态包括:通讯中断、通讯干扰和通讯正常。为了判断故障,这里的逻辑关系是:IO打开的时候不一定代表通讯正常;IO关闭不一定代表通讯中断;通讯中断不一定代表IO关闭;通讯干扰不一定代表IO打开。

(4)    数据完整性:允许数据缺失,一般在原来数据基础上的增量数据是可以允许丢失的;不允许数据缺失,一般脉冲数据是不允许数据丢失的。

1.2    通讯机制

(1)主动请求数据:服务器端主动下发命令给终端,让谁上传数据、上传什么数据都由服务器端决定。

(2)被动接收数据:服务器端被动接收终端上传的数据,根据数据信息进行数据处理,以及返回确认信息。

第二章     ActvieMQ应用场景

     消息队列比较多,本文以ActiveMQ为例进行介绍,全部代码实现C#为主,主要考虑到常见的应用模式。事例代码下载:http://pan.baidu.com/s/1qXZ1sU4。

2.1    发布/订阅(Publish/Subscribe)

     一个信息发布者在某一个主题上发布消息,所有订阅该主题的订阅都会收到相同的消息,这种模式是一对多的关系,如下图:

工业物联网或系统集成中应用消息队列(ActiveMQ,C#的demo)的场景全面分析

发布端代码:

static void Main(get='_blank'>string[] args)    {      try      {        IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/");        using (IConnection connection = factory.CreateConnection())        {          using (ISession session = connection.CreateSession())          {            IMessageProducer prod = session.CreateProducer(new Apache.NMS.ActiveMQ.Commands.ActiveMQTopic("Topic"));            string text = Console.ReadLine();            while (text!="exit")            {              ITextMessage msg = prod.CreateTextMessage();              msg.Text = text;              prod.Send(msg, Apache.NMS.MsgDeliveryMode.NonPersistent, Apache.NMS.MsgPriority.Normal, TimeSpan.MinValue);              Console.WriteLine("Sending: " + text);              System.Threading.Thread.Sleep(2000);            }          }        }        Console.ReadLine();      }      catch (System.Exception e)      {        Console.WriteLine("{0}", e.Message);        Console.ReadLine();      }    }

原标题:工业物联网或系统集成中应用消息队列(ActiveMQ,C#的demo)的场景全面分析

关键词:C#

C#
*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们: admin#shaoqun.com (#换成@)。

可能感兴趣文章

我的浏览记录