本发明涉及数据传输,具体涉及用于mqtt通信中断的数据续传方法及系统。
背景技术:
1、随着物联网技术的迅速发展,设备之间的数据交互变得日益频繁和重要。在众多通信协议中,mqtt协议因其轻量级、低带宽需求和高效的发布及订阅模式而被广泛应用,然而,在实际的数据传输过程中,由于网络环境的复杂性和不确定性,通信中断的情况时有发生。
2、现有技术存在着当mqtt通信中断时,导致部分采集数据的丢失,影响数据的完整性和准确性的技术问题。
技术实现思路
1、本申请提供了用于mqtt通信中断的数据续传方法及系统,用于针对解决现有技术中当mqtt通信中断时,导致部分采集数据的丢失,影响数据的完整性和准确性的技术问题。
2、鉴于上述问题,本申请提供了用于mqtt通信中断的数据续传方法及系统。
3、本申请的第一个方面,提供了用于mqtt通信中断的数据续传方法,所述方法包括:
4、连接数据源获取采集数据;通过mqtt协议,将所述采集数据发送至目标服务器;连接监测设备,获取实时监测的mqtt连接状态;判断所述mqtt连接状态是否为断开连接,当满足断开连接状态时,激活本地缓存模块,所述本地缓存模块用于将接收到的最新采集数据保持至本地数据库中;持续获取监测设备输出的mqtt连接状态,当所述mqtt连接状态满足连接状态时,从所述本地数据库中读取存储数据,并通过所述mqtt协议将读取的存储数据进行续传。
5、本申请的第二个方面,提供了用于mqtt通信中断的数据续传系统,所述系统包括:
6、采集数据获取模块,所述采集数据获取模块用于连接数据源获取采集数据;采集数据发送模块,所述采集数据发送模块用于通过mqtt协议,将所述采集数据发送至目标服务器;监测设备连接模块,所述监测设备连接模块用于连接监测设备,获取实时监测的mqtt连接状态;连接状态判断模块,所述连接状态判断模块用于判断所述mqtt连接状态是否为断开连接,当满足断开连接状态时,激活本地缓存模块,所述本地缓存模块用于将接收到的最新采集数据保持至本地数据库中;存储数据续传模块,所述存储数据续传模块用于持续获取监测设备输出的mqtt连接状态,当所述mqtt连接状态满足连接状态时,从所述本地数据库中读取存储数据,并通过所述mqtt协议将读取的存储数据进行续传。
7、本申请中提供的一个或多个技术方案,至少具有如下技术效果或优点:
8、连接数据源获取采集数据;通过mqtt协议,将所述采集数据发送至目标服务器;连接监测设备,获取实时监测的mqtt连接状态;判断所述mqtt连接状态是否为断开连接,当满足断开连接状态时,激活本地缓存模块,持续获取监测设备输出的mqtt连接状态,当mqtt连接状态满足时,从本地数据库中读取存储数据,并通过mqtt协议将读取的存储数据进行续传。达到了通过本地缓存模块将最新采集数据保存至本地数据库,保证了数据的完整性和连续性的技术效果。
1.用于mqtt通信中断的数据续传方法,其特征在于,所述用于mqtt通信中断的数据续传方法包括:
2.如权利要求1所述的用于mqtt通信中断的数据续传方法,其特征在于,所述连接数据源获取采集数据,包括:
3.如权利要求2所述的用于mqtt通信中断的数据续传方法,其特征在于,所述数据源至少包括传感器。
4.如权利要求1所述的用于mqtt通信中断的数据续传方法,其特征在于,所述激活本地缓存模块,包括:
5.如权利要求4所述的用于mqtt通信中断的数据续传方法,其特征在于,所述持续获取监测设备输出的mqtt连接状态之后,还包括:
6.如权利要求5所述的用于mqtt通信中断的数据续传方法,其特征在于,通过所述mqtt协议将读取的存储数据进行续传,包括:
7.如权利要求5所述的用于mqtt通信中断的数据续传方法,其特征在于,激活所述本地缓存模块接收所述采集数据执行本地数据库缓存,包括:
8.用于mqtt通信中断的数据续传系统,其特征在于,所述用于mqtt通信中断的数据续传系统包括: