首先解释一下mqtt协议的session的概念，因为只有有了session才会存在消息质量保证一说如果清理会话（CleanSession）标志被设置为0，服务端必须基于当前会话（使用客户端标识符识别）的状态恢复与客户端的通信。如果没有与这个客户端标识符关联的会话，服务端必须创建一个新的会话。在连接断开之后，当连接断开后，客户端和服务端必须保存会话信息[MQTT-3.1.2-4]。当清理会话标志为0
分类：
其他好文 时间：
2018-04-05 11:39:52
阅读次数：
772
mqtt协议-broker之moqutte源码研究六之集群，moquette集群讲解
分类：
其他好文 时间：
2018-03-02 23:13:08
阅读次数：
471
mqtt协议-broker之moqutte源码研究五之UNSUBSCRIBE与DISCONN报文处理
分类：
其他好文 时间：
2018-03-02 12:26:34
阅读次数：
155
mqtt协议-broker之moqutte源码研究三之PUBLISH报文处理
分类：
其他好文 时间：
2018-03-01 17:27:27
阅读次数：
288
mqtt协议-broker之moqutte源码研究二之SUBSCRIBE报文处理
分类：
其他好文 时间：
2018-02-28 16:26:59
阅读次数：
189
mqtt协议-broker之moqutte源码研究二之Connect报文处理
分类：
其他好文 时间：
2018-02-27 19:26:15
阅读次数：
303
MQTT moquette 的Server发布主题Java代码packagecom.etrip.mqtt.future;importjava.net.URISyntaxException;importorg.fusesource.mqtt.client.FutureConnection;import...
在moquette-mqtt中提供了回调callback模式的发布和订阅但是在订阅之后没有发现有消息接收的方法，参看moquette-mqtt中Block，Future式的发布订阅基础是callback式订阅发布，但是本人在研究源代码测试，发现callback方式接收没有成功。所以本文中只是call...
在上面两篇关于mqtt的broker的启动和mqtt的服务端发布主题信息之后，我们客户端需要订阅相关的信息并接收相关的主题信息。Java代码packagecom.etrip.mqtt;importjava.net.URISyntaxException;importorg.fusesource.mqt...
* 使用 Java 为 MQ Telemetry Transport 创建订户* 在此任务中，您将遵循教程来创建订户应用程序。订户将针对主题创建预订并接收该预订的发布。*提供了一个示例订户应用程序 Subscribe。Subscribe 将创建预订主题 MQTT Examples，并等待获*得该预订...
