Springboot MQTT messageArridve触发connectLost

Question

Springboot 在mqtt的回调函数messageArrived方法里引用Dao层对数据库操作 就会触发我的connect'Lost掉线，为什么?

Answer 1

这种情况可能是由于在messageArrived方法中的数据库操作导致了线程阻塞而触发了MQTT的连接丢失。MQTT客户端的connectLost方法会在客户端与服务器之间的连接丢失时调用，这通常是由于网络连接异常或服务器宕机等原因引起的。

为了避免这种情况，您可以在messageArrived方法中启用一个新线程来执行数据库操作，同时确保该线程及时释放数据库连接资源，以避免对连接池资源的浪费和线程的阻塞。另外，在MQTT连接中发生丢失时，您也可以通过重新连接的方式来重新建立连接并恢复数据传输。