spring-mqtt

基于Springboot封装了paho-mqtt原生客户端。

• 封装了mqtt连接和客户端自动创建并注入容器的过程
• 封装了MqttCallback的实现，使用者可以使用@MqttConsumerHandler和@MqttSubscribe注解实现消息接收
• 封装了与EMQX客户端的API服务

接入方式

注意事项

• 接入前提需要引入Springboot-starter

接入步骤

1. 导入spring-mqtt-starter包

<dependency>
    <groupId>com.leyunone</groupId>
    <artifactId>spring-mqtt</artifactId>
    <version>1.0.0-RELEASE</version>
</dependency>

2. 如果你需要订阅消息，创建你的消费者，并加载到Spirngioc中，使用MqttConsumerHandler来标识消费者实例， 使用@MqttSubscribe注解来标识消息处理方法，并提供topic和message两个参数

@Component
@MqttConsumerHandler
public class MqttConsumer {

    final static Logger logger = LoggerFactory.getLogger(MqttConsumer.class);

    @MqttSubscribe
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        logger.debug("message arrived. topic:{},message:{}.",topic,message.toString());
    }


}

3. yaml配置：

spring:
  mqtt:
    url: 连接地址
    clientId: 客户端Id
    topics:
      - topic: topic
        qos: qos
      - topic: topic
        qos: qos
    username: 用户名称
    password: 密码
    group: 分组
    ssl:  ssl ca证书地址