专利转让平台_买专利_卖专利_中国高校专利技术交易-买卖发明专利上知查网

全部分类
全部分类
一种高效的大数据网络实现方法

一种高效的大数据网络实现方法

IPC分类号 : H04L12/707,H04L12/733,H04L12/741,H04L29/08

申请号
CN201810431363.9
可选规格
  • 专利类型: 发明专利
  • 法律状态: 有权
  • 申请日: 2018-05-08
  • 公开号: CN108768846B
  • 公开日: 2018-11-06
  • 主分类号: H04L12/707 分类号: H04L12/707,H04L12/733,H04L12/741,H04L29/08
  • 专利权人: 常熟理工学院

专利摘要

本发明提供了一种高效的大数据网络实现方法,所述网络包括连个以上的移动节点,一种数据由一个名称唯一标识,一种数据由两个以上的数据分片构成;如果一种数据包含N个数据分片,N为大于2的自然数,则每个数据分片由一个数据分片IDn1唯一标识,n1取值范围1~N;移动设备通过本发明提供的方法能够快速获取大数据,从而降低数据通信延迟和代价,提高服务质量。本发明可应用于农业工程化、智能医疗等诸多领域,具有广泛的应用前景。

权利要求

1.一种高效的大数据网络实现方法,其特征在于,所述网络包括两个以上的移动节点,一种数据由一个名称唯一标识,一种数据由两个以上的数据分片构成;如果一种数据包含N个数据分片,N为大于2的自然数,则每个数据分片由一个数据分片ID n1唯一标识,n1取值范围1~N;

每个移动节点维护一个转发表,一个转发表项包含名称域、横坐标区间域、纵坐标区间域和生命周期域;如果一个转发表项的生命周期衰减为0,则删除该转发表项;

移动节点通过查询消息和查询响应消息来建立转发表项;一个查询消息包含名称域、消息类型域和广播范围域,查询消息的消息类型值为1;一个查询响应消息包含名称域、消息类型域、广播范围域、横坐标区间域、纵坐标区间域以及生命周期域,查询响应消息的消息类型值为2;

数据C1由名称NA1唯一标识,如果移动节点M1的转发表中任何一个转发表项的名称域值都不等于名称NA1,那么移动节点M1执行下述过程建立转发表项:

步骤101:开始;

步骤102:移动节点M1发送一个查询消息,该查询消息的名称域值为名称NA1,消息类型为1,广播范围为0;

步骤103:接收到该查询消息的移动节点将该查询消息中的广播范围域值递增1;判断该移动节点能否提供数据C1,且该移动节点在未来时间T1范围内的移动区域为横坐标区间[x1,x2]和纵坐标区间[y1,y2]定义的长方形,区间下限x1和区间上限x2为正整数且x1<x2,区间下限y1和区间上限y2为正整数且y1<y2,如果能则执行步骤104,否则执行步骤105;

步骤104:接收到查询消息的移动节点发送一个查询响应消息,该查询响应消息的名称域值等于该查询消息的名称域值,消息类型为2,广播范围域值等于该查询消息中的广播范围域值,横坐标区间为[x1,x2],纵坐标区间为[y1,y2],生命周期域值为T1,执行步骤107;

步骤105:接收到查询消息的移动节点判断该查询消息中的广播范围域值是否大于预定值TS1,如果是,则执行步骤107,否则执行步骤106;

步骤106:接收到查询消息的移动节点转发该查询消息,执行步骤103;

步骤107:接收到查询响应消息的移动节点将该查询响应消息中的广播范围域值递减1;该移动节点创建一个转发表项,该转发表项的名称域值等于该查询响应消息中的名称域值,该转发表项的横坐标区间域值等于该查询响应消息中的横坐标区间域值,该转发表项的纵坐标区间域值等于该查询响应消息中的纵坐标区间域值,该转发表项的生命周期域值等于该查询响应消息中的生命周期域值;

步骤108:接收到查询响应消息的移动节点判断该查询响应消息的广播范围域值是否为0,如果是,则执行步骤110,否则执行步骤109;

步骤109:接收到查询响应消息的移动节点转发该查询响应消息,执行步骤107;

步骤110:如果移动节点M1在预定时间PT1内至少接收到一个查询响应消息,则执行步骤112,否则执行步骤111;

步骤111:移动节点M1将预定值TS1递增h1,其中,h1为正整数,执行步骤102;

步骤112:结束;

每个移动节点具有唯一性的硬件ID,每个移动节点保存一个节点表,每个节点表项包含坐标域、硬件ID域和生命周期域;

移动节点通过移动节点消息来建立节点表;

一个移动节点消息包含消息类型域,硬件ID域和坐标域,移动节点消息类型值为3;

一个移动节点通过下述过程创建节点表:

步骤201:开始;

步骤202:移动节点定期发送移动节点消息,该移动节点消息的消息类型为3,硬件ID域等于该移动节点的硬件ID,坐标域值等于该移动节点当前的坐标;

步骤203:邻居移动节点接收到该移动节点消息后,查看节点表;判断是否存在一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,如果是则执行步骤204,否则执行步骤205;

步骤204:接收到移动节点消息的邻居移动节点选择一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,将该节点表项的坐标域值更新为该移动节点消息的坐标域值,将生命周期设置为最大值,执行步骤206;

步骤205:接收到移动节点消息的邻居移动节点创建一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,该节点表项的坐标域值等于该移动节点消息的坐标域值,生命周期设置为最大值;

步骤206:结束;

移动节点通过请求消息和响应消息来获取数据;

一个请求消息包含名称域、消息类型域、目的硬件ID域、源硬件ID域、横坐标区间域、纵坐标区间域和生命周期域,请求消息的消息类型值为4;

一个响应消息包含名称域、消息类型域、数据分片ID域、最后分片域、目的硬件ID域、数据值域、横坐标区间域、纵坐标区间域和生命周期域,响应消息类型值为5;

长方形区域R1由横坐标区间[x1,x2]和纵坐标区间[y1,y2]定义,如果坐标(x3,y3)和坐标(x4,y4)满足公式(1),则坐标(x3,y3)与长方形区域R1的距离比坐标(x4,y4)与长方形区域R1的距离更短;

