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