tofly-parent/common-mqtt

1.该包用于快速接入mqtt写协议

接入步骤 1.引入
com.tofly common-mqtt 1.0.0 2.实现 MqttMessageResolve 接口, 通过@Component 交由容器管理。 定义单独数据处理的topic，qos默认为1

QoS 0：最多一次传递。消息发布者发送消息后，不会收到任何确认或保证消息的可靠传递。这种级别的QoS是最低的，但是传递速度最快，适用于不重要的消息或者不需要确保每条消息都被接收的场景。

QoS 1：至少一次传递。消息发布者发送消息后，会收到一个确认消息，以保证消息至少被接收一次。如果发布者没有收到确认消息，它会重新发送消息，直到收到确认。这种级别的QoS提供了可靠的传递保证，但是会增加网络开销和延迟。

QoS 2：恰好一次传递。消息发布者发送消息后，会收到一个确认消息，并且接收者会收到一个保证消息只被接收一次的确认。这种级别的QoS提供了最高的可靠性保证，但是会增加更多的网络开销和延迟。

1. getTopic 方法中 返回该处理类要监听的 topic

2. 在dataResolve 方法中 进行具体的数据处理，如数据入库等

5 待续 暂时只整合了消费端的功能