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