zoukankan      html  css  js  c++  java
  • MQTT

    MQTT(消息队列遥测传输)是ISO 标准(ISO/IEC PRF 20922)下基于发布/订阅范式的消息协议。
    它工作在 TCP/IP协议族上,是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布/订阅型消息协议,为此,它需要一个消息中间件 。
    用于:机器与机器(M2M)通信和物联网(IoT)。其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。
    MQTT协议是为大量计算能力有限,且工作在低带宽、不可靠的网络的远程传感器和控制设备通讯而设计的协议,它具有以下主要的几项特性:
    1、使用发布/订阅消息模式,提供一对多的消息发布,解除应用程序耦合;
    2、对负载内容屏蔽的消息传输;
    3、使用 TCP/IP 提供网络连接;
    4、有三种消息发布服务质量:
    “至多一次”,消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况,环境传感器数据,丢失一次读记录无所谓,因为不久后还会有第二次发送。
    “至少一次”,确保消息到达,但消息重复可能会发生。
    “只有一次”,确保消息到达一次。这一级别可用于如下情况,在计费系统中,消息重复或丢失会导致不正确的结果。
    5、小型传输,开销很小(固定长度的头部是 2 字节),协议交换最小化,以降低网络流量;
    6、使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制。
    (1)Connect。等待与服务器建立连接。
    (2)Disconnect。等待MQTT客户端完成所做的工作,并与服务器断开TCP/IP会话。
    (3)Subscribe。等待完成订阅。
    (4)UnSubscribe。等待服务器取消客户端的一个或多个topics订阅。
    (5)Publish。MQTT客户端发送消息请求,发送完成后返回应用程序线程。

    MQTT是一种协议工具。 
     MQTT传输的消息分为:主题(Topic)和负载(payload)两部分:
      (1)Topic,可以理解为消息的类型,订阅者订阅(Subscribe)后,就会收到该主题的消息内容(payload);
      (2)payload,可以理解为消息的内容,是指订阅者具体要使用的内容。
    MQTT的搭建:
    mqtt相关的包
    sudo apt-get install mosquitto
    sudo apt-get install mosquitto-clients
    测试
    sudo service mosquitto status
    订阅:
    mosquitto_sub -h 192.168.1.102 -t "mqtt" -v
    -h  服务器
    -t    订阅主题
    -v 打印信息
    mosquitto_pub -t 192.168.1.102 -t "mqtt" -m "hello ShengLi"
    -h  服务器
    -t 推送主题
    -m 指定消息内容
    修改配置 实现指定用户登录:
    sudo vi /etc/mosquitto/mosquitto.conf
    allow_anonymous  false
    password_file /etc/mosqutto/pwfile
    acl_file /etc/mosqutto/acl

    添加用户:
    sudo mosquitto_passwd -c /etc/mosqutto/pwfile   ShengLi
    -c 添加一个用户
    启动:
    sudo -c /etc/mosquitto/mosquitto.conf
     
    MQTT 是一种连接协议,它指定了如何组织数据字节并通过 TCP/IP 网络传输它们。设备联网,也需要连接到互联网中,
    在大万维的世界中,TCP 如同汽车,有轮子就能用来运输数据,MQTT 就像是交通规则。在网络模型中,TCP是传输层协议,
    而 MQTT是在应用层,在 TCP 的上层,因此MQTT 也是基于这个而构建的,提高了可靠性。
     
     
     
  • 相关阅读:
    朴灵:基于MongoDB与NodeJS构建物联网系统
    平均年薪40万!为什么却很少见程序员炫富?
    写春联、变魔术、模仿马云唱歌_为你揭秘阿里云人工智能ET背后的技术
    Mysql查询性能优化-善用Explain语句
    numpy linspace arange函数
    vim笔记
    redis压缩列表
    tensorflow笔记之反向传播时用到的几种方法
    损失函数
    kafka 修改partition,删除topic,查询offset
  • 原文地址:https://www.cnblogs.com/countryboy666/p/11333938.html
Copyright © 2011-2022 走看看