一、 即时通讯协议-mqtt
Message Queuing Telemetry Transport ,中文 : 消息队列遥测传输
1. 主要特点
- 使用发布/订阅消息模式，提供一对多的消息发布，解除应用程序耦合
- 对负载内容屏蔽的消息传输
- 使用 TCP/IP 提供网络连接
- 有三种消息发布服务质量: “至多一次”:适用消息频繁发且丢失一两条不影响的场景,如:环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。 “至少一次”:确保消息到达，但消息重复可能会发生 “只有一次”:确保消息到达一次。优点是确保消息送达且有且仅有一次，缺点是系统开销大.
- 小型传输，开销很小
- 使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制
2. mqtt broker
是基于MQTT协议的服务端实现，即mqtt服务器
3. mqtt client
是基于MQTT协议的客户端实现。
二、 mqtt服务器-EMQ安装
官网下载 https://www.emqx.io/cn/downloads#broker
下载完成后（不要下载企业版的），解压压缩包，打开 Windows 命令行窗口，cd 到程序bin目录（路径不能包含中文或者空格，不然可能会出错）， 启动 EMQ X：
G:\emqx-windows-v3.2.3\emqx\bin>emqx start
G:\emqx-windows-v3.2.3\emqx>cd bin
G:\emqx-windows-v3.2.3\emqx\bin>emqx_ctl status
Node 'emqx@127.0.0.1' is started
emqx 3.2.3 is running
G:\emqx-windows-v3.2.3\emqx\bin>浏览器访问：http://127.0.0.1:18083/#/ ，进入控制台可视化页面，默认用户名/密码 admin/public
三、 使用Paho进行测试
1. 下载
mqtt 客户端图形调试工具 Eclipse Paho Java所有版本下载地址https://repo.eclipse.org/content/repositories/paho-releases/org/eclipse/paho/org.eclipse.paho.ui.app/1.0.2/
2. 简单使用
- 准确输入IP，点击连接
- “订阅”面板，新增一条主题并订阅；“发布”面板，填写需要发布的消息并发布
- 服务质量: 0 至多一次,1 至少一次 ,2 刚好一次 。具体根据项目需求决定，比如设备不停推送消息，偶尔漏一条不要紧的选择0，希望每条消息都能收到且不是那种一点差错都不能出的(如涉及到钱，重要信息) 那么选择1， 不能出一点差错的选择2。注： 2的开销最大，若不是必须不选择2。
另外，也可以用使用EMQ中Websocket工具，发布一条主题为test的信息。
发送后Paho客户端便会接收到发送的信息
3. 遗愿调试
关于遗愿的作用: 当连接MQTT服务器时设置了遗愿的客户端异常退出，心跳超时后MQTT服务器会将该客户的遗愿消息发布出去，订阅了该遗愿消息的客户端会收到通知。总的来说，就是设置(app、设备)等客户异常退出(比如，断网) 通知应用服务器的作用 (这个通知会有延迟，延迟时间和心跳有关)。
实际项目场景: 应用app服务器 监听了 主题/logout 的消息, 客户端app 连接MQTT服务器时 设置了遗愿 主题：/logout , 消息内容 {当前app用户的id} , 当用户app网络断开，过了一段时间后,MQTT服务器发现这个连接的APP客户端心跳停止很久了(和超时时间有关) ,认为app客户端已经异常退出了，然后将其连接时设置的遗愿消息发布出来主题：/logout。服务器由于已经订阅了主题/logout的消息，所以能收到这条消息，消息内容中是app用户的id，然后服务器就可以做一些下线处理了。
