celery-mqtt-assistantMQTT 助手

Mqtt助手 - 是一个基于spring-integration-mqtt包自研实现的Spring Boot Stater。通过简单注解配置即可进行MQTT协议通信。在物联网环境中可以非常方便的结合完成与设备的通信。

主要特性

• 基于成熟mqtt包扩展，没有任何框架变动，只为简化开发使用


• 配置简单灵活，无需复杂的配置文件：开发者可以快速注解类或者方法实现通信消息接收


• 发送封装：开发者可以注入工具类实现消息发送

使用指引

引入依赖

implementation("cool.doudou:mqtt-assistant:latest")

配置文件

mqtt:

  server-uri: tcp://127.0.0.1:1883

  username: admin

  password: 1234.abcd

  client-id: test

  topics:

    - "celery"

使用方式

消息订阅：1. 类添加注解 @MqttClient(topics = {"celery"})，实现 MqttSubscribeCallback 接口，重写 messageArrived 方法 2. 方法添加注解 @MqttSubscriber(topic = "celery")，topic为订阅主题

注意：两种方式任意一种都可以，若两种方式都配置，则第一种优先

@Component

@MqttClient(topics = {"celery"})

public class MqttComponent implements MqttSubscribeCallback {

    /**

     * 重写 messageArrived 方法

     * @param topic 订阅主题

     * @param payload 数据载荷

     */

    @Override

    public void messageArrived(String topic, byte[] payload) {

        System.out.println("messageArrived: topic[" + topic + "] => " + Arrays.toString(bytes));

    }

}



@Component

public class MqttComponent {

    /**

     * 自定义方法

     * @param topic 订阅主题

     * @param payload 数据载荷

     */

    @MqttSubscriber(topic = {"celery"})

    public void receive(String topic, byte[] payload) {

        System.out.println("receive: topic[" + topic + "] => " + Arrays.toString(bytes));

    }

}

消息发送：依赖注入 MqHelper，调用 send(String topic, byte[] payload) 方法

@AllArgsConstructor

@Component

public class MqttComponent {

    private MqttHelper mqttHelper;



    /**

     * 消息发送

     * @param topic 发送主题

     * @param payload 数据载荷

     */

    public void test(String topic, byte[] payload) {

        boolean sendFlag = mqttHelper.send("celery-send", payload);

        System.out.println("send: " + sendFlag);

    }

}