每个移动节点维护一个等待处理表,每个等待处理表项包含名称域,前一跳域和生命周期域;

数据C1由名称NA1定义,包含N1个数据分片,每个数据分片由数据分片ID s1唯一标识,s1取值1~N1,如果请求数据C1的移动节点的数量不大于预定值TS3,则移动节点M1通过下述过程获取数据C1:

步骤301:开始;

步骤302:移动节点M1查看转发表,判断是否存在名称域值等于NA1的转发表项,如果是,则无需做任何操作,否则执行步骤101~112建立转发表;移动节点M1查看所有名称域值为NA1的转发表项,然后从所述转发表项中选取横坐标区间和纵坐标区间域值所定义的长方形面积最小的转发表项,移动节点M1选择一个节点表项,该节点表项的坐标与该转发表项的横坐标区间和纵坐标区间域值所定义的长方形距离最近,发送一个请求消息,该请求消息的名称为NA1,消息类型为4,目的硬件ID为该节点表项中的硬件ID,源硬件ID等于移动节点M1的硬件ID,横坐标区间域和纵坐标区间域分别等于该转发表项的横坐标区间和纵坐标区间域值,生命周期域等于预定值;

步骤303:目的移动节点接收到该请求消息后,判断该请求消息的生命周期是否衰减为0,如果是,则执行步骤314,否则执行步骤304;

步骤304:接收到请求消息的目的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值;

步骤305:判断接收到请求消息的目的移动节点是否位于由该请求消息横坐标区域和纵坐标区域定义的长方形区域内,如果是,则执行步骤307,否则执行步骤306;

步骤306:接收到请求消息的目的移动节点选择一个节点表项,该移动节点表项的坐标与该请求消息的横坐标区间和纵坐标区间域值所定义的长方形距离最近,将该请求消息的目的硬件ID更新为该节点表项的硬件ID,将该请求消息的源硬件ID更新为该目的移动节点的硬件ID,转发该请求消息,执行步骤303;

步骤307:接收到请求消息的目的移动节点将该请求消息的目的硬件ID域设置为空,将该请求消息的源硬件ID设置为自己的硬件ID,转发该请求消息;

步骤308:接收到请求消息的移动节点判断该请求消息的生命周期是否为0,如果是,则执行步骤314,否则执行步骤309;

步骤309:判断接收到请求消息的移动节点是否能提供该请求消息名称域值定义的数据C1,如果能,则执行步骤311,否则执行步骤310;

步骤310:接收到请求消息的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值,该移动节点将该请求消息的源硬件ID更新为自己的硬件ID,转发该请求消息,执行步骤307;

步骤311:如果接收到该请求消息的移动节点在未来时间T5范围内的移动区域为横坐标区间[x5,x6]和纵坐标区间[y5,y6]定义的长方形,该移动节点设置一个参数s2,其值为0;

步骤312:判断接收到该请求消息的移动节点将参数s2递增1,如果参数s2大于N1,则执行步骤314,否则执行步骤313;

步骤313:接收到该请求消息的移动节点发送一个响应消息,该响应消息的名称域为该请求消息的名称域值,消息类型域值为5,数据分片ID域值为s2,目的硬件ID域等于该请求消息的源硬件ID,数据值域等于该请求消息的名称域值所标识的数据的第s2个分片,横坐标区间域值为[x5,x6],纵坐标区间域值为[y5,y6],生命周期域值为T5;如果参数s2等于N1,则最后分片域值为1,否则最后分片域值为0,执行步骤312;

步骤314:判断移动节点M1是否接收到响应消息,是则执行步骤317,否则执行步骤315;

步骤315:目的移动节点接收到响应消息后,查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期;

步骤316:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,对于每个选取的等待处理表项,该目的移动节点将该响应消息的目的硬件ID更新为该等待处理表项的前一跳域值,如果该响应消息的最后分片域值为1,则删除该等待处理表项,该目的移动节点转发该响应消息,执行步骤314;

步骤317:如果移动节点M1接收到最后分片域值为1的响应消息,则执行步骤319,否则执行步骤318;

步骤318:移动节点M1保存接收到的响应消息的数据,执行步骤314;

步骤319:移动节点M1保存接收到的响应消息中的数据,将所有接收到的数据消息中的分片构建成数据C1,保存数据C1;

步骤320:结束;

数据C1由名称NA1定义,包含N1个数据分片;每个数据分片由数据分片ID s1唯一标识,s1取值1~N1;如果请求数据C1的移动节点的数量大于预定值TS3,则移动节点M1通过下述过程获取数据C1:

步骤401:开始;

步骤402:移动节点M1查看转发表,判断是否存在名称域值等于NA1的转发表项,如果存在,则不做任何操作,否则执行步骤101~112建立转发表;移动节点M1所有名称域值为NA1的转发表项,然后从这些转发表项中选取横坐标区间和纵坐标区间域值所定义的长方形面积最小的转发表项,选择一个节点表项,该节点表项的坐标与该转发表项的横坐标区间和纵坐标区间域值所定义的长方形距离最近,移动节点M1发送一个请求消息,该请求消息的名称为NA1,消息类型为4,目的硬件ID为该节点表项中的硬件ID,源硬件ID等于移动节点M1的硬件ID,横坐标区间域和纵坐标区间域分别等于该转发表项的横坐标区间和纵坐标区间域值,生命周期域等于预定值;

步骤403:目的移动节点接收到该请求消息后,判断该请求消息的生命周期是否衰减为0,如果是,则执行步骤414,否则执行步骤404;

步骤404:接收到请求消息的目的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值;

步骤405:判断接收到请求消息的目的移动节点是否位于由该请求消息横坐标区域和纵坐标区域定义的长方形区域内,如果是,则执行步骤407,否则执行步骤406;

步骤406:接收到请求消息的目的移动节点选择一个节点表项,该移动节点表项的坐标与该请求消息的横坐标区间和纵坐标区间域值所定义的长方形距离最近,将该请求消息的目的硬件ID更新为该节点表项的硬件ID,将该请求消息的源硬件ID更新为该目的移动节点的硬件ID,转发该请求消息,执行步骤403;

