springboot整合RabbitMQ Mqtt

springboot整合RabbitMQ Mqtt,第1张

第一,pom配置,我们需要引入相关jar:

第二,配置MQTT服务器基本信息,在springBoot配置文件applicationproperties中配置,添加如下:

第三,配置MQTT消息推送配置类,

第四,配置MqttGateway消息推送接口类,在sendToMqtt(String data,@Header(MqttHeadersTOPIC)String topic)接口中,data为发送的消息内容,topic为主题。指定topic,则我们的接口可以根据需要,向不同的主题发送消息,方便灵活应用。如果不指定,则使用默认配置的主题。

第五,接口类测试下功能,用Postman调用sendMqttdo接口,往hello主题发送消息,用MQTTLens订阅hello主题,从下面截图,可以看出可以正常往MQTT服务发送消息了,而且可以订阅到。


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zz/10784555.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-11
下一篇 2023-05-11

发表评论

登录后才能评论

评论列表(0条)

保存