`
longgangbai
  • 浏览: 7330401 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

MQTT的学习研究(十)【转】mosquitto——一个开源的mqtt代理

阅读更多

        MQTT(MQ Telemetry Transport),消息队列遥测传输协议,轻量级的发布/订阅协议,适用于一些条件比较苛刻的环境,进行低带宽、不可靠或间歇性的通信。值得一提的是mqtt提供三种不同质量的消息服务:

  • “至多一次”,消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况,环境传感器数据,丢失一次读记录无所谓,因为不久后还会有第二次发送。
  • “至少一次”,确保消息到达,但消息重复可能会发生。
  • “只有一次”,确保消息到达一次。这一级别可用于如下情况,在计费系统中,消息重复或丢失会导致不正确的结果。

下面是比较详细的介绍链接。

MQ 遥测传输 (MQTT) V3.1 协议规范

http://www.ibm.com/developerworks/cn/webservices/ws-mqtt/index.html

 

而mosquitto是一个开源broker,并且支持MQTTv3.1,支持客户端的验证。

mosquitto包括服务端和客户端。

 

mosquitto_pub 客户端可发布一条消息到指定主题:

用法:

mosquitto_pub [-d] [-h hostname] [-i client_id] [-I client id prefix] [-p port number] [-q message QoS] [--quiet] [-r] { -f file | -l | -m message | -n | -s} [-u username [-P password] ] [ --will-topic topic [--will-payload payload] [--will-qos qos] [--will-retain] ] -t message-topic  

选项:

-d, --debug  

开启debug选项

-f, --file

把一个文件的内容做为消息的内容发送。经测试,支持txt文件,不支持doc等其他形式文件。

-h, --host

说明所连接到的域名,默认是localhost

-i, --id

客户端的ID号,如果没有指定,默认是mosquitto_pub_加上客户端的进程id,不能和--id_prefix同时使用。

-I, --id-prefix

指定客户端ID的前缀,与客户端的进程ID连接组成客户端的ID,不能喝--id同时使用。

-l, --stdin-line

从总段读取输入发送消息,一行为一条消息,空白行不会被发送。

-m, --message

从命令行发送一条消息,-m后面跟发送的消息内容。

-n, --null-message

发送一条空消息。

-p, --port

连接的端口号,默认是1883.

-P, --pw

指定密码用于代理认证,使用此选项时必须有有效的用户名。 

-q, --qos

指定消息的服务质量,可以为0,1,2,默认是0.

--quiet

如果指定该选项,则不会有任何错误被打印,当然,这排除了无效的用户输入所引起的错误消息。

-r, --retain

如果指定该选项,该条消息将被保留做为最后一条收到的消息。下一个订阅消息者将能至少收到该条消息。

-s, --stdin-file

从标准输入接收传输的消息内容,所有输入做为一条消息发送。

-t, --topic

指定消息所发布到哪个主题。

-u, --username

指定用户名用于代理认证。

--will-payload

如果指定该选项,则万一客户端意外和代理服务器断开,则该消息将被保留在服务端并发送出去,该选项必须同时用--will-topic指定主题。

--will-qos

指定Will的服务质量,默认是0.必须和选项 --will-topic同时使用.

--will-retain

如果指定该选项,则万一客户端意外断开,已被发送的消息将被当做retained消息。必须和选项 --will-topic同时使用.

--will-topic

指定客户端意外断开时,Will消息发送到的主题。

 

 

 

sub_client客户端订阅一个或多个主题的消息:

用法:

mosquitto_sub [-c] [-d] [-h hostname] [-i client_id] [-I client id prefix] [-k keepalive time] [-p port number] [-q message QoS] [--quiet] [-v] [ -u username [-Ppassword] ] [ --will-topic topic [--will-payload payload] [--will-qos qos] [--will-retain] ] -t message topic ...  

命令:

mosquitto_sub 订阅到主题,接收到消息时打印

选项:

-c--disable-clean-session

禁止'clean session'选项,即如果客户端断开连接,这个订阅仍然保留来接收随后到的QoS为1和2的消息,当改客户端重新连接之后,它将接收到已排在队列中的消息。建议使用此选项时,客户端id选项设为--id

If using this option, it is recommended that the client id is set manually with --id

-d--debug

开启debug选项

-h--host

说明所连接到的域名,默认是localhost

-i--id

客户端的ID号,如果没有指定,默认是mosquitto_pub_加上客户端的进程id,不能和--id_prefix同时使用。

-I--id-prefix

指定客户端ID的前缀,与客户端的进程ID连接组成客户端的ID,不能喝--id同时使用。

-k--keepalive

给代理发送PING命令(目的在于告知代理该客户端连接保持且在正常工作)的间隔时间,默认是60s

-p--port

说明客户端连接到的端口,默认是1883

-P--pw

指定密码用于代理认证,使用此选项时必须有有效的用户名。 

-q--qos

指定消息的服务质量,可以为0,1,2,默认是0.

--quiet

如果指定该选项,则不会有任何错误被打印,当然,这排除了无效的用户输入所引起的错误消息。

-t--topic

指定订阅的消息主题,允许同时订阅到多个主题

-u--username

指定用户名用于代理认证。

-v--verbose

冗长地打印收到的消息。若指定该选项,打印消息时前面会打印主题名——“主题 消息内容”,否则,只打印消息内容

--will-payload

如果指定该选项,则万一客户端意外和代理服务器断开,则该消息将被保留在服务端并发送出去,该选项必须同时用--will-topic指定主题。

--will-qos

指定Will的服务质量,默认是0.必须和选项 --will-topic同时使用.

--will-retain

如果指定该选项,则万一客户端意外断开,已被发送的消息将被当做retained消息。必须和选项 --will-topic同时使用.

--will-topic

指定客户端意外断开时,Will消息发送到的主题。

 

 

报文种类

 

1.连接请求(CONNECT)

 当一个从客户端到服务器的TCP/IP套接字连接被建立时,必须用一个连接流来创建一个协议级别的会话。

 

2.连接请求确认(CONNECTACK)

 连接请求确认报文(CONNECTACK)是服务器发给客户端,用以确认客户端的连接请求

 

3.发布报文(PUBLISH)

客户端发布报文到服务器端,用来提供给有着不同需求的订阅者们。每个发布的报文都有一个主题,这是一个分层的命名空间,他定义了报文来源分类,方便订阅者订阅他们需要的主题。订阅者们可以注册自己的需要的报文类别。

 

 

4.发布确认报文(PUBACK)

发布确认报文(PUBACK)是对服务质量级别为1的发布报文的应答。他可以是服务器对发布报文的客户端的报文确认,也可以是报文订阅者对发布报文的服务器的应答。

 

5.发布确认报文(PUBREC)

PUBREC报文是对服务质量级别为2的发布报文的应答。这是服务质量级别为2的协议流的第二个报文。PUBREC是由服务器端对发布报文的客户端的应答,或者是报文订阅者对发布报文的服务器的应答。

 

6.发布确认报文(PUBREL)

PUBREL是报文发布者对来自服务器的PUBREC报文的确认,或者是服务器对来自报文订阅者的PUBREC报文的确认。它是服务质量级别为2的协议流的第三个报文。

 

7.确定发布完成(PUBCOMP)

PUBCOMP报文是服务器对报文发布者的PUBREL报文的应答,或者是报文订阅者对服务器的PUBREL报文的应答。它是服务质量级别为2的协议流的第四个也是最后一个报文。

 

8.订阅命名的主题(SUBSCRIBE)

订阅报文(SUBSCRIBE)允许一个客户端在服务器上注册一个或多个感兴趣的主题名字。发布给这些主题的报文作为发布报文从服务器端交付给客户端。订阅报文也描述了订阅者想要收到的发布报文的服务质量等级。

 

9. 订阅报文确认(SUBACK)

当服务器收到客户端发来的订阅报文时,将发送订阅报文的确认报文给客户端。一个这样的确认报文包含一列被授予的服务质量等级。被授予的服务质量等级次序和对应的订阅报文中的主题名称的次序相符。

 

10. 退订命名的主题(UNSUBSCRIBE)

退订主题的报文是从客户端发往服务器端,用以退订命名的主题。

 

11. 退订确认(UNSUBACK)

退订确认报文是从服务器发往客户端,用以确认客户端发来的退订请求报文。

 

12. Ping请求(PINGREQ)

Ping请求报文是从连接的客户端发往服务器端,用来询问服务器端是否还存在。

 

13. Ping应答(PINGRESP)

Ping应答报文是从服务器端发往Ping请求的客户端,对客户端的Ping请求进行确认。

 

14. 断开通知(DISCONNECT)

断开通知报文是从客户端发往服务器端用来指明将要关闭它的TCP/IP连接,他允许彻底地断开,而非只是下线。如果客户端已经和干净会话标志集联系,那么所有先前关于客户端维护的信息将被丢弃。一个服务器在收到断开报文之后,不能依赖客户端关闭TCP/IP连接。

 

转自

http://www.cnblogs.com/aaronwxb/archive/2012/07/20/2601509.html

 

分享到:
评论

相关推荐

    MQTT学习资料,搜集整理

    发布者和订阅者并不直接通信,而是通过一个中心节点——服务器(也称为消息代理或Broker)进行中转。 - **主题(Topic)**:主题是消息传输的通道,类似于电子邮件的主题行,用于区分不同类型的事件或数据。订阅者...

    mqtt windows动态库

    描述中提到的问题是用户从官方网站下载了mosquitto,mosquitto是一个开源的MQTT代理服务器,但在尝试使用时遇到了0x00000007错误。这个错误通常与动态库版本不兼容有关。开发者已经对这些动态库进行了调整,并在Win7...

    mosquitto-1.4.9.tar.gz

    **Mosquitto** 是一个开源的 MQTT 代理服务器,符合 MQTT v3.1 和 v3.1.1 规范。它支持多种操作系统,包括 Linux、Windows、macOS 和各种嵌入式系统。Mosquitto 提供了客户端库和命令行工具,允许开发者轻松地集成 ...

    mosquitto1.4.14 & 2.0.14,MQTTBox0.2.1,通讯猫307&313

    总结来说,标题中提到的MQTT工具组合,为开发者和物联网从业者提供了一个完整的MQTT通信环境,从服务器端的mosquitto,到客户端的MQTTBox和通讯猫,涵盖了MQTT协议的核心功能,便于测试、调试和实际部署。...

    mosquitto-1.6.9-install-windows-x64.exe

    Mosquitto是一个开源(BSD许可证)的消息代理,实现MQTT(消息队列遥测传输)协议版本3.1。 MQTT(MQ Telemetry Transport),消息队列遥测传输协议,轻量级的发布/订阅协议,适用于一些条件比较苛刻的环境,进行低带宽...

    mosquitto-1.6.10 编译的windows库文件,支持vs2015、vs2017

    mosquitto是一个开源的MQTT(Message Queuing Telemetry Transport)代理,它是物联网(IoT)和设备通信的标准协议之一。MQTT是一个轻量级的发布/订阅消息传输协议,设计用于低带宽、高延迟或不可靠的网络环境。在本...

    安卓Android源码——基于MQTT的安卓消息推送php服务端源码+安卓端源码.rar

    5. **优质源码链接**: "点这里查看更多优质源码~.url"可能是一个链接,指向更多的开源项目或者学习资源,供开发者参考和学习,以提升他们的Android和MQTT应用开发技能。 总的来说,这个压缩包为开发者提供了一个...

    mosquitto-2.0.14-install-windows-x64

    【mosquitto-2.0.14-install-windows-x64】是一个专为Windows 64位系统设计的安装包,用于部署和运行MQTT(Message Queuing Telemetry Transport)服务器——mosquitto。MQTT是一种轻量级的发布/订阅消息协议,广泛...

    RTT_ESP8266_TCP&MQTT.zip

    在RTT系统中,可以使用开源的MQTT库,如Paho MQTT或mosquitto,与AT Client结合,实现物联网设备的数据交换。 5. 实现过程: 首先,配置RTOS环境,集成ESP8266的驱动和AT Client库。然后,创建AT指令线程,初始化...

    mqttv3-1.2.5.zip

    - Mosquitto:一个开源的MQTT服务器,可以在各种操作系统上运行。 - HiveMQ:一个高性能的企业级MQTT代理,提供丰富的管理和监控工具。 - Applozic:提供包括MQTT在内的实时通讯SDK,适用于聊天、推送通知等功能...

    Downloads.zip

    Mosquitto是一个轻量级的MQTT(Message Queuing Telemetry Transport)消息代理,遵循MQTT 3.1.1和3.1标准。MQTT是一种广泛应用于物联网(IoT)的发布/订阅型消息协议,因其低带宽、低延迟和高可靠性而备受青睐。...

    emqttd-windows7-v2.3.0.zip

    本文将详细介绍如何在Windows 7操作系统上搭建MQTT服务器,具体以开源MQTT服务器软件emqttd v2.3.0为例。 首先,我们需要下载emqttd的Windows版本。这里提供的是"emqttd-windows7-v2.3.0.zip"压缩包,包含了emqttd...

    C#项目开发全程实录

    6. **消息队列MQTT**:为了确保消息的可靠传递,可能会使用消息队列技术,如使用开源的Mosquitto或Azure IoT Hub。 7. **事件驱动编程**:事件和委托机制是C#中实现响应用户操作和系统事件的重要手段,企业QQ源码中...

    Messaging-System:此项目用于培训以及系统发送和接收消息

    2. AMQP库:如RabbitMQ,它是一个开源的消息代理,支持AMQP协议,可以通过C#客户端库进行操作。 3. MQTT库:如Mosquitto,这是一个轻量级的发布/订阅消息协议,适用于物联网环境,C#也有对应的库可供使用。 4. ...

Global site tag (gtag.js) - Google Analytics