在《物联网核心协议—消息推送技术演进》一文中已向读者介绍了多种消息推送技术的情况,包括HTTP单向通信、Ajax轮询、Websocket、MQTT、CoAP等,其中MQTT协议为IBM制定并力推,其具有开放、简单、轻量级以及易于实现的特点使得其即便在资源受限的环境中也能得到很好的使用,比如运行在资源紧缺型的嵌入式系统中或网络带宽非常昂贵的环境中,除此之外,它也被广泛用于遥感勘测、智能家居、能源监测和医疗应用程序等各个领域,是物联网的重要组成部分,将来可能会成为物联网的事实标准。

  本篇文章将帮助读者认识MQTT协议以及在Linux环境下部署MQTT的开源实现Mosquitto进行体验验证,在后续文章中将展开对其源码框架的分析,为构建物联网平台做好铺垫。

一、MQTT协议分析

1.1、MQTT协议简介

  MQTT(MessageQueueing Telemetry Transport Protocol)的全称是消息队列遥感传输协议的缩写,是由IBM公司推出的一种基于轻量级代理的发布/订阅模式的消息传输协议,运行在TCP协议栈之上,为其提供有序、可靠、双向连接的网络连接保证。由于其开放、简单和易于实现所以能够应用在资源受限的环境中,对于M2M和物联网应用程序来说是一个相当不错的选择。

1.2、发布者/订阅者

  MQTT采用代理的发布/订阅模式实现了发布者和订阅者的解耦(decouple),因此,在MQTT协议中有三种角色:代理服务器、发布者客户端以及订阅者客户端,其中发布者和订阅者互不干扰,也就是说发布者和订阅者互不知道对方的存在,它们只知道代理服务器,代理服务器负责将来自发布者的消息进行存储处理并将这些消息发送到正确的订阅者中去。这种解耦体现在以下3个方面上:

·空间解耦:发布者和订阅者不必知道对方的存在,例如对方的IP地址或者端口;

·时间解耦:发布者和订阅者不必同时建立连接;

·同步解耦:发布者和订阅者在发布消息或接收消息的时候不需要同步;

1.3、MQTT的消息类型

  MQTT的三种角色通过14种不同的消息类型进行交互:

1.CONNECT控制报文用于客户端请求与服务器建立连接,应用层的连接而不是TCP/IP连接,CONNECT控制报文的发送在TCP/IP建立连接后;

2.CONNACK控制报文用于服务器向请求连接的客户端回发连接确认;

3.PUBLISH控制报文用于发布指定主题名的应用信息;

4.PUBACK/PUBREC/PUBREL/PUBCOMP控制报文用于针对不同服务质量的应用信息的回应;

5.SUBSCRIBE控制报文用于订阅者向服务器发送一个主题过滤器列表,用于表示客户端想要订阅的主题;

6.SUBACK控制报文用于SUBSCRIBE控制报文的响应;

7.UNSUBSCRIBE控制报文用于向服务器发送一个主题过滤器列表,用于表示客户端想要取消订阅的主题;

8.UNSUBACK控制报文用于UNSUBSCRIBE控制报文的响应;

9.PINGREQ/PINGRESP控制报文作为客户端和服务器间的心跳包;

10.DISCONNECT控制报文用于客户端在断开前告诉服务器其将断开连接;

1.4、主题(topic)

  使用主题是服务器为每一个客户端管理应用信息所采用的一种方式,一个主题名可以由多个主题层级(topic level)组成,每一层通过’/’斜杠分隔开,当客户端指定的主题过滤器包含通配符时,即客户端想一次订阅多个具有类似结构的主题时,主题层级分隔符就很有用了。

  主题通配符只可用在主题过滤器中,在发布应用消息时的主题名不允许包含通配符,主题通配符有两种:

  单层通配符:’+’,它会匹配某一个主题层级中的所有主题;

  多层通配符:’#’,它会匹配多个主题主题层级的主题;

  例如:如果客户端订阅时的主题过滤器为”grade/subject/math/#”,它会收到使用下列主题名发布的消息:

“grade/subject/math”

“grade/subject/math/student1”

“grade/subject/math/student1/lastterm”

