CN109302398A - 对于IPv6网络UDP数据包的接收解析与存储方法 - Google Patents
对于IPv6网络UDP数据包的接收解析与存储方法 Download PDFInfo
- Publication number
- CN109302398A CN109302398A CN201811193659.8A CN201811193659A CN109302398A CN 109302398 A CN109302398 A CN 109302398A CN 201811193659 A CN201811193659 A CN 201811193659A CN 109302398 A CN109302398 A CN 109302398A
- Authority
- CN
- China
- Prior art keywords
- class
- data
- message packet
- udp message
- parsing
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 18
- 230000006870 function Effects 0.000 description 16
- 230000005540 biological transmission Effects 0.000 description 13
- 230000008901 benefit Effects 0.000 description 4
- 230000009286 beneficial effect Effects 0.000 description 3
- 230000008569 process Effects 0.000 description 3
- 230000008447 perception Effects 0.000 description 2
- 230000009471 action Effects 0.000 description 1
- 238000004458 analytical method Methods 0.000 description 1
- 238000007405 data analysis Methods 0.000 description 1
- 238000010586 diagram Methods 0.000 description 1
- 230000007246 mechanism Effects 0.000 description 1
- 230000003068 static effect Effects 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/16—Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]
- H04L69/164—Adaptation or special uses of UDP protocol
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/16—Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]
- H04L69/161—Implementation details of TCP/IP or UDP/IP stack architecture; Specification of modified or new header fields
- H04L69/162—Implementation details of TCP/IP or UDP/IP stack architecture; Specification of modified or new header fields involving adaptations of sockets based mechanisms
Landscapes
- Engineering & Computer Science (AREA)
- Computer Security & Cryptography (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本发明涉及一种对于IPv6网络UDP数据包的接收解析与存储方法,在接收UDP数据包的过程中,使用Java自有的DatagramSocket、InetAddress和Runnable类,步骤如下:创建一个包含main函数的Kernel类作为程序运行的开始,在该类中创建数据下载的Upload的线程并且启动该线程,此时数据接收开始;程序跳转到Upload中执行,该类继承Runnable类并对其中的run()方法进行重写,之后程序跳转到Receive类中,该类是接收UDP数据包的具体执行类;将解析后的数据通过InsertMySQL类中的addDataToTemHumTable()函数完成数据的存储。
Description
技术领域
本发明涉及一种数据包接收与存储方法。
背景技术
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=newSimpleDateFormat("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数据包的接收解析与存储,为开发人员提供了一种数据接收方式,有益于物联网的发展。
Claims (1)
1.一种对于IPv6网络UDP数据包的接收解析与存储方法,在接收UDP数据包的过程中,使用Java自有的DatagramSocket、InetAddress和Runnable类,步骤如下:创建一个包含main函数的Kernel类作为程序运行的开始,在该类中创建数据下载的Upload的线程并且启动该线程,此时数据接收开始;程序跳转到Upload中执行,该类继承Runnable类并对其中的run()方法进行重写,之后程序跳转到Receive类中,该类是接收UDP数据包的具体执行类;将解析后的数据通过InsertMySQL类中的addDataToTemHumTable()函数完成数据的存储。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201811193659.8A CN109302398A (zh) | 2018-10-15 | 2018-10-15 | 对于IPv6网络UDP数据包的接收解析与存储方法 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201811193659.8A CN109302398A (zh) | 2018-10-15 | 2018-10-15 | 对于IPv6网络UDP数据包的接收解析与存储方法 |
Publications (1)
Publication Number | Publication Date |
---|---|
CN109302398A true CN109302398A (zh) | 2019-02-01 |
Family
ID=65162649
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201811193659.8A Pending CN109302398A (zh) | 2018-10-15 | 2018-10-15 | 对于IPv6网络UDP数据包的接收解析与存储方法 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN109302398A (zh) |
Cited By (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114630178A (zh) * | 2022-02-16 | 2022-06-14 | 山东浪潮超高清视频产业有限公司 | 基于5g nr广播的消息接收系统及实现方法 |
Citations (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN101729542A (zh) * | 2009-11-26 | 2010-06-09 | 上海大学 | 基于网络数据包的多协议信息解析的系统 |
CN103001971A (zh) * | 2012-12-25 | 2013-03-27 | 成都科来软件有限公司 | 一种网络数据包解析方法 |
-
2018
- 2018-10-15 CN CN201811193659.8A patent/CN109302398A/zh active Pending
Patent Citations (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN101729542A (zh) * | 2009-11-26 | 2010-06-09 | 上海大学 | 基于网络数据包的多协议信息解析的系统 |
CN103001971A (zh) * | 2012-12-25 | 2013-03-27 | 成都科来软件有限公司 | 一种网络数据包解析方法 |
Non-Patent Citations (2)
Title |
---|
年轻小斗奋: "JAVA基础-网络编程-UDP", 《HTTPS://WWW.CNBLOGS.COM/CHUN2015/P/4939698.HTM》 * |
憧憬LICOY: "Java-UDP协议数据传输简单小案例", 《HTTPS://WWW.LICOY.CN/2411.HTML/AMP》 * |
Cited By (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114630178A (zh) * | 2022-02-16 | 2022-06-14 | 山东浪潮超高清视频产业有限公司 | 基于5g nr广播的消息接收系统及实现方法 |
CN114630178B (zh) * | 2022-02-16 | 2024-05-14 | 山东浪潮超高清视频产业有限公司 | 基于5g nr广播的消息接收系统及实现方法 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
Tolle et al. | Design of an application-cooperative management system for wireless sensor networks | |
CN101799751B (zh) | 一种构建主机监控代理软件的方法 | |
CN112637318B (zh) | 一种面向存储完整性的智能网关系统、装置及其控制方法 | |
US10791050B2 (en) | Geographic location determination in a content delivery framework | |
US7467078B2 (en) | Portable distributed application framework | |
CN110069354A (zh) | 微服务全链路跟踪方法及微服务架构 | |
CN106201862A (zh) | web服务压力测试方法及装置 | |
WO2021082081A1 (zh) | 动态修改Nginx配置参数的方法、系统、装置及存储介质 | |
CN112527647B (zh) | 基于NS-3的Raft共识算法测试系统 | |
CN108833005B (zh) | 光网络通信设备及其组网业务的自动化测试工具包及方法 | |
Li et al. | Code offload with least context migration in the mobile cloud | |
US11294740B2 (en) | Event to serverless function workflow instance mapping mechanism | |
CN102664952B (zh) | 一种对嵌入式设备集群管理及监控的方法 | |
CN108804147A (zh) | 联动关机方法、装置及客户端 | |
CN105515837A (zh) | 一种基于事件驱动的高并发web流量产生器 | |
CN108882053B (zh) | 弹幕消息分发方法、装置、设备及存储介质 | |
CN114756357B (zh) | 一种基于jvm的非阻塞分布式计划任务调度方法 | |
CN108228880B (zh) | 数据库管理系统调用外部函数的方法、装置、设备及介质 | |
CN109302398A (zh) | 对于IPv6网络UDP数据包的接收解析与存储方法 | |
CN113835904A (zh) | 一种远程过程调用控制方法、装置、设备及存储介质 | |
US20090327995A1 (en) | Annotation-aided code generation in library-based replay | |
CN109005468B (zh) | 弹幕消息分发方法、装置、设备及存储介质 | |
US9537931B2 (en) | Dynamic object oriented remote instantiation | |
Schoeberl et al. | tpip: A time-predictable tcp/ip stack for cyber-physical systems | |
CN112241359B (zh) | 一种设备测试方法及设备 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
RJ01 | Rejection of invention patent application after publication | ||
RJ01 | Rejection of invention patent application after publication |
Application publication date: 20190201 |