Node.js与MQTT协议的应用.ppt

JavaScript的事件驱动 JavaScript的事件驱动 JavaScript的事件驱动 “跨平台”的异步编程 浏览器与Web服务器：socket.io 服务器与服务器/其他设备：MQTT websocket socket.io介绍 支持命名空间namespace 多种连接方式自动切换： xhr-polling xhr-multipart htmlfile websocket flashsocket jsonp-polling 自定义事件名称 socket.io的事件驱动 socket.io的自定义事件 客户端触发服务器端事件： position 更新位置 address 更新区域 say 发送聊天信息 服务器端触发客户端事件： say 有人说话 position 更新人物位置 come 人物进入 out 任务离开 ad 广告 MQTT协议的特点 使用发布/订阅消息模式，提供一对多的消息发布，解除应用程序耦合。 对负载内容屏蔽的消息传输。 使用 TCP/IP 提供网络连接。 有三种消息发布服务质量。 小型传输，开销很小（固定长度的头部是 2 字节），协议交换最小化，以降低网络流量。 使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制。 三种消息发布服务质量 “至多一次”，消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况，环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。 “至少一次”，确保消息到达，但消息重复可能会发生。 “只有一次”，确保消息到达一次。这一级别可用于如下情况，在计费系统中，消息重复或丢失会导致不正确的结果。 主题通配符 匹配一个层级：+ a/b/c/d +/b/c/d a/+/c/d a/+/+/d +/+/+/+ 匹配后面所有层级：# # a/# a/b/# a/b/c/# +/b/c/# 工作原理 聊天室原理 聊天室原理 MQTT消息主题 订阅：/省/市/区/# 聊天信息：/省/市/区/chat 广告信息：/省/市/区/ad 人物位置：/省/市/区/pos 人物出现：/省/市/区/come 人物离开：/省/市/区/out * socket.io与MQTT协议的应用 雷宗民 客户端：发送消息 客户端：接收消息 服务器端 MQTT协议概述 MQTT（Message Queuing Telemetry Transport） 消息队列遥测传输 是轻量级基于代理的发布/订阅的消息传输协议， 设计思想是开放、简单、轻量、易于实现。这些 特点使它适用于受限环境： 网络代价昂贵，带宽低、不可靠。 在嵌入设备中运行，处理器和内存资源有限。 MQTT消息代理 订阅消息 发布消息 MQTT代理 socket.io 浏览器 聊天信息 广播信息 人物位置信息 发布到相应的主题 接收所订阅的主题的消息 触发响应的事件 MQTT代理 socket.io 浏览器 其他客户端 转发给订阅了该主题的客户端 发布到相应的主题 触发响应的事件 *