celery-mqtt-assistantMQTT 助手

Mqtt助手 - 是一個基于spring-integration-mqtt包自研實現(xiàn)的Spring Boot Stater。通過簡單注解配置即可進行MQTT協(xié)議通信。在物聯(lián)網(wǎng)環(huán)境中可以非常方便的結(jié)合完成與設備的通信。

主要特性

• 基于成熟mqtt包擴展，沒有任何框架變動，只為簡化開發(fā)使用
• 配置簡單靈活，無需復雜的配置文件：開發(fā)者可以快速注解類或者方法實現(xiàn)通信消息接收
• 發(fā)送封裝：開發(fā)者可以注入工具類實現(xiàn)消息發(fā)送

使用指引

引入依賴

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"})，實現(xiàn) MqttSubscribeCallback 接口，重寫 messageArrived 方法 2. 方法添加注解 @MqttSubscriber(topic = "celery")，topic為訂閱主題

注意：兩種方式任意一種都可以，若兩種方式都配置，則第一種優(yōu)先

@Component
@MqttClient(topics = {"celery"})
public class MqttComponent implements MqttSubscribeCallback {
    /**
     * 重寫 messageArrived 方法
     * @param topic 訂閱主題
     * @param payload 數(shù)據(jù)載荷
     */
    @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 數(shù)據(jù)載荷
     */
    @MqttSubscriber(topic = {"celery"})
    public void receive(String topic, byte[] payload) {
        System.out.println("receive: topic[" + topic + "] => " + Arrays.toString(bytes));
    }
}

消息發(fā)送：依賴注入 MqHelper，調(diào)用 send(String topic, byte[] payload) 方法

@AllArgsConstructor
@Component
public class MqttComponent {
    private MqttHelper mqttHelper;

    /**
     * 消息發(fā)送
     * @param topic 發(fā)送主題
     * @param payload 數(shù)據(jù)載荷
     */
    public void test(String topic, byte[] payload) {
        boolean sendFlag = mqttHelper.send("celery-send", payload);
        System.out.println("send: " + sendFlag);
    }
}