celery-mqtt-assistant

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);
    }
}