Mqtt助手-是一个基于spring-integration-mqtt包自研实现的SpringBootStater。通过简单注解配置即可进行MQTT协议通信。在物联网环境中可以非常方便的结合完成与设备的通信。
主要特性基于成熟mqtt包扩展，没有任何框架变动，只为简化开发使用配置简单灵活，无需复杂的配置文件：开发者可以快速注解类或者方法实现通信消息接收发送封装：开发者可以注入工具类实现消息发送使用指引引入依赖implementation("cool.doudou:mqtt-assistant:latest")配置文件mqtt:server-uri:tcp://127.0.0.1:1883username:adminpassword:1234.abcdclient-id:testtopics:-"celery"使用方式消息订阅：1.类添加注解@MqttClient(topics={"celery"})，实现MqttSubscribeCallback接口，重写messageArrived方法2.方法添加注解@MqttSubscriber(topic="celery")，topic为订阅主题
注意：两种方式任意一种都可以，若两种方式都配置，则第一种优先
@Component@MqttClient(topics={"celery"})publicclassMqttComponentimplementsMqttSubscribeCallback{/***重写messageArrived方法*@paramtopic订阅主题*@parampayload数据载荷*/@OverridepublicvoidmessageArrived(Stringtopic,byte[]payload){System.out.println("messageArrived:topic["+topic+"]=>"+Arrays.toString(bytes));}}@ComponentpublicclassMqttComponent{/***自定义方法*@paramtopic订阅主题*@parampayload数据载荷*/@MqttSubscriber(topic={"celery"})publicvoidreceive(Stringtopic,byte[]payload){System.out.println("receive:topic["+topic+"]=>"+Arrays.toString(bytes));}}消息发送：依赖注入MqHelper，调用send(Stringtopic,byte[]payload)方法
@AllArgsConstructor@ComponentpublicclassMqttComponent{privateMqttHelpermqttHelper;/***消息发送*@paramtopic发送主题*@parampayload数据载荷*/publicvoidtest(Stringtopic,byte[]payload){booleansendFlag=mqttHelper.send("celery-send",payload);System.out.println("send:"+sendFlag);}}
评论