MQTT接受订阅消息并写入数据库

在springboot框架中成功引入MQTT后，能够持续受到消息，则证明MQTT成功运行：

那么接下来的问题就是如何把接受订阅的消息之后，将数据写入数据库。以方便后期对于数据的呈现和编写接口。

1、新建一个Service用来处理消息

接收到的消息是json格式的，解析这个格式的数据我用的是alibaba的fastjson。当messageType为deviceDatapoint是数据点消息，deviceLifeCycle是设备生命周期事件。将订阅的消息首先转成数据库的String类型：

然后我们在MQTT的消息监听MessageCallbackListener类里面去调用这个方法：

测试得出数据能够正常显示，那么我们就可以按照正常的Dao层Server层去写方法，将拿到的数据存到数据库中：

Dao层

写好SQL语句和sever层后，就可以正常调用方法了。