【乐创“协”说】物联网消息队列MQ简介

MQTT(Message Queuing Telemetry Transport),说人话的意思就是消息队列遥测传输。早些年的PC端盛行的时候,很多工程师压根就没有听过个绕口的名词,但是随着物联网(IoT)技术的逐步发展,这个协议越来越频繁地出现在各大工程师的眼前。这也就造成了很多工程师只知其名不知其意,甚至很多热都还以为这是一种随着IoT发展而被开发出来的协议。其实不然,MQTT协议最早在二十几年前就被发明出来,到了1999年IBM公司的安迪·斯坦福-克拉克及Cirrus Link公司的阿兰·尼普撰写了该协议的第一个版本。后来这个协议也被国际标准化了,成为了ISO 标准(ISO/IEC PRF 20922)下基于发布/订阅范式的消息协议。IBM公司在2013年就向结构化资讯标准促进组织提交了 MQTT 3.1 版规范,并附有相关章程,以确保只能对规范进行少量更改,此后MQTT协议一直在一些小众领域中使用。而到了物联网技术基础设施架构完成之后,这种古老的协议开始焕发出它的第一个春天。

以太网的传输层和应用层众所周知,物联网至今的高速发展离开不了通讯网络的基础建设,你现在可以在全世界的任何一个角落控制家里某个房间灯光的开关,或者做工业控制的时候,你也可以远程操控某个机器人的运动,这种技术的成熟都是基于网络通讯为基础的。而目前网络技术的主要技术就是OSI七层模型,当然实际应用中其实使用的是TCP/IP四层网络模型。

TCP/IP四层网络模型的第三层传输层就是大名鼎鼎的TCP/IP协议了,这一层协议的主要目的是用来将网络上一台计算机发出的通信数据传输到指定IP地址的另一台机器上面,比如一个IP地址为“192.168.137.19”的机器要发给IP地址为“192.168.137.10”的机器16字节的二进制数据包,那么使用TCP/IP协议传输即可以。而是用TCP传输数据时,我们常用的方式就是用socket。

但当IP地址为“192.168.137.19”的机器发送数据给“192.168.137.10”的机器时,这一包TCP数据包里面的数据究竟是代表什么意思,接收端的IP地址为“192.168.137.10”的机器该如何其解析这一个包的数据,这个问题就是交由传输层上面一层的协议来解决了,这就是应用层协议。当然,如果你的协议不想给普通的网络上的计算机解析时,你也可以自己去制定一些应用层的协议,这个无关紧要,传输层的目的只是把数据传达到目标机器上面就可以了。我们日常的工作,娱乐中常常会碰到各种各样的应用层协议,比如当你打开一个网页时,这个图片显示在那个位置,这个按钮点下去是实现什么功能,这种都是由HTML超文本传输协议(英文:Hyper Text Transfer Protocol,缩写:HTTP)所约定的。这就保证了你网站中某个网页被任何一台设备请求时,这台设备可以正常的显示出来。除了HTTP,应用层协议还有很多,如DNS,FTP等,而我们今天的主角MQTT协议也是其中的一员。