1.5、服务质量等级(QosLevels)

  MQTT提供三种Qos的消息传递质量:

  a.最多一次(Atmost once delivery):QoS=0,协议对此等级应用信息不要求回应确认,也没有重发机制,这类信息可能会发生消息丢失或重复,取决于TCP/IP提供的尽最大努力交互的数据包服务。

  b.最少一次(Atleast once delivery):QoS=1,确保信息到达,但消息重复可能发生,发送者如果在指定时间内没有收到PUBACK控制报文,应用信息会被重新发送,且控制报文中DUP标志位置1。

  c.仅仅一次(Exactlyonce delivery):QoS=2,最高级别的服务质量,消息丢失和重复都是不可接受的。

1.6、支持MQTT协议的服务器和客户端

  当前流行的开源代理服务器(MQTT Broker)的实现有:mosquitto, HiveMQ, Apache ActiveMQ, RabbitMQ, mosca等,MQTT客户端也有不同操作系统和编程语言下的实现,流行的客户端库(MQTT ClientLibraries)有:Eclipse Paho(支持C,C++, Java, Javascript, Python, Go, C#), M2MQTT(C#), Fusesource MQTTClient(Java), MQTT.js(javascript), libmosquitto(c/c++)等等,通过以上库而开发出的MQTT客户端应用程序有:mosquitto_pub/mosquitto_sub(可运行于Linux, Windows, MacOSX操作系统), HiveMQWebsocket Client(Web browser), MyMQTT(Android), MQTTLens(Google Chrome)等等。

二、Mosquitto部署验证

2.1、Ubuntu下安装Mosquitto

1.源码包下载:http://mosquitto.org/files/source/

版本:mosquitto-1.4.tar.gz

解压:tar -zxvf mosquitto-1.4.tar.gz

进入目录:cd mosquitto-1.4

2.编译安装

打开配置文件,去掉暂且不需要的功能:

vi config.mk

如:WITH_TLS,WITH_TLS_PSK, WITH_SRV, WITH_WEBSOCKETS, WITH_SOCKS, WITH_UUID等

保存退出:wq

安装mosquitto

make

make install

2.2、启动mosquitto服务器

  mosquitto默认以mosquitto用户启动,所以首先创建mosquitto用户:

  adduser mosquitto

  启动代理服务器:mosquitto -c/etc/mosquitto/mosquitto.conf.example

  在启动服务器过程中有可能遇到以下错误:找不到libmosquitto.so.1文件,解决方法是添加链接库路径:

  vi/etc/ld.so.conf.d/liblocal.conf

  /usr/local/lib64

  /usr/local/lib

  退出文件后刷新:ldconfig

  重新执行:mosquitto -c /etc/mosquitto/mosquitto.conf.example

2.3、启动订阅者客户端mosquitto_sub,订阅test主题

  mosquitto_sub客户端应用程序位于/mosquitto-1.4/client目录下,执行./mosquitto_sub-t test, -t表示主题过滤器属性,后面带指定的主题过滤器。

2.4、启动发布者客户端mosquitto_pub,并且多次发布主题信息

  ./mosquitto_pub-t test -l

  其中-t表示发布的主题名,主题名中不允许包含通配符,-l是指通过标准输入的方式输入将要发布的应用信息,更多的属性可通过:./mosquiito_pub --help了解,也可通过官网了解:

http://mosquitto.org/man/mosquitto_pub-1.html。

发布者发布应用信息:

2.5、发布者通过键入”Ctrl+D”向服务器发送DISCONNECT控制报文,然后正常退出

如果通过”Ctrl+C”终止客户端程序(异常网络断开),服务器将提示:Scoket error

  本篇文章初步讲述了MQTT协议及以其中的一种实现为例进行部署和体验,协议的详细具体内容如控制报文格式等,读者可自行到官网下载文档查阅,也可以关注嵌入式企鹅圈来获取共享资源。

  接下来会对Mosquitto的mosquito_pub发布者的客户端源码框架进行深入分析,掌握MQTT的实现和编程。

物联网MQTT协议分析和开源Mosquitto部署验证相关推荐

  1. 一文读懂物联网 MQTT 协议之实战篇

    一.前言 上一篇我们介绍了 MQTT 协议格式以及相关的特性:一文读懂物联网 MQTT 协议之基础特性篇,这一篇我们就来实战一番,理论得与实践结合,方能吃透 MQTT. 我的那个读者还提到了讲一下 M ...

  2. 一文读懂物联网 MQTT 协议之基础特性篇

    一.前言 上个月有个读者问我物联网 MQTT 协议实战相关的问题,我说后面会搞,没想到不知不觉一个月了,太忙了,再怎么忙答应的事情还是要给读者一个交代,所以就有了此文. 二.MQTT 协议概要 2.1 ...

  3. 物联网 MQTT 协议

    MQTT官网:MQTT - The Standard for IoT Messaging MQTT中文网(全是广告):首页 | MQTT中文网 物联网百科 物联网(Internet of Things ...

  4. 物联网MQTT协议详解

    一.什么是MQTT协议 Message Queuing Telemetry Transport:消息队列遥测传输协议.是一种基于客户端-服务端的发布/订阅模式.与 HTTP 一样,基于TCP/IP协议 ...

  5. 【协议分析】Web QQ登陆验证分析

    今天开始想写个验证QQ密码的工具,以前写过一个QQ验证器的程序,就拿了那个代码试了一下居然不能同.就到QQ登陆页面去抓包. xmit.jpg (110.62 KB, 下载次数: 111) 下载附件   ...

  6. MQTT协议(1)介绍

    物联网MQTT协议介绍 1.MQTT概述 是一种基于发布/订阅(publish/subscribe)模式的"轻量级"通讯协议,该协议构建于TCP/IP协议上,由IBM在1999年发 ...

  7. 物联网应用层协议选择和分析--MQTT、CoAP 、HTTP、XMPP、SoAP

    物联网应用层协议选择和分析--MQTT.CoAP .HTTP.XMPP.SoAP MQTT协议 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)最早 ...

  8. 浅浅的 使用网络调试助手和Mosquitto 分析MQTT协议数据包内容

    使用网络调试助手和Mosquitto 分析MQTT协议数据包内容 参考: 零.涉及到的主要的数据包: 一.环境搭建 二.connect数据包 根据数据包的内容逐个字节进行分析: 三.心跳包 四.订阅S ...

  9. MQTT学习笔记——MQTT协议体验 Mosquitto安装和使用

    原版地址:http://blog.csdn.net/xukai871105/article/details/39252653 0 前言 MQTT是IBM开发的一个即时通讯协议.MQTT是面向M2M和物 ...

最新文章

  1. BZOJ1856[Scoi2010]字符串——组合数学+容斥
  2. 11.14 模拟:总结
  3. 客制化键盘键位修改_可以用很漂亮形容的一把键盘,差一步就完美
  4. 虚拟化精华问答 | 什么是虚拟化?
  5. NVIDIA DLI 深度学习培训 | 北京 上海两站新年火热来袭
  6. apache 支持 php5
  7. 国内git clone报错问题解决办法
  8. 【QGIS】shp文件下载
  9. 董明珠为什么选择长沙?
  10. 安卓后门工具:backdoor-apk 教程
  11. 【SEO网络推广】会被百度K站的原因
  12. [简单]poi 创建word2007脚注(FootNote)
  13. 你还在以为打马赛克就安全了吗?AI消除马赛克,GitHub开源项目上线三天收获近7000星
  14. intent跳转和转场动画
  15. 微型机器人正迎来发展,三大领域应用大有可为
  16. 使用Lodop进行web 打印(jatoolsPrinter,墙外打印控件 楚琳Web打印控件)
  17. 高视角!如何认识微积分方法与原理?
  18. mysql CONFLICT 冲突
  19. 唱吧免费导出歌曲mp3
  20. OpenOCD的调试

热门文章

  1. c#窗体应用计算机设计,C#应用程序设计
  2. 计算机cpu散热方式,调整电脑CPU散热风扇转速的简单方法【图文】
  3. AJPFX:什么是外汇交易
  4. [项目管理]项目计划如何做
  5. 正则表达式判断合法的电话号码
  6. 使用python生成随机中奖姓名和电话号码并存入excel
  7. STL-老子的全排列呢
  8. 手把手教你如何制作和使用lib和dll
  9. 利用Google AIY Vision Kit 自制人类检测器(下)
  10. FCK上传图片问题解决