步骤407:接收到请求消息的目的移动节点将该请求消息的目的硬件ID域设置为空,将该请求消息的源硬件ID设置为自己的硬件ID,转发该请求消息;

步骤408:接收到请求消息的移动节点判断该请求消息的生命周期是否为0,如果是,则执行步骤414,否则执行步骤409;

步骤409:判断接收到请求消息的移动节点是否能提供该请求消息名称域值定义的数据C1,如果能,则执行步骤411,否则执行步骤410;

步骤410:接收到请求消息的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值,该移动节点将该请求消息的源硬件ID更新为自己的硬件ID,转发该请求消息,执行步骤407;

步骤411:如果接收到该请求消息的移动节点在未来时间T7范围内的移动区域为横坐标区间[x7,x8]和纵坐标区间[y7,y8]定义的长方形,该移动节点设置一个参数s2,其值为0;

步骤412:接收到该请求消息的移动节点将参数s2递增1,如果参数s2大于N1,则执行步骤414,否则执行步骤413;

步骤413:接收到该请求消息的移动节点发送一个响应消息,该响应消息的名称域为该请求消息的名称域值,消息类型域值为5,数据分片ID域值为s2,目的硬件ID域等于该请求消息的源硬件ID,数据值域等于该请求消息的名称域值所标识的数据的第s2个分片,横坐标区间域值为[x5,x6],纵坐标区间域值为[y5,y6],生命周期域值为T5;如果参数s2等于N1,则最后分片域值为1,否则最后分片域值为0,执行步骤412;

步骤414:如果移动节点M1接收到响应消息,则执行步骤421,否则执行步骤415;

步骤415:判断移动节点接收到的响应消息的目的硬件ID是否为空,是则执行步骤416,否则执行步骤417;

步骤416:接收到响应消息的移动节点查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期,执行步骤418;

步骤417:接收到响应消息的目的移动节点查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期;

步骤418:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,如果选中的等待处理表项的个数大于预定值TS3,则执行步骤420,否则执行步骤419;

步骤419:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,对于每个选取的等待处理表项,该目的移动节点将该响应消息的目的硬件ID更新为该等待处理表项的前一跳域值,如果该响应消息的最后分片域值为1,则删除该等待处理表项,该目的移动节点转发该响应消息,执行步骤414;

步骤420:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,该目的移动节点将该响应消息的目的硬件ID设置为空,如果该响应消息的最后分片为1,则删除所有选中的等待处理表项,转发该响应消息,执行步骤414;

步骤421:如果移动节点M1接收到最后分片域值为1的响应消息,则执行步骤423,否则执行步骤422;

步骤422:移动节点M1保存接收到的响应消息的数据,执行步骤414;

步骤423:移动节点M1保存接收到的响应消息中的数据,将所有接收到的数据消息中的分片构建成数据C1,保存数据C1;

步骤424:结束。

说明书

技术领域

本发明涉及一种网络实现方法,尤其涉及的是一种高效的大数据网络实现方法。

背景技术

随着大数据网络技术的不断发展以及各种新应用的不断涌现,迫切需要提高大数据网络的数据通信性能。近年来,很多研究工作致力于大数据网络数据通信方法,以便使移动节点能够快速获取网络服务。随着大数据网络技术的发展,大数据网络数据通信方法会成为未来提供服务的一种模式。

目前,大数据网络数据通信的实现模式是通过广播来实现,因此延迟和代价都比较大,降低了网络服务性能。因此,如何降低大数据网络提供服务的延迟和代价成为近年来研究的热点问题。

发明内容

发明目的:本发明所要解决的技术问题是针对现有技术的不足,提供了一种高效的大数据网络实现方法。

技术方案:本发明公开了一种高效的大数据网络实现方法,所述网络包括连个以上的移动节点,一种数据由一个名称唯一标识,一种数据由两个以上的数据分片构成;如果一种数据包含N个数据分片,N为大于2的自然数,则每个数据分片由一个数据分片ID n1唯一标识,n1取值范围1~N;

每个移动节点维护一个转发表,一个转发表项包含名称域、横坐标区间域、纵坐标区间域和生命周期域;如果一个转发表项的生命周期衰减为0,则删除该转发表项;

移动节点通过查询消息和查询响应消息来建立转发表项;一个查询消息包含名称域、消息类型域和广播范围域,查询消息的消息类型值为1;一个查询响应消息包含名称域、消息类型域、广播范围域、横坐标区间域、纵坐标区间域以及生命周期域,查询响应消息的消息类型值为2;

数据C1由名称NA1唯一标识,如果移动节点M1的转发表中任何一个转发表项的名称域值都不等于名称NA1,那么移动节点M1执行下述过程建立转发表项:

步骤101:开始;

步骤102:移动节点M1发送一个查询消息,该查询消息的名称域值为名称NA1,消息类型为1,广播范围为0;

步骤103:移动节点接收到该查询消息后,将该查询消息中的广播范围域值递增1;判断该移动节点能否提供数据C1,且该移动节点在未来时间T1范围内的移动区域为横坐标区间[x1,x2]和纵坐标区间[y1,y2]定义的长方形,区间下限x1和区间上限x2为正整数且x1<x2,区间下限y1和区间上限y2为正整数且y1<y2,如果能则执行步骤104,否则执行步骤105;

步骤104:接收到查询消息的移动节点发送一个查询响应消息,该查询响应消息的名称域值等于该查询消息的名称域值,消息类型为2,广播范围域值等于该查询消息中的广播范围域值,横坐标区间为[x1,x2],纵坐标区间为[y1,y2],生命周期域值为T1,执行步骤107;

步骤105:接收到查询消息的移动节点判断该查询消息中的广播范围域值是否大于预定值TS1,如果是,则执行步骤107,否则执行步骤106;预定值TS1设置的意义在于阻止广播风暴;预定值TS1一般设定为网络直径,即任意两个移动节点之间的最大距离,距离一般用跳数来衡量,一般设置为10;

步骤106:接收到查询消息的移动节点转发该查询消息,执行步骤103;