为何物联网倾向于MQTT既然我们既有的应用中已经有了那么多优秀的应用层协议,为何在物联网领域中偏偏MQTT大放异彩。其实选择MQTT协议也不是毫无根据的,MQTT 是一种轻量级的、灵活的网络协议,致力于为 IoT 开发人员实现适当的平衡:这个轻量级协议可在严重受限的设备硬件和高延迟/带宽有限的网络上实现。它的灵活性使得为 IoT 设备和服务的多样化应用场景提供支持成为可能。大多数开发人员已经熟悉 HTTP Web 服务。那么为什么不让 IoT 设备连接到 Web 服务?设备可采用 HTTP 请求的形式发送其数据,并采用 HTTP 响应的形式从系统接收更新。这种请求和响应模式存在一些严重的局限性:HTTP 是一种同步协议。客户端需要等待服务器响应。Web 浏览器具有这样的要求,但它的代价是牺牲了可伸缩性。在 IoT 领域,大量设备以及很可能不可靠或高延迟的网络使得同步通信成为问题。异步消息协议更适合 IoT 应用程序。传感器发送读数,让网络确定将其传送到目标设备和服务的最佳路线和时间。HTTP 是单向的。客户端必须发起连接。在 IoT 应用程序中,设备或传感器通常是客户端,这意味着它们无法被动地接收来自网络的命令。HTTP 是一种一对一的协议。客户端发出请求,服务器进行响应。将消息传送到网络上的所有设备上,不但很困难,而且成本很高,而这是 IoT 应用程序中的一种常见使用情况。HTTP 是一种有许多标头和规则的重量级协议。它不适合受限的网络。出于上述原因,大部分高性能、可扩展的系统都使用异步消息总线来进行内部数据交换,而不使用 Web 服务。订阅/发布模型有意思的是,这种MQTT协议的服务器,其实是比web服务器设计还要简单地多,因为它追求的是一种高效性的服务。MQTT主要进行消息收发的机制有点类似于我们公众号和各位读者之间的关系。在现实的世界中,我和大家一样都类似于一个有一个的MQTT设备挂接在统一的一个服务器上面,大家出于对我们公众号的兴趣或者某种感情订阅了我们,而当每天我发文推送的时候,大家的手机里就会出现我推送的消息了,这个过程中,你获取我信息的方式被称为“订阅”,而我向这个公众号发布消息的行为就是“发布”。而大家看到我文章的时候,可以随意地向我留言,这个行为就是大家的“发布”行为,而我无时无刻守在某一篇推送面前看大家的留言,这就是一种“订阅”行为。在这个过程中,外部的所有信息都与我们无关,我们只是简单地以两个方向的信息流沟通着。MQTT中的消息传递机制也是基于“发布(Publish)”-“订阅(Subscribe)”的模型的。

MQTT具体的操作步骤为:第一步:使用先获得一个MQTT服务器,然后新建一个MQTT通讯产品。第二步:接着去连接这个服务器,连接服务器的两个重要的参数就是主机号(域名或者IP地址)和端口号。第三步:如果使用的是第三方云服务器平台,它可能需要你使用产品ID和鉴权信息去登录这个设备,这两个在设备云的后台都能找到。着三个步骤做完之后,你就可以对对应的主题订阅或者发布消息了。我后面会专门整理一个文档来给大家演示一下如何来“白嫖”一个中国移动的设备云开放接入平台。这三个步骤既适用于应用软件开发,也适用于单片机开发。在单片机开发时,如果你用AT指令和外部的WIFI模块通讯,那么一般模块都可以自带AT+MQTT命令,这是最好的办法,可以极大地减少单片机的压力。或者你也可以直接获取TCP/IP传输层的数据,然后自己去解析这个MQTT,这就需要用户对MQTT协议要有一个很深的理解还要自己去解析Json数据,所以一般在做嵌入式设备时,一般推荐大家直接用现成带MQTT协议的模块,直接解析AT指令是比较方便的。

案例分析:远程控制灯和获取当前房间温度。关于这个案例,其实是MQTT最简单的一个应用,首先房间的嵌入式控制板主要通过WIFI连接到服务器,它既可以控制灯的开关,也可以采集温度。远在天边的终端设备是一台手机。要保持通信正常,首先它们需要接入同一个MQTT服务器。设备端的温度信息,是设备采集的,因此需要将采集来的数据发布到“温度”主题,而手机是获取这个温度信息的,因此需要来订阅这个“温度”主题。一旦设备端发送温度信息到“温度主题”,这个主题就会被手机所接收。设备端的灯控,是设备执行的,因此需要订阅“灯开关”主题,而手机是控制灯的开关的,因此需要来对这个“灯开关”主题发布控制信息。一旦手机发送开灯信息到“灯开”关主题,这个主题就会被终端所接收,再去执行开灯命令。

