一、业务场景

        提示：对于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注解
  • 
•    在回调函数中注入对应的Service即可，此Service跟普通的Service接口一样
  • 

三、结尾

源码传送门

有不懂的地方随时留言。（15670600690）