步骤107:移动节点接收到查询响应消息后,将该查询响应消息中的广播范围域值递减1;该移动节点创建一个转发表项,该转发表项的名称域值等于该查询响应消息中的名称域值,该转发表项的横坐标区间域值等于该查询响应消息中的横坐标区间域值,该转发表项的纵坐标区间域值等于该查询响应消息中的纵坐标区间域值,该转发表项的生命周期域值等于该查询响应消息中的生命周期域值;

步骤108:接收到查询响应消息的移动节点判断该查询响应消息的广播范围域值是否为0,如果是,则执行步骤110,否则执行步骤109;

步骤109:接收到查询响应消息的移动节点转发该查询响应消息,执行步骤107;

步骤110:如果移动节点M1在预定时间PT1内至少接收到一个查询响应消息,则执行步骤112,否则执行步骤111;例如,预定时间PT1为1s;

步骤111:移动节点M1将预定值TS1递增h1,其中,h1为正整数,执行步骤102;

步骤112:结束。

移动节点通过上述过程能够建立转发表,移动节点通过转发表能够从距离最近的移动节点获取数据,从而降低数据通信延迟和代价,此外,转发表项中包含移动节点的移动区域,因此提高了数据通信成功率。

本发明所述方法中,每个移动节点具有唯一性的硬件ID,例如MAC地址,每个移动节点保存一个节点表,每个节点表项包含坐标域、硬件ID域和生命周期域;

移动节点通过移动节点消息来建立节点表;

一个移动节点消息包含消息类型域,硬件ID域和坐标域,移动节点消息类型值为3;

一个移动节点通过下述过程创建节点表:

步骤201:开始;

步骤202:移动节点定期发送移动节点消息,该移动节点消息的消息类型为3,硬件ID域等于该移动节点的硬件ID,坐标域值等于该移动节点当前的坐标;

步骤203:邻居移动节点接收到该移动节点消息后,查看节点表;判断是否存在一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,如果是则执行步骤204,否则执行步骤205;

步骤204:接收到移动节点消息的邻居移动节点选择一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,将该节点表项的坐标域值更新为该移动节点消息的坐标域值,将生命周期设置为最大值,例如1s,执行步骤206;

步骤205:接收到移动节点消息的邻居移动节点创建一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,该节点表项的坐标域值等于该移动节点消息的坐标域值,生命周期设置为最大值;

步骤206:结束。

移动节点通过上述过程能够实时维护邻居移动节点的信息,从而能够根据邻居移动节点的实时坐标,将消息转发给距离目标节点最近的邻居移动节点以降低数据通信延迟和代价。

本发明所述方法中,移动节点通过请求消息和响应消息来获取数据;

一个请求消息包含名称域、消息类型域、目的硬件ID域、源硬件ID域、横坐标区间域、纵坐标区间域和生命周期域,请求消息的消息类型值为4;

一个响应消息包含名称域、消息类型域、数据分片ID域、最后分片域、目的硬件ID域、数据值域、横坐标区间域、纵坐标区间域和生命周期域,响应消息类型值为5;

长方形区域R1由横坐标区间[x1,x2]和纵坐标区间[y1,y2]定义,如果坐标(x3,y3)和坐标(x4,y4)满足公式(1),则坐标(x3,y3)与长方形区域R1的距离比坐标(x4,y4)与长方形区域R1的距离更短;

每个移动节点维护一个等待处理表,每个等待处理表项包含名称域,前一跳域和生命周期域;

数据C1由名称NA1定义,包含N1个数据分片,每个数据分片由数据分片ID s1唯一标识,s1取值1~N1,如果请求数据C1的移动节点的数量不大于预定值TS3,预定值TS3一般为小于5的正整数;则移动节点M1通过下述过程获取数据C1:

步骤301:开始;

步骤302:移动节点M1查看转发表,判断是否存在名称域值等于NA1的转发表项,如果是,则无需做任何操作,否则执行步骤101~112建立转发表;移动节点M1查看所有名称域值为NA1的转发表项,然后从所述转发表项中选取横坐标区间和纵坐标区间域值所定义的长方形面积最小的转发表项,如果存在多个长方形面积最小的转发表项,移动节点M1则随机选取一个多个长方形面积最小的转发表项,移动节点M1选择一个节点表项,该节点表项的坐标与该转发表项的横坐标区间和纵坐标区间域值所定义的长方形距离最近,如果存在多个距离最近的节点表项,移动节点M1则随机选取一个距离最近的节点表项,发送一个请求消息,该请求消息的名称为NA1,消息类型为4,目的硬件ID为该节点表项中的硬件ID,源硬件ID等于移动节点M1的硬件ID,横坐标区间域和纵坐标区间域分别等于该转发表项的横坐标区间和纵坐标区间域值,生命周期域等于预定值,例如500ms;

步骤303:目的移动节点接收到该请求消息后,判断该请求消息的生命周期是否衰减为0,如果是,则执行步骤314,否则执行步骤304;

步骤304:接收到请求消息的目的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值;

步骤305:判断接收到请求消息的目的移动节点是否位于由该请求消息横坐标区域和纵坐标区域定义的长方形区域内,如果是,则执行步骤307,否则执行步骤306;

步骤306:接收到请求消息的目的移动节点选择一个节点表项,该移动节点表项的坐标与该请求消息的横坐标区间和纵坐标区间域值所定义的长方形距离最近,如果存在多个距离最近的节点表项,移动节点则随机选取一个距离最近的节点表项,将该请求消息的目的硬件ID更新为该节点表项的硬件ID,将该请求消息的源硬件ID更新为该目的移动节点的硬件ID,转发该请求消息,执行步骤303;

步骤307:接收到请求消息的目的移动节点将该请求消息的目的硬件ID域设置为空,将该请求消息的源硬件ID设置为自己的硬件ID,转发该请求消息;

步骤308:判断接收到请求消息的移动节点判断该请求消息的生命周期是否为0,如果是,则执行步骤314,否则执行步骤309;

步骤309:判断接收到请求消息的移动节点是否能提供该请求消息名称域值定义的数据C1,如果能,则执行步骤311,否则执行步骤310;

步骤310:接收到请求消息的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值,该移动节点将该请求消息的源硬件ID更新为自己的硬件ID,转发该请求消息,执行步骤307;

步骤311:如果接收到该请求消息的移动节点在未来时间T5范围内的移动区域为横坐标区间[x5,x6]和纵坐标区间[y5,y6]定义的长方形,该移动节点设置一个参数s2,其值为0;

步骤312:判断接收到该请求消息的移动节点将参数s2递增1,如果参数s2大于N1,则执行步骤314,否则执行步骤313;

步骤313:接收到该请求消息的移动节点发送一个响应消息,该响应消息的名称域为该请求消息的名称域值,消息类型域值为5,数据分片ID域值为s2,目的硬件ID域等于该请求消息的源硬件ID,数据值域等于该请求消息的名称域值所标识的数据的第s2个分片,横坐标区间域值为[x5,x6],纵坐标区间域值为[y5,y6],生命周期域值为T5;如果参数s2等于N1,则最后分片域值为1,否则最后分片域值为0,执行步骤312;

步骤314:判断移动节点M1是否接收到响应消息,是则执行步骤317,否则执行步骤315;

步骤315:目的移动节点接收到响应消息后,查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期;

步骤316:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,对于每个选取的等待处理表项,该目的移动节点将该响应消息的目的硬件ID更新为该等待处理表项的前一跳域值,如果该响应消息的最后分片域值为1,则删除该等待处理表项,该目的移动节点转发该响应消息,执行步骤314;

步骤317:如果移动节点M1接收到最后分片为1的响应消息,则执行步骤319,否则执行步骤318;

步骤318:移动节点M1保存接收到的响应消息的数据,执行步骤314;

步骤319:移动节点M1保存接收到的响应消息中的数据,将所有接收到的数据消息中的分片构建成数据C1,保存数据C1;

步骤320:结束。

请求数据C1的移动节点的数量不大于预定值TS3时,这些移动节点通过上述过程实现数据通信,由于等待处理表实现了请求消息的聚合,因此移动节点可以通过中间节点共享数据,因此大幅度降低了数据通信延迟和代价。

本发明所述方法中,数据C1由名称NA1定义,包含N1个数据分片;每个数据分片由数据分片ID s1唯一标识,s1取值1~N1;如果请求数据C1的移动节点的数量大于预定值TS3,预定值TS3一般为小于5的正整数,则移动节点M1通过下述过程获取数据C1:

步骤401:开始;

步骤402:移动节点M1查看转发表,判断是否存在名称域值等于NA1的转发表项,如果存在,则不做任何操作,否则执行步骤101~112建立转发表;移动节点M1所有名称域值为NA1的转发表项,然后从这些转发表项中选取横坐标区间和纵坐标区间域值所定义的长方形面积最小的转发表项,选择一个节点表项,该节点表项的坐标与该转发表项的横坐标区间和纵坐标区间域值所定义的长方形距离最近,如果存在多个距离最近的节点表项,移动节点M1则随机选取一个距离最近的节点表项,移动节点M1发送一个请求消息,该请求消息的名称为NA1,消息类型为4,目的硬件ID为该节点表项中的硬件ID,源硬件ID等于移动节点M1的硬件ID,横坐标区间域和纵坐标区间域分别等于该转发表项的横坐标区间和纵坐标区间域值,生命周期域等于预定值,例如500ms;

步骤403:目的移动节点接收到该请求消息后,判断该请求消息的生命周期是否衰减为0,如果是,则执行步骤414,否则执行步骤404;

步骤404:接收到请求消息的目的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值;

步骤405:判断接收到请求消息的目的移动节点是否位于由该请求消息横坐标区域和纵坐标区域定义的长方形区域内,如果是,则执行步骤407,否则执行步骤406;

步骤406:接收到请求消息的目的移动节点选择一个节点表项,该移动节点表项的坐标与该请求消息的横坐标区间和纵坐标区间域值所定义的长方形距离最近,如果存在多个距离最近的节点表项,移动节点则随机选取一个距离最近的节点表项,将该请求消息的目的硬件ID更新为该节点表项的硬件ID,将该请求消息的源硬件ID更新为该目的移动节点的硬件ID,转发该请求消息,执行步骤403;

步骤407:接收到请求消息的目的移动节点将该请求消息的目的硬件ID域设置为空,将该请求消息的源硬件ID设置为自己的硬件ID,转发该请求消息;

步骤408:判断接收到请求消息的移动节点判断该请求消息的生命周期是否为0,如果是,则执行步骤414,否则执行步骤409;

步骤409:判断接收到请求消息的移动节点是否能提供该请求消息名称域值定义的数据C1,如果能,则执行步骤411,否则执行步骤410;

步骤410:接收到请求消息的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值,该移动节点将该请求消息的源硬件ID更新为自己的硬件ID,转发该请求消息,执行步骤407;

步骤411:如果接收到该请求消息的移动节点在未来时间T7范围内的移动区域为横坐标区间[x7,x8]和纵坐标区间[y7,y8]定义的长方形,该移动节点设置一个参数s2,其值为0;

步骤412:接收到该请求消息的移动节点将参数s2递增1,如果参数s2大于N1,则执行步骤414,否则执行步骤413;

步骤413:接收到该请求消息的移动节点发送一个响应消息,该响应消息的名称域为该请求消息的名称域值,消息类型域值为5,数据分片ID域值为s2,目的硬件ID域等于该请求消息的源硬件ID,数据值域等于该请求消息的名称域值所标识的数据的第s2个分片,横坐标区间域值为[x5,x6],纵坐标区间域值为[y5,y6],生命周期域值为T5;如果参数s2等于N1,则最后分片域值为1,否则最后分片域值为0,执行步骤412;

步骤414:如果移动节点M1接收到响应消息,则执行步骤421,否则执行步骤415;

步骤415:判断移动节点接收到的响应消息的目的硬件ID是否为空,则执行步骤416,否则执行步骤417;

步骤416:接收到响应消息的移动节点查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期,执行步骤418;

步骤417:接收到响应消息的目的移动节点查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期;

步骤418:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,如果选中的等待处理表项的个数大于预定值TS3,则执行步骤420,否则执行步骤419;

步骤419:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,对于每个选取的等待处理表项,该目的移动节点将该响应消息的目的硬件ID更新为该等待处理表项的前一跳域值,如果该响应消息的最后分片域值为1,则删除该等待处理表项,该目的移动节点转发该响应消息,执行步骤414;

步骤420:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,该目的移动节点将该响应消息的目的硬件ID设置为空,如果该响应消息的最后分片为1,则删除所有选中的等待处理表项,转发该响应消息,执行步骤414;

步骤421:如果移动节点M1接收到最后分片为1的响应消息,则执行步骤423,否则执行步骤422;

步骤422:移动节点M1保存接收到的响应消息的数据,执行步骤414;

步骤423:移动节点M1保存接收到的响应消息中的数据,将所有接收到的数据消息中的分片构建成数据C1,保存数据C1;

步骤424:结束。

如果请求数据C1的移动节点的数量大于预定值TS3,移动节点则通过上述过程获取数据,由于多个移动节点同时申请数据,导致网络性能有所下降以及丢包率增加,因此上述方法采用多路径数据传输从而大幅度降低了丢包率,增加了数据通信的成功率。

有益效果:本发明提供了一种高效的大数据网络实现方法,移动设备通过本发明提供的方法能够快速获取大数据,从而降低数据通信延迟和代价,提高服务质量。本发明可应用于农业工程化、智能医疗等诸多领域,具有广泛的应用前景。

附图说明

下面结合附图和具体实施方式对本发明做更进一步的具体说明,本发明的上述和/或其他方面的优点将会变得更加清楚。

图1为本发明所述的建立转发表流程示意图。

图2为本发明所述的创建节点表流程示意图。

图3为本发明所述的数据通信流程示意图。

图4为本发明所述的获取数据流程示意图。

具体实施方式:

本发明提供了一种高效的大数据网络实现方法,移动设备通过本发明提供的方法能够快速获取大数据,从而降低数据通信延迟和代价,提高服务质量。本发明可应用于农业工程化、智能医疗等诸多领域,具有广泛的应用前景。

图1为本发明所述的建立转发表流程示意图。所述网络包括连个以上的移动节点,一种数据由一个名称唯一标识,一种数据由两个以上的数据分片构成;如果一种数据包含N个数据分片,N为大于2的自然数,则每个数据分片由一个数据分片ID n1唯一标识,n1取值范围1~N;

每个移动节点维护一个转发表,一个转发表项包含名称域、横坐标区间域、纵坐标区间域和生命周期域;如果一个转发表项的生命周期衰减为0,则删除该转发表项;

移动节点通过查询消息和查询响应消息来建立转发表项;一个查询消息包含名称域、消息类型域和广播范围域,查询消息的消息类型值为1;一个查询响应消息包含名称域、消息类型域、广播范围域、横坐标区间域、纵坐标区间域以及生命周期域,查询响应消息的消息类型值为2;

数据C1由名称NA1唯一标识,如果移动节点M1的转发表中任何一个转发表项的名称域值都不等于名称NA1,那么移动节点M1执行下述过程建立转发表项:

步骤101:开始;

步骤102:移动节点M1发送一个查询消息,该查询消息的名称域值为名称NA1,消息类型为1,广播范围为0;

步骤103:移动节点接收到该查询消息后,将该查询消息中的广播范围域值递增1;判断该移动节点能否提供数据C1,且该移动节点在未来时间T1范围内的移动区域为横坐标区间[x1,x2]和纵坐标区间[y1,y2]定义的长方形,区间下限x1和区间上限x2为正整数且x1<x2,区间下限y1和区间上限y2为正整数且y1<y2,如果能则执行步骤104,否则执行步骤105;

步骤104:接收到查询消息的移动节点发送一个查询响应消息,该查询响应消息的名称域值等于该查询消息的名称域值,消息类型为2,广播范围域值等于该查询消息中的广播范围域值,横坐标区间为[x1,x2],纵坐标区间为[y1,y2],生命周期域值为T1,执行步骤107;

步骤105:接收到查询消息的移动节点判断该查询消息中的广播范围域值是否大于预定值TS1,如果是,则执行步骤107,否则执行步骤106;

步骤106:接收到查询消息的移动节点转发该查询消息,执行步骤103;

步骤107:移动节点接收到查询响应消息后,将该查询响应消息中的广播范围域值递减1;该移动节点创建一个转发表项,该转发表项的名称域值等于该查询响应消息中的名称域值,该转发表项的横坐标区间域值等于该查询响应消息中的横坐标区间域值,该转发表项的纵坐标区间域值等于该查询响应消息中的纵坐标区间域值,该转发表项的生命周期域值等于该查询响应消息中的生命周期域值;

步骤108:接收到查询响应消息的移动节点判断该查询响应消息的广播范围域值是否为0,如果是,则执行步骤110,否则执行步骤109;

步骤109:接收到查询响应消息的移动节点转发该查询响应消息,执行步骤107;

步骤110:如果移动节点M1在预定时间PT1内至少接收到一个查询响应消息,则执行步骤112,否则执行步骤111;

步骤111:移动节点M1将预定值TS1递增h1,其中,h1为正整数,执行步骤102;

步骤112:结束。

图2为本发明所述的创建节点表流程示意图。每个移动节点具有唯一性的硬件ID,每个移动节点保存一个节点表,每个节点表项包含坐标域、硬件ID域和生命周期域;

移动节点通过移动节点消息来建立节点表;

一个移动节点消息包含消息类型域,硬件ID域和坐标域,移动节点消息类型值为3;

一个移动节点通过下述过程创建节点表:

步骤201:开始;

步骤202:移动节点定期发送移动节点消息,该移动节点消息的消息类型为3,硬件ID域等于该移动节点的硬件ID,坐标域值等于该移动节点当前的坐标;

步骤203:邻居移动节点接收到该移动节点消息后,查看节点表;判断是否存在一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,如果是则执行步骤204,否则执行步骤205;

步骤204:接收到移动节点消息的邻居移动节点选择一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,将该节点表项的坐标域值更新为该移动节点消息的坐标域值,将生命周期设置为最大值,执行步骤206;

步骤205:接收到移动节点消息的邻居移动节点创建一个节点表项,该节点表项的硬件ID域值等于该移动节点消息的硬件ID域值,该节点表项的坐标域值等于该移动节点消息的坐标域值,生命周期设置为最大值;

步骤206:结束。

图3为本发明所述的数据通信流程示意图。移动节点通过请求消息和响应消息来获取数据;

一个请求消息包含名称域、消息类型域、目的硬件ID域、源硬件ID域、横坐标区间域、纵坐标区间域和生命周期域,请求消息的消息类型值为4;

一个响应消息包含名称域、消息类型域、数据分片ID域、最后分片域、目的硬件ID域、数据值域、横坐标区间域、纵坐标区间域和生命周期域,响应消息消息类型值为5;

长方形区域R1由横坐标区间[x1,x2]和纵坐标区间[y1,y2]定义,如果坐标(x3,y3)和坐标(x4,y4)满足公式(1),则坐标(x3,y3)与长方形区域R1的距离比坐标(x4,y4)与长方形区域R1的距离更短;

每个移动节点维护一个等待处理表,每个等待处理表项包含名称域,前一跳域和生命周期域;

数据C1由名称NA1定义,包含N1个数据分片,每个数据分片由数据分片ID s1唯一标识,s1取值1~N1,如果请求数据C1的移动节点的数量不大于预定值TS3,则移动节点M1通过下述过程获取数据C1:

步骤301:开始;

步骤302:移动节点M1查看转发表,判断是否存在名称域值等于NA1的转发表项,如果是,则无需做任何操作,否则执行步骤101~112建立转发表;移动节点M1查看所有名称域值为NA1的转发表项,然后从所述转发表项中选取横坐标区间和纵坐标区间域值所定义的长方形面积最小的转发表项,移动节点M1选择一个节点表项,该节点表项的坐标与该转发表项的横坐标区间和纵坐标区间域值所定义的长方形距离最近,发送一个请求消息,该请求消息的名称为NA1,消息类型为4,目的硬件ID为该节点表项中的硬件ID,源硬件ID等于移动节点M1的硬件ID,横坐标区间域和纵坐标区间域分别等于该转发表项的横坐标区间和纵坐标区间域值,生命周期域等于预定值;

步骤303:目的移动节点接收到该请求消息后,判断该请求消息的生命周期是否衰减为0,如果是,则执行步骤314,否则执行步骤304;

步骤304:接收到请求消息的目的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值;

步骤305:判断接收到请求消息的目的移动节点是否位于由该请求消息横坐标区域和纵坐标区域定义的长方形区域内,如果是,则执行步骤307,否则执行步骤306;

步骤306:接收到请求消息的目的移动节点选择一个节点表项,该移动节点表项的坐标与该请求消息的横坐标区间和纵坐标区间域值所定义的长方形距离最近,将该请求消息的目的硬件ID更新为该节点表项的硬件ID,将该请求消息的源硬件ID更新为该目的移动节点的硬件ID,转发该请求消息,执行步骤303;

步骤307:接收到请求消息的目的移动节点将该请求消息的目的硬件ID域设置为空,将该请求消息的源硬件ID设置为自己的硬件ID,转发该请求消息;

步骤308:判断接收到请求消息的移动节点判断该请求消息的生命周期是否为0,如果是,则执行步骤314,否则执行步骤309;

步骤309:判断接收到请求消息的移动节点是否能提供该请求消息名称域值定义的数据C1,如果能,则执行步骤311,否则执行步骤310;

步骤310:接收到请求消息的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值,该移动节点将该请求消息的源硬件ID更新为自己的硬件ID,转发该请求消息,执行步骤307;

步骤311:如果接收到该请求消息的移动节点在未来时间T5范围内的移动区域为横坐标区间[x5,x6]和纵坐标区间[y5,y6]定义的长方形,该移动节点设置一个参数s2,其值为0;

步骤312:判断接收到该请求消息的移动节点将参数s2递增1,如果参数s2大于N1,则执行步骤314,否则执行步骤313;

步骤313:接收到该请求消息的移动节点发送一个响应消息,该响应消息的名称域为该请求消息的名称域值,消息类型域值为5,数据分片ID域值为s2,目的硬件ID域等于该请求消息的源硬件ID,数据值域等于该请求消息的名称域值所标识的数据的第s2个分片,横坐标区间域值为[x5,x6],纵坐标区间域值为[y5,y6],生命周期域值为T5;如果参数s2等于N1,则最后分片域值为1,否则最后分片域值为0,执行步骤312;

步骤314:判断移动节点M1是否接收到响应消息,是则执行步骤317,否则执行步骤315;

步骤315:目的移动节点接收到响应消息后,查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期;

步骤316:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,对于每个选取的等待处理表项,该目的移动节点将该响应消息的目的硬件ID更新为该等待处理表项的前一跳域值,如果该响应消息的最后分片域值为1,则删除该等待处理表项,该目的移动节点转发该响应消息,执行步骤314;

步骤317:如果移动节点M1接收到最后分片为1的响应消息,则执行步骤319,否则执行步骤318;

步骤318:移动节点M1保存接收到的响应消息的数据,执行步骤314;

步骤319:移动节点M1保存接收到的响应消息中的数据,将所有接收到的数据消息中的分片构建成数据C1,保存数据C1;

步骤320:结束。

图4为本发明所述的获取数据流程示意图。数据C1由名称NA1定义,包含N1个数据分片;每个数据分片由数据分片ID s1唯一标识,s1取值1~N1;如果请求数据C1的移动节点的数量大于预定值TS3,则移动节点M1通过下述过程获取数据C1:

步骤401:开始;

步骤402:移动节点M1查看转发表,判断是否存在名称域值等于NA1的转发表项,如果存在,则不做任何操作,否则执行步骤101~112建立转发表;移动节点M1所有名称域值为NA1的转发表项,然后从这些转发表项中选取横坐标区间和纵坐标区间域值所定义的长方形面积最小的转发表项,选择一个节点表项,该节点表项的坐标与该转发表项的横坐标区间和纵坐标区间域值所定义的长方形距离最近,移动节点M1发送一个请求消息,该请求消息的名称为NA1,消息类型为4,目的硬件ID为该节点表项中的硬件ID,源硬件ID等于移动节点M1的硬件ID,横坐标区间域和纵坐标区间域分别等于该转发表项的横坐标区间和纵坐标区间域值,生命周期域等于预定值;

步骤403:目的移动节点接收到该请求消息后,判断该请求消息的生命周期是否衰减为0,如果是,则执行步骤414,否则执行步骤404;

步骤404:接收到请求消息的目的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值;

步骤405:判断接收到请求消息的目的移动节点是否位于由该请求消息横坐标区域和纵坐标区域定义的长方形区域内,如果是,则执行步骤407,否则执行步骤406;

步骤406:接收到请求消息的目的移动节点选择一个节点表项,该移动节点表项的坐标与该请求消息的横坐标区间和纵坐标区间域值所定义的长方形距离最近,将该请求消息的目的硬件ID更新为该节点表项的硬件ID,将该请求消息的源硬件ID更新为该目的移动节点的硬件ID,转发该请求消息,执行步骤403;

步骤407:接收到请求消息的目的移动节点将该请求消息的目的硬件ID域设置为空,将该请求消息的源硬件ID设置为自己的硬件ID,转发该请求消息;

步骤408:判断接收到请求消息的移动节点判断该请求消息的生命周期是否为0,如果是,则执行步骤414,否则执行步骤409;

步骤409:判断接收到请求消息的移动节点是否能提供该请求消息名称域值定义的数据C1,如果能,则执行步骤411,否则执行步骤410;

步骤410:接收到请求消息的移动节点创建一个等待处理表项,该等待处理表项的名称域值和生命周期域值分别等于该请求消息的名称域值和生命周期域值,前一跳域值等于该请求消息的源硬件ID域值,该移动节点将该请求消息的源硬件ID更新为自己的硬件ID,转发该请求消息,执行步骤407;

步骤411:如果接收到该请求消息的移动节点在未来时间T7范围内的移动区域为横坐标区间[x7,x8]和纵坐标区间[y7,y8]定义的长方形,该移动节点设置一个参数s2,其值为0;

步骤412:接收到该请求消息的移动节点将参数s2递增1,如果参数s2大于N1,则执行步骤414,否则执行步骤413;

步骤413:接收到该请求消息的移动节点发送一个响应消息,该响应消息的名称域为该请求消息的名称域值,消息类型域值为5,数据分片ID域值为s2,目的硬件ID域等于该请求消息的源硬件ID,数据值域等于该请求消息的名称域值所标识的数据的第s2个分片,横坐标区间域值为[x5,x6],纵坐标区间域值为[y5,y6],生命周期域值为T5;如果参数s2等于N1,则最后分片域值为1,否则最后分片域值为0,执行步骤412;

步骤414:如果移动节点M1接收到响应消息,则执行步骤421,否则执行步骤415;

步骤415:判断移动节点接收到的响应消息的目的硬件ID是否为空,则执行步骤416,否则执行步骤417;

步骤416:接收到响应消息的移动节点查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期,执行步骤418;

步骤417:接收到响应消息的目的移动节点查看转发表,如果存在一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,该目的移动节点则将该转发表项的生命周期域值更新为该响应消息的生命周期;否则该目的移动节点创建一个转发表项,该转发表项的名称域值,横坐标区间和纵坐标区间域值分别等于该响应消息的名称域值,横坐标区间和纵坐标区间域值,生命周期域值为该响应消息的生命周期;

步骤418:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,如果选中的等待处理表项的个数大于预定值TS3,则执行步骤420,否则执行步骤419;

步骤419:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,对于每个选取的等待处理表项,该目的移动节点将该响应消息的目的硬件ID更新为该等待处理表项的前一跳域值,如果该响应消息的最后分片域值为1,则删除该等待处理表项,该目的移动节点转发该响应消息,执行步骤414;

步骤420:接收到响应消息的目的移动节点选取所有名称域值等于该响应消息的名称域值的等待处理表项,该目的移动节点将该响应消息的目的硬件ID设置为空,如果该响应消息的最后分片为1,则删除所有选中的等待处理表项,转发该响应消息,执行步骤414;

步骤421:如果移动节点M1接收到最后分片为1的响应消息,则执行步骤423,否则执行步骤422;

步骤422:移动节点M1保存接收到的响应消息的数据,执行步骤414;

步骤423:移动节点M1保存接收到的响应消息中的数据,将所有接收到的数据消息中的分片构建成数据C1,保存数据C1;

步骤424:结束。

实施例1

基于表1的仿真参数,本实施例模拟了本发明中的一种高效的大数据网络实现方法,性能分析如下:当传输数据量增加时,网络性能下降,数据获取延迟有所增加,当传输数据量降低时,网络性能增强,数据获取延迟有所降低,数据获取的平均延迟为1.58s。

表1仿真参数

本发明提供了一种高效的大数据网络实现方法的思路,具体实现该技术方案的方法和途径很多,以上所述仅是本发明的优选实施方式,应当指出,对于本技术领域的普通技术人员来说,在不脱离本发明原理的前提下,还可以做出若干改进和润饰,这些改进和润饰也应视为本发明的保护范围。本实施例中未明确的各组成部份均可用现有技术加以实现。

一种高效的大数据网络实现方法专利购买费用说明

专利买卖交易资料

Q:办理专利转让的流程及所需资料

A:专利权人变更需要办理著录项目变更手续,有代理机构的,变更手续应当由代理机构办理。

1:专利变更应当使用专利局统一制作的“著录项目变更申报书”提出。

2:按规定缴纳著录项目变更手续费。

3:同时提交相关证明文件原件。

4:专利权转移的,变更后的专利权人委托新专利代理机构的,应当提交变更后的全体专利申请人签字或者盖章的委托书。

Q:专利著录项目变更费用如何缴交

A:(1)直接到国家知识产权局受理大厅收费窗口缴纳,(2)通过代办处缴纳,(3)通过邮局或者银行汇款,更多缴纳方式

Q:专利转让变更,多久能出结果

A:著录项目变更请求书递交后,一般1-2个月左右就会收到通知,国家知识产权局会下达《转让手续合格通知书》。

动态评分

0.0

没有评分数据
没有评价数据
×

打开微信,点击底部的“发现”

使用“扫一扫”即可将网页分享至朋友圈

×
复制
用户中心
我的足迹
我的收藏

您的购物车还是空的,您可以

  • 微信公众号

    微信公众号
在线留言
返回顶部