# 如何二次封装MQTT开源组件moquette ## 一、前言 MQTT作为物联网领域最主流的轻量级通信协议，其开源实现moquette以其轻量级和高性能著称。但在实际企业级应用中，直接使用原生
首先解释一下mqtt协议的session的概念，因为只有有了session才会存在消息质量保证一说 如果清理会话（CleanSession）标志被设置为0，服务端必须基于当前会话（使用客户端标识符识别
一. 前言在下载，编译，运行moquette源代码之后，肯定想加入自己的逻辑。但是又不想过多的修改源代码，为了以后的升级。所以最好另外做个插件，单独的jar包moquette源代码编译：http://
本文讲解moquette对UNSUBSCRIBE和DISCONNECT的处理 先说UNSUBSCRIBE，代码比较简单 public void processUnsubscribe(Chann
一. 简介moquette是一个Java版本的mqtt协议broker实现github源代码： https://github.com/andsel/moquettegoogle moquet
先上一个图，大概说明一下moquette 的类之间的关系 一.ProtocolProcessor类该类是moquette里面的最终要的类，负责所有报文的处理，持有所有各模块功能的实现对象的引用，
这一篇开始讲解moqutte对SUBSCRIBE报文的处理 代码不复杂public void processSubscribe(Channel channel, MqttSubscribeMessag
moquette的集群功能是通过Hazelcast来实现的，对Hazelcast不了解的同学可以自行Google以下。在讲解moquette的集群功能之前需要讲解一下moquette的拦截器，因为mo