Message Queuing Telemetry Transport ,中文 : 消息队列遥测传输

是基于MQTT协议的服务端实现,即mqtt服务器
3. mqtt client是基于MQTT协议的客户端实现。
二、 mqtt服务器-EMQ安装官网下载 https://www.emqx.io/cn/downloads#broker

下载完成后(不要下载企业版的),解压压缩包,打开 Windows 命令行窗口,cd 到程序bin目录(路径不能包含中文或者空格,不然可能会出错), 启动 EMQ Xmqtt客户端订阅queue:
G:emqx-windows-v3.2.3emqxbin>emqx startG:emqx-windows-v3.2.3emqx>cd binG:emqx-windows-v3.2.3emqxbin>emqx_ctl statusNode 'emqx@127.0.0.1' is startedemqx 3.2.3 is runningG:emqx-windows-v3.2.3emqxbin>
浏览器访问mqtt客户端订阅queue: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. 简单使用
另外,也可以用使用EMQ中Websocket工具,发布一条主题为test的信息。

发送后Paho客户端便会接收到发送的信息

关于遗愿的作用: 当连接MQTT服务器时设置了遗愿的客户端异常退出,心跳超时后MQTT服务器会将该客户的遗愿消息发布出去,订阅了该遗愿消息的客户端会收到通知。总的来说,就是设置(app、设备)等客户异常退出(比如,断网) 通知应用服务器的作用 (这个通知会有延迟,延迟时间和心跳有关)。
实际项目场景: 应用app服务器 监听了 主题/logout 的消息, 客户端app 连接MQTT服务器时 设置了遗愿 主题:/logout , 消息内容 {当前app用户的id} , 当用户app网络断开,过了一段时间后,MQTT服务器发现这个连接的APP客户端心跳停止很久了(和超时时间有关) ,认为app客户端已经异常退出了,然后将其连接时设置的遗愿消息发布出来主题:/logout。服务器由于已经订阅了主题/logout的消息,所以能收到这条消息,消息内容中是app用户的id,然后服务器就可以做一些下线处理了。


标签: mqtt客户端订阅queue