本发明涉及一种数据包接收与存储方法。
背景技术:
Java是一门面向对象编程语言,不仅吸收了C++语言的各种优点,还摒弃了C++里难以理解的多继承、指针等概念,因此Java语言具有功能强大和简单易用两个特征。Java语言作为静态面向对象编程语言的代表,极好地实现了面向对象理论,允许程序员以优雅的思维方式进行复杂的编程。Java具有简单性、面向对象、分布式、健壮性、安全性、平台独立与可移植性、多线程、动态性等特点。Java可以编写桌面应用程序、Web应用程序、分布式系统和嵌入式系统应用程序等。
由于IPv6最大的问题在于网络地址资源有限,严重制约了互联网的应用和发展。IPv6的使用,不仅能解决网络地址资源数量的问题,而且也解决了多种接入设备连入互联网的障碍,IPv6协议主要定义了三种地址类型:单播地址(Unicast Address)、组播地址(Multicast Address)和任播地址(Anycast Address)。与原来在IPv4地址相比,新增了“任播地址”类型,取消了原来IPv4地址中的广播地址,因为在IPv6中的广播功能是通过组播来完成的。而IPV6下一代互联网主角,必将应用到生活中的方方面面,其与物联网的结合势在必行。IPV6无论是接入地址亦或是寻址等问题都能凭借其技术优势顺利解决,尤其在IPV6成为国家战略后,在国家全力支撑的背景下,将物联网与IPV6相结合必然是大势所趋,而且符合未来技术发展趋势。
随着物联网的大力发展,接入节点的要求都是低功耗,低传输速率的,这时TCP传输协议并不适用,而UDP传输协议便成了很好的替代品,UDP传输协议是一种不可靠的网络协议,在低功耗、低传输速率、低开销下UDP协议会变得非常有用。因为UDP具有TCP所望尘莫及的速度优势。虽然TCP协议中植入了各种安全保障功能,但是在实际执行的过程中会占用大量的系统开销,无疑使速度受到严重的影响。反观UDP由于排除了信息可靠传递机制,将安全和排序等功能移交给上层应用来完成,极大降低了执行时间,使速度得到了保证。
随着物联网行业的兴起,在数据传输方面更多的要求是低功耗、低传输速率、低开销下、低内存。传统的TCP传输协议并不适用于物联网底层感知数据的传输,而UDP传输协议的控制选项较少,在数据传输过程中延迟小、数据传输效率高,适合对可靠性要求不高的应用程序,它不属于连接型协议,因而具有资源消耗小,处理速度快的优点,所以通常音频、视频和普通数据在传送时使用UDP较多,因为它们即使偶尔丢失一两个数据包,也不会对接收结果产生太大影响,非常适合物联网感知数据的传送,因此服务器端UDP数据包的接收必不可少。
技术实现要素:
本发明提供一种基于Java的对于IPv6网络UDP数据包的接收解析与存储方法,用以接收UDP数据包并解析其中有用信息,将信息存储至数据库以便进行数据分析。技术方案如下:
一种对于IPv6网络UDP数据包的接收解析与存储方法,在接收UDP数据包的过程中,使用Java自有的DatagramSocket、InetAddress和Runnable类,步骤如下:创建一个包含main函数的Kernel类作为程序运行的开始,在该类中创建数据下载的Upload的线程并且启动该线程,此时数据接收开始;程序跳转到Upload中执行,该类继承Runnable类并对其中的run()方法进行重写,之后程序跳转到Receive类中,该类是接收UDP数据包的具体执行类;将解析后的数据通过InsertMySQL类中的addDataToTemHumTable()函数完成数据的存储。
本发明的有益效果如下:
1.本发明提出一种基于Java的对于IPv6网络UDP数据包的接收解析与存储,为开发人员提供了一种数据接收方式,有益于物联网的发展。
2.通过使用Java语言eclipse开发工具监听端口完成对UDP数据包的接收并解析后存储。由于Java语言使用的普遍性,方便开发人员的深入开发。
附图说明
图1系统运行流程图
具体实施方式
本发明在接收UDP数据包的过程中,使用了Java自有的DatagramSocket、InetAddress和Runnable类。具体流程是:首先创建一个包含main函数的Kernel类作为程序运行的开始,在该类中创建数据下载的Upload的线程并且启动该线程,此时数据接收开始。然后程序跳转到Upload中执行,该类继承Runnable类并对其中的run()方法进行重写,之后程序跳转到Receive类中,该类是接收UDP数据包的具体执行类。最后将解析后的数据通过InsertMySQL类中的addDataToTemHumTable()函数完成数据的存储。
具体实施方式
本发明在接收UDP数据包的过程中,使用了Java自有的DatagramSocket、InetAddress和Runnable类。具体流程是:首先创建一个包含main函数的Kernel类作为程序运行的开始,在该类中创建数据下载的Upload的线程并且启动该线程,此时数据接收开始。然后程序跳转到Upload中执行,该类继承Runnable类并对其中的run()方法进行重写,之后程序跳转到Receive类中,该类是接收UDP数据包的具体执行类。最后将解析后的数据通过InsertMySQL类中的addDataToTemHumTable()函数完成数据的存储。
1线程的创建
该类较为简单,只有一个main函数,作为整个项目的开始,函数中创建一个数据接收的线程并启动该线程,之后程序跳转到Upload类中运行。
2数据接收的启动
该类也较为简单,继承Java自带的Runnable父类并重写run()方法,此时启动数据接收模块,程序跳转到并使用try,catch结构,当数据接收启动失败是抛出异常。
3数据接收与解析
第一步通过DatagramSocket socket=new DatagramSocket(port,ip6address)创建接收套接字对象,并与所监听的端口号和本机ipv6地址保持一致。第二步通过DatagramPacket packet=new DatagramPacket(buf,buf.length)创建接收数据包存储在buf中,buf为数据接收的缓存数组。第三步通过SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")设置日期,将接收到数据的时间日期设为yyyy-MM-dd HH:mm:ss格式。第四步通过Split函数将数据包中的接收到的数据按照空格进行切割,并存储到变量date中,之后将切割后的每一部分分别存储到相应的变量中。第五步创建list数组,将每个变量添加到该list中,然后调用addDataToTemHumTable(list)函数将list中的数据添加到数据库中,此时程序跳转到InsertMySQL中执行。至此数据的接收与解析完成。
4解析后数据的存储
该类的主要功能是将数据向数据库中存储,主要包括3个函数,获取数据库的连接getConn()、关闭数据库连接closeAll()和向数据库中添加数据addDataToTemHumTable()。上一步中调用的就是addDataToTemHumTable()函数,在该函数中首先获取数据库连接,将上一步中传来的list列表通过sql语句"INSERT INTO TemHumSensor(receiveTime,Tem,Hum,sensorIP,sensorPort)VALUES(?,?,?,?,?)"写入到数据库中。至此完成从端口接收数据,经过解析后存储到数据库中以方便分析使用。
本发明适用于物联网系统中IPv6网络UDP数据包的接收。随着物联网行业的兴起,在数据传输方面更多的要求是低功耗、低传输速率、低开销下、低内存,UDP传输协议将普遍应用于物联网行业,因此对于UDP数据包的接收处理会大量使用,而本发明提出一种基于Java的对于IPv6网络UDP数据包的接收解析与存储,为开发人员提供了一种数据接收方式,有益于物联网的发展。