对比一些MQTT的代理（broker）

broker的主要职责是接受发布者发布的所有消息，并将其过滤后分发给不同的消息订阅者。
如今有很多的broker，下面就是一张关于各种broker对比的：

目前我用过的有mosquitto和emqttd（20版本后改叫EMQ），因为目前的需求是希望做每秒10万以上的数据接入，所以需要考虑建立集群。但是在使用mosquitto的过程中发现他不支持集群，所以就放弃了，转投emqttd。
在使用mosquitto过程中发现了一些问题：
在使用mosquitto时，如果想使用集群的话，可能会需要进行二次开发。目前只支持桥接。并且他在遍历时的效率非常低，使得他无法支持大量的客户端或者 *** 作过于频繁的 *** 作（比如十万或百万级别的客户端同时发送数据）
emqttd有以下优点：

EMQ 20 (Erlang/Enterprise/Elastic MQTT Broker) 是基于 Erlang/OTP 语言平台开发，支持大规模连接和分布式集群，发布订阅模式的开源 MQTT 消息服务器。(抄自 EMQ官方文档 )

mqtt与服务器建立连接。会使用到一个clientid（客户端id）。如果生产者和消费者使用的是同一个clientid的话，那么恭喜你该成不一样的就好了

原因是生产者和消费者是单独连接服务器的，也就是说与服务区有两个连接一个是生产者的连接一个是消费者的连接

最近在着手研究使用网页控制硬件的交互过程，发现mqtt协议有很多种语言的封装，整个思路也很清晰，就是一个客户端进行发布和订阅+服务器中间代理的过程，于是开始学习使用MQTT框架搭建交互平台。
客户端使用了MQTTjs，服务器使用mosca（基于nodejs）。

QoS在MQTT中有（摘自 MQ 遥测传输 (MQTT) V31 协议规范 ）：

MQTTjs只是支持了MQTT协议，并没有支持QoS，也就是说，只支持最低级别的“至多一次”（QoS0）。

在MQTT协议中，一个MQTT数据包由：固定头（Fixed header）、可变头（Variable header）、消息体（payload）三部分构成。
这里只了解消息体，固定头和可变头并不需要我们手动写。
payload消息体包含CONNECT、SUBSCRIBE、SUBACK、UNSUBSCRIBE四种类型的消息：

（1）Connect    与服务器建立连接。
（2）Disconnect    与服务器断开TCP/IP会话。
（3）Subscribe    订阅。
（4）UnSubscribe    取消订阅。
（5）Publish    发送消息请求，发送完成后返回应用程序线程。
二、实现（具体的API稍后呈现）

      用户在使用CAT1模组MQTT协议对接自己的服务器，有时会遇到设备无法连接服务器问题(比如提示+ECMTCON:0,0,5连接服务器被拒绝，认证失败)。此时可以通过 标准的MQTT服务器 进行对比，因为用户自己的服务器一般加入校验信息，导致模组&MQTT服务器无法连接。

       Eclipse Mosquitto是一个开源消息代理，实现了MQTT协议版本31和311，这里使用该服务器进行测试。针对该服务器更详细的介绍也可以参考 >第一，pom配置，我们需要引入相关jar：

第二，配置MQTT服务器基本信息，在springBoot配置文件applicationproperties中配置，添加如下：

第三，配置MQTT消息推送配置类，

第四，配置MqttGateway消息推送接口类，在sendToMqtt(String data,@Header(MqttHeadersTOPIC)String topic)接口中，data为发送的消息内容，topic为主题。指定topic，则我们的接口可以根据需要，向不同的主题发送消息，方便灵活应用。如果不指定，则使用默认配置的主题。

第五，接口类测试下功能，用Postman调用sendMqttdo接口，往hello主题发送消息，用MQTTLens订阅hello主题，从下面截图，可以看出可以正常往MQTT服务发送消息了，而且可以订阅到。

---