以上就是MQTT协议的简介,后续我会做详细的设计教程。

(0)

相关推荐

  • Modbus转MQTT网关

    Modbus转MQTT网关简介: BL101是一款Modbus RTU.Modbus TCP转换为Modbus TCP.OPC UA.MQTT.华为云IoT.AWS IoT.阿里云IoT.金鸽云等协议 ...

  • 物联网关键技术:如何实现设备接入

    物联网云平台 设备接入.规则引擎.实时计算.数据存储都是物联网云平台的关键技术,其中设备接入组件(IoT Hub)是物联网云平台的核心. 物联网云平台架构(简化示意图) 物联网云平台需要支持多网络多协 ...

  • 面向IoT的协议选择思考

    对于使用传感器和保持连接性的IoT系统而言,如何使用这些元素和多种互联网技术相结合呢? 互联网协议并不陌生, 但是IoT相关的互联网协议可能是有不同, 有些协议被用来辅助塑造系统.TCP/IP协议栈上 ...

  • 【乐创“协”说】万物互联时代,作为工程师你必须知道这个协议——MQTT简介

    MQTT(Message Queuing Telemetry Transport),说人话的意思就是消息队列遥测传输.早些年的PC端盛行的时候,很多工程师压根就没有听过个绕口的名词,但是随着物联网(I ...

  • 物联网关键技术:消息队列

    消息队列MQ连接物联网与后端系统(业务应用.数据分析) 大量的设备接入物联网平台后,会产生各种类型的事件和数据,对接到后端的各种服务,包括计算和存储.消息队列可以起到异步通信.应用解藕.削峰平谷的作用 ...

  • 消息队列在RTOS的应用

    传说互联网应用有两大利器,一个是缓存,另一个就是消息队列. 一直相对消息队列做一下梳理,希望早日另有成文. 一叶知秋,实际上消息队列在嵌入式系统中同样有着广泛的应用. 近来致力于IoT和智能硬件,现学 ...

  • 手把手教姐姐写消息队列

    前言 这周姐姐入职了新公司,老板想探探他的底,看了一眼他的简历,呦呵,精通kafka,这小姑娘有两下子,既然这样,那你写一个消息队列吧.因为要用go语言写,这可给姐姐愁坏了.赶紧来求助我,我这么坚贞不 ...

  • C#后台异步消息队列实现

    简介 基于生产者消费者模式,我们可以开发出线程安全的异步消息队列. 知识储备 什么是生产者消费者模式? 为了方便理解,我们暂时将它理解为垃圾的产生到结束的过程. 简单来说,多住户产生垃圾(生产者)将垃 ...

  • RabbitMQ消息队列之Windows下安装和部署(一)

    参考文档: https://jingyan.baidu.com/article/ed15cb1bb5c3411be369819d.html https://blog.csdn.net/hzw19920 ...

  • RabbitMQ 消息队列中 VirtualHost介绍 与权限管理 | IT工程师的生活足迹

    一.VirtualHost 像mysql服务有数据库的概念并且可以设置用户对库和表等对象的操作权限,RabbitMQ也有类似的权限管理. 在RabbitMQ中可以虚拟消息服务器 VirtualHost ...

  • Redis、Kafka 和 Pulsar 消息队列对比

    刘德恩 云时代架构 一.最基础的队列 最基础的消息队列其实就是一个双端队列,我们可以用双向链表来实现,如下图所示: push_front:添加元素到队首: pop_tail:从队尾取出元素. 有了这样 ...

  • Go 中如何让消息队列达到最大吞吐量?

    kevwan Go语言中文网 今天 你在使用消息队列的时候关注过吞吐量吗? 思考过吞吐量的影响因素吗? 考虑过怎么提高吗? 总结过最佳实践吗? 本文带你一起探讨下消息队列消费端高吞吐的 Go 框架实现 ...