MQTT将订阅到的消息存储数据库 |
您所在的位置:网站首页 › mqtt传文件 › MQTT将订阅到的消息存储数据库 |
一、业务场景
提示:对于Broker(MQTT服务器)来说,不论我们是发布方,还是订阅方,都是属于客户端 硬件方面将采集的数据上报至MQTT服务器,我们平台(自己的WEB服务)将订阅到的消息存储数据库,如何用JAVA作为客户端订阅消息在我的上一篇文章中有讲解如何使用JAVA编写MQTT客户端连接MQTT服务器。 好多朋友在看官网的时候对于这一点理解有点偏差,官网上面说开源版本不支持消息存储数据库,主要表达的意思是MQTT服务端不会自动将收到的消息存储数据库(当企业版的是可以配置后,MQTT服务端自动将收到的消息存储数据库),但是我们可以自己编写代码去实现这个功能,并不麻烦的。 二、解决方案基于以上问题,针对开源版本,有两种方式将订阅到的消息存储数据库,如下: 方式一、我们可以自己编写插件,采用EMQX支持自定义插件扩展,但是个人不建议采用自定义插件,因为erlang语言不熟悉,出问题无法及时解决。 方式二、下面主要讲解如何在回调函数中调用我们的service服务,将订阅到的数据存储数据库 1、首先,采用Springboot搭建项目框架,编写MQTT客户端,在我的上一章节中有详细代码介绍JAVA编写MQTT客户端连接MQTT服务端。 2、如何在回调函数中调用我们的service服务存储数据,可能好多朋友直接在回调函数中使用注解形式@Autowired,就像我们在controller中那样直接调用service服务,但是实际用的时候发现注解注入的service服务是空的,给你报java.lang.NullException,然后MQTT就断开连接了。 其实采用注解形式是可以获取到service服务的,那是因为我们的编码不当造成的。以下是采用注解方式解决的办法: 在监听器中(MQTTListener)将回调函数注入,回调函数本身添加@Component注解![]() ![]() 源码传送门 有不懂的地方随时留言。(15670600690) |
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |