一种提高单向传输系统中数据传输可靠性的方法及系统与流程

未命名 08-26 阅读:124 评论:0


1.本发明涉及数据处理技术领域,尤其涉及一种提高单向传输系统中数据传输可靠性的方法及系统。


背景技术:

2.目前,在采用2+1系统架构的网络隔离设备中,设备由发送系统、接收系统和交换通道三个部分组成,在隔离数据交换过程中,很多业务场景要求数据的有序性,业务数据经过隔离交换设备后需要保证业务数据的先后顺序,但业务数据在隔离产品设备的交换过程中,因采用第三方软硬件,如操作系统、交换通道硬件、网络驱动和传输协议等因素,无法保证隔离交换数据通过接收系统、交换通道、发送系统后业务数据发送次序与进入接收系统数据顺序相同,若不对隔离交换过程进行管理,无法保证接收文件数据包的顺序性从而导致服务器收到的业务数据可能前后错乱,进而导致数据交换业务失败,降低了数据传输稳定性。


技术实现要素:

3.针对上述所显示出来的问题,本发明提供了一种提高单向传输系统中数据传输可靠性的方法及系统用以解决背景技术中提到的不对隔离交换过程进行管理,无法保证接收文件数据包的顺序性从而导致服务器收到的业务数据可能前后错乱,进而导致数据交换业务失败,降低了数据传输稳定性的问题。
4.一种提高单向传输系统中数据传输可靠性的方法,包括以下步骤:
5.利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;
6.使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;
7.利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;
8.基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。
9.3、优选的,所述利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存,包括:
10.生成通信连接指令并传输到所述网闸的接收系统并构建通信连接,接收上传文件命令并根据其构建数据连接;
11.基于所述数据连接利用所述网闸的接收系统基于tcp传输协议接收上传的业务文件数据并按照文件数据上传顺序进行编号;
12.启动预设数据预设数据缓存队列并按照编号顺序将业务文件数据发送到所述预设数据缓存队列中进行缓存;
13.接收上传文件数据完毕后确定最后数据编号并销毁数据连接。
14.优选的,所述使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中,包括:
15.获取每个编号数据的数据头协议并确定其协议格式;
16.根据每个编号数据的协议格式确定该编号数据的当前协议数据格式;
17.获取网闸的接收系统的配置文件,根据所述配置文件确定网闸的接收系统可读取的私有协议数据格式;
18.将每个编号数据的当前协议数据格式转化为私有协议数据格式以进行数据封装,根据封装结果生成发送数据并将其写入到单向数据传输通道中。
19.优选的,所述利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据,包括:
20.生成数据发送指令同时在所述网闸的发送系统生成数据接收指令;
21.确定所述数据发送指令和数据接收指令是否匹配,若是,将所述发送数据上传到网闸的发送系统中;
22.检测所述发送数据中是否存在重复数据,若是,将重复数据进行剔除处理,获取处理后的发送数据;
23.将处理后的发送数据插入到一级数据缓存序列中获取输出数据。
24.优选的,所述基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送,包括:
25.确定输出数据中编号数据的最大数据长度,基于所述最大数据长度设置临时缓存数据长度阈值,同时调取二级数据缓存序列作为临时缓存数据池;
26.获取首个输出数据的第一目标编号,基于所述保序算法确定所述第一目标编号是否为期待编号,若是,将首个输出数据传输到待发送数据序列中;
27.若否,将首个输出数据存储到二级数据缓存序列中,同时对后续输出数据进行重复编号判断和二级数据缓存序列存储处理直到输出数据为所述期待编号为止;
28.在将期待编号的输出数据传输到待发送数据序列后,优先从二级数据缓存序列中获取后续期待编号对应数据以实现将所有输出数据有序传输到待发送数据序列中。
29.将待发送数据序列中的所有输出数据发送到数据接收服务器中。
30.一种提高单向传输系统中数据传输可靠性的系统,该系统包括:
31.缓存模块,用于利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;
32.生成模块,用于使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;
33.插入模块,用于利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;
34.发送模块,用于基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。
35.优选的,所述缓存模块,包括:
36.构建子模块,用于生成通信连接指令并传输到所述网闸的接收系统并构建通信连
接,接收数据发送端发送的上传文件命令并根据其构建数据连接;
37.接收子模块,用于基于所述数据连接利用所述网闸的接收系统基于tcp传输协议接收上传的业务文件数据并按照文件数据上传顺序进行编号;
38.缓存子模块,用于启动预设数据预设数据缓存队列并按照编号顺序将业务文件数据发送到所述预设数据缓存队列中进行缓存;
39.销毁子模块,用于接收上传文件数据完毕后确定最后数据编号并销毁数据连接。
40.优选的,所述生成模块,包括:
41.第一确定子模块,用于获取每个编号数据的数据头协议并确定其协议格式;
42.第二确定子模块,用于根据每个编号数据的协议格式确定该编号数据的当前协议数据格式;
43.第三确定子模块,用于获取网闸的接收系统的配置文件,根据所述配置文件确定网闸的接收系统可读取的私有协议数据格式;
44.第一生成子模块,用于将每个编号数据的当前协议数据格式转化为私有协议数据格式以进行数据封装,根据封装结果生成发送数据并将其写入到单向数据传输通道中。
45.优选的,所述插入模块,包括:
46.第二生成子模块,用于生成数据发送指令同时在所述网闸的发送系统生成数据接收指令;
47.上传子模块,用于确定所述数据发送指令和数据接收指令是否匹配,若是,将所述发送数据上传到网闸的发送系统中;
48.处理子模块,用于检测所述发送数据中是否存在重复数据,若是,将重复数据进行剔除处理,获取处理后的发送数据;
49.插入子模块,用于将处理后的发送数据插入到一级数据缓存序列中获取输出数据。
50.优选的,所述发送模块,包括:
51.第四确定子模块,用于确定输出数据中编号数据的最大数据长度,基于所述最大数据长度设置临时缓存数据长度阈值,同时调取二级数据缓存序列作为临时缓存数据池;
52.第五确定子模块,用于获取首个输出数据的第一目标编号,基于所述保序算法确定所述第一目标编号是否为期待编号,若是,将首个输出数据传输到待发送数据序列中;
53.存储子模块,用于若否,将首个输出数据存储到二级数据缓存序列中,同时对后续输出数据进行重复编号判断和二级数据缓存序列存储处理直到输出数据为所述期待编号为止;
54.传输子模块,用于在将期待编号的输出数据传输到待发送数据序列后,优先从二级数据缓存序列中获取后续期待编号对应数据以实现将所有输出数据有序传输到待发送数据序列中;
55.发送子模块,用于将待发送数据序列中的所有输出数据发送到数据接收服务器中。
56.本发明的其它特征和优点将在随后的说明书中阐述,并且,部分地从说明书中变得显而易见,或者通过实施本发明而了解。本发明的目的和其他优点可通过在所写的说明书以及附图中所特别指出的结构来实现和获得。
57.下面通过附图和实施例,对本发明的技术方案做进一步的详细描述。
附图说明
58.附图用来提供对本发明的进一步理解,并且构成说明书的一部分,与本发明的实施例一起用于解释本发明,并不构成对本发明的限制。
59.图1为本发明所提供的一种提高单向传输系统中数据传输可靠性的方法的工作流程图;
60.图2为本发明所提供的一种提高单向传输系统中数据传输可靠性的方法的另一工作流程图;
61.图3为本发明所提供的一种提高单向传输系统中数据传输可靠性的方法的实施例截图;
62.图4为本发明所提供的一种提高单向传输系统中数据传输可靠性的系统的结构示意图;
63.图5为本发明所提供的一种提高单向传输系统中数据传输可靠性的系统中缓存模块的结构示意图。
具体实施方式
64.这里将详细地对示例性实施例进行说明,其示例表示在附图中。下面的描述涉及附图时,除非另有表示,不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本公开相一致的所有实施方式。相反,它们仅是与如所附权利要求书中所详述的、本公开的一些方面相一致的装置和方法的例子。
65.目前,在采用2+1系统架构的网络隔离设备中,设备由发送系统、接收系统和交换通道三个部分组成,在隔离数据交换过程中,很多业务场景要求数据的有序性,业务数据经过隔离交换设备后需要保证业务数据的先后顺序,但业务数据在隔离产品设备的交换过程中,因采用第三方软硬件,如操作系统、交换通道硬件、网络驱动和传输协议等因素,无法保证隔离交换数据通过接收系统、交换通道、发送系统后业务数据发送次序与进入接收系统数据顺序相同,若不对隔离交换过程进行管理,无法保证接收文件数据包的顺序性从而导致服务器收到的业务数据可能前后错乱,进而导致数据交换业务失败,降低了数据传输稳定性。为了解决上述问题,本实施例公开了一种提高单向传输系统中数据传输可靠性的方法。
66.一种提高单向传输系统中数据传输可靠性的方法,如图1所示,包括以下步骤:
67.步骤s101、利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;
68.步骤s102、使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;
69.步骤s103、利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;
70.步骤s104、基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。
71.在本实施例中,数据编号表示为待传输业务数据按照传送时间点先后顺序进行设置的数据包编号;
72.在本实施例中,数据封装表示为将缓存业务数据封装为特定协议的数据包;
73.在本实施例中,单向数据传输通道表示为尽可通过一端向另一端进行单向数据传输的传输通道;
74.在本实施例中,保序算法表示为在将发送数据输出时保证与接收时一致顺序的算法。
75.上述技术方案的工作原理为:利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。
76.上述技术方案的有益效果为:通过在接收数据时对数据进行编号然后进行数据缓存进而通过保序算法将其发送到数据接收服务器可以使得服务器所接收的业务数据的顺序性与设备上传时保持一致,避免了数据紊乱情况的发生,提高了业务数据上传的稳定性,解决了现有技术中不对隔离交换过程进行管理,无法保证接收文件数据包的顺序性从而导致服务器收到的业务数据可能前后错乱,进而导致数据交换业务失败,降低了数据传输稳定性的问题。
77.在一个实施例中,如图2所示,所述利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存,包括:
78.步骤s201、生成通信连接指令并传输到所述网闸的接收系统并构建通信连接,接收上传文件命令并根据其构建数据连接;
79.步骤s202、基于所述数据连接利用所述网闸的接收系统基于tcp传输协议接收上传的业务文件数据并按照文件数据上传顺序进行编号;
80.步骤s203、启动预设数据预设数据缓存队列并按照编号顺序将业务文件数据发送到所述预设数据缓存队列中进行缓存;
81.步骤s204、接收上传文件数据完毕后确定最后数据编号并销毁数据连接。
82.上述技术方案的有益效果为:通过构建数据连接并使用tcp传输协议接收传输数据可以保证数据传输的稳定性和可靠性以及有序性,进一步地,通过将接收业务文件数据进行缓存可以保证接收数据的完整性,提高了实用性,进一步地,通过自适应销毁数据连接可以避免数据遗漏情况的发生,提高了数据安全性和稳定性。
83.在本实施例中,启动预设数据预设数据缓存队列并按照编号顺序将业务文件数据发送到所述预设数据缓存队列中进行缓存,包括:
84.生成所述预设数据缓存队列的启动指令,响应所述启动指令启动预设数据预设数据缓存队列;
85.检测所述预设数据缓存队列的缓存空间容量和业务文件数据的数据块长度;
86.基于所述预设数据缓存队列的缓存空间容量和业务文件数据的数据块长度生成虚拟内存分配策略;
87.根据所述虚拟内存分配策略确定预设数据缓存队列的多个缓存节点以及每个缓存节点的对冲数据流;
88.获取所述业务文件数据对应的数据序列,根据所述数据序列和每个缓存节点的对冲数据流确定每个缓存节点的缓存数据项;
89.确定每个缓存节点的数据缓存条件,基于所述数据缓存条件判断每个缓存节点的缓存数据项是否符合缓存状态,获取判断结果;
90.根据所述判断结果选择性地对每个缓存节点的缓存数据项的状态属性值进行自适应调节处理,获取处理后的缓存数据项;
91.根据每个缓存节点的处理后的缓存数据项配置数据缓存进程,获取配置结果;
92.基于配置结果将业务文件数据发送到所述预设数据缓存队列中进行缓存,检测在发送过程中的数据传输带宽变化值区间;
93.根据所述数据传输带宽变化值区间构建数据传输带宽变化曲线,确定所述数据传输带宽变化曲线的曲线特性;
94.通过所述曲线特性确定对于业务文件数据的当前传输效率,若所述当前传输效率小于预设传输效率,将预设数据缓存队列中的原始数据导入到机械硬盘中以释放缓存空间。
95.在本实施例中,缓存空间容量表示为预设数据缓存队列可进行数据存储的空间容量;
96.在本实施例中,虚拟内存分配策略表示为针对业务文件数据在预设数据缓存队列中的缓存内存的分配策略;
97.在本实施例中,缓存节点表示为预设数据缓存队列在对业务文件数据进行缓存时需要用到的网络节点;
98.在本实施例中,对冲流数据表示为每个网络节点需要接收和缓存的数据流;
99.在本实施例中,数据序列表示为业务文件数据按照序列号进行排序后的总数据;
100.在本实施例中,缓存数据项表示为每个缓存节点的待缓存数据的具体项;
101.在本实施例中,数据缓存条件表示为每个缓存节点对于待缓存数据的格式参数限定条件;
102.在本实施例中,状态属性值表示为缓存数据项的形态表现属性值。
103.上述技术方案的有益效果为:既可以保证对于业务文件数据的稳定接收缓存同时还可以保证数据在缓存过程前后的一致性,提高了稳定性和可靠性,进一步地,通过自适应释放预设数据缓存队列的缓存空间容量可以进一步地保证缓存完整性,同时也提高了缓存效率,提高了整体的稳定性和实用性。
104.在一个实施例中,所述使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中,包括:
105.获取每个编号数据的数据头协议并确定其协议格式;
106.根据每个编号数据的协议格式确定该编号数据的当前协议数据格式;
107.获取网闸的接收系统的配置文件,根据所述配置文件确定网闸的接收系统可读取的私有协议数据格式;
108.将每个编号数据的当前协议数据格式转化为私有协议数据格式以进行数据封装,
根据封装结果生成发送数据并将其写入到单向数据传输通道中。
109.上述技术方案的有益效果为:通过进行协议数据格式转换可以快速地生成私有协议的封装数据,提高了数据封装效率,同时也保证了数据的隐私性,进一步地,通过使用单向数据传输通道进行数据传输可以保证数据在传输过程中的稳定性,避免数据紊乱情况的发生,提高了实用性。
110.在一个实施例中,所述利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据,包括:
111.生成数据发送指令同时在所述网闸的发送系统生成数据接收指令;
112.确定所述数据发送指令和数据接收指令是否匹配,若是,将所述发送数据上传到网闸的发送系统中;
113.检测所述发送数据中是否存在重复数据,若是,将重复数据进行剔除处理,获取处理后的发送数据;
114.将处理后的发送数据插入到一级数据缓存序列中获取输出数据。
115.上述技术方案的有益效果为:通过剔除重复数据可以保证发送数据的完整性和可靠性,同时避免了数据紊乱的概率,进一步地提高了实用性,进一步地,通过判定数据的指令匹配可以进一步地确定对于发送数据传输的设备保证性。保证了发送数据的隐私性和安全性。
116.在一个实施例中,所述基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送,包括:
117.确定输出数据中编号数据的最大数据长度,基于所述最大数据长度设置临时缓存数据长度阈值,同时调取二级数据缓存序列作为临时缓存数据池;
118.获取首个输出数据的第一目标编号,基于所述保序算法确定所述第一目标编号是否为期待编号,若是,将首个输出数据传输到待发送数据序列中;
119.若否,将首个输出数据存储到二级数据缓存序列中,同时对后续输出数据进行重复编号判断和二级数据缓存序列存储处理直到输出数据为所述期待编号为止;
120.在将期待编号的输出数据传输到待发送数据序列后,优先从二级数据缓存序列中获取后续期待编号对应数据以实现将所有输出数据有序传输到待发送数据序列中。
121.将待发送数据序列中的所有输出数据发送到数据接收服务器中。
122.上述技术方案的有益效果为:可以有序地将所有业务数据进行上传,进一步地保证了服务器所接收的业务数据的顺序性与设备上传时保持一致,提高了业务数据传输的稳定性和可靠性。
123.在一个实施例中,如图3所示,本设计方案通过增加管理消息对网络隔离设备接收系统、发送系统和传输通道进行控制管理,在接收系统中业务数据接收模块使用tcp传输协议接收有序数据,然后使用预设数据缓存队列对有序数据进行缓存,队列使用先进先出原则,保证数据写入传输通道的顺序性,从而尽可能保证发送系统从传输通道接收的数据包基本有序;在发送系统中从传输通道读取数据,将数据放入预设数据缓存队列,然后通过保序算法保证发送系统数据转发顺序的正确性,然后使用tcp传输协议发送有序数据。
124.其中,保序算法具体的实施步骤为:
125.1.准备有序数据发送,默认起始数据期待编号为1,临时缓存数据长度阈值默认为
100;
126.2.获取发送数据;
127.3.检查数据编号是否为期待编号,若是期待编号则转交业务发送服务,期待编号加1;若不是期待编号则将数据临时缓存,则转步骤2;
128.4.检查临时缓存数据数,若为0则跳转步骤2;
129.5.检查临时缓存是否有期待数据,有则获取数据转交业务发送服务,期待编号加1,跳转步骤4;若无检查临时缓存数据数大于阈值,则期待编号加1;跳转步骤4;否则转步骤2。
130.关于tcp协议数据有序保障:
131.(1)接收系统处理流程描述
132.接收系统业务数据接收模块使用tcp传输协议接收有序数据,并获取数据编号,默认接收第一个数据编号为1;
133.接收系统tcp协议数据接收模块剥离协议头获取tcp数据;
134.接收系统封装私有协议数据格式,并填充数据编号,插入先进先出缓存队列;
135.接收系统交换通道发送工作线程获取发送数据;
136.接收系统将发送数据写入交换通道两次;
137.(2)发送系统处理流程描述
138.发送系统从交换通道读取隔离交换数据;
139.发送系统解析私有协议数据格式,获取tcp数据和数据编号,并插入一级缓存队列;
140.发送系统从一级缓存队列中获取tcp数据并删除重复数据,并插入二级缓存队列;
141.发送系统从二级缓存队列获取数据,根据保序算法发送数据。
142.本方案设计通过在tcp协议数据根据编号和保序算法保障有序数据的收发,ftp文件传输中使用管理消息开始消息、传输消息和结束/取消消息和基于数据编号的保序算法来控制管理有序数据包的收发,保证了隔离设备接收和发送出去的业务数据序列的正确性,消除了隔离交换有序数据因第三方软硬件导致的数据乱序,完全保证了隔离交换对有序数据交换的序列的正确性,从而保证了具有有序数据的业务正确性。
143.本实施例还公开了一种提高单向传输系统中数据传输可靠性的系统,如图4所示,该系统包括:
144.缓存模块401,用于利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;
145.生成模块402,用于使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;
146.插入模块403,用于利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;
147.发送模块404,用于基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。
148.上述技术方案的工作原理为:首先利用缓存模块利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;其次基于生成模块使用私
有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;然后使用插入模块利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;最后通过发送模块基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。
149.上述技术方案的有益效果为:通过在接收数据时对数据进行编号然后进行数据缓存进而通过保序算法将其发送到数据接收服务器可以使得服务器所接收的业务数据的顺序性与设备上传时保持一致,避免了数据紊乱情况的发生,提高了业务数据上传的稳定性。
150.在一个实施例中,如图5所示,所述缓存模块401,包括:
151.构建子模块4011,用于生成通信连接指令并传输到所述网闸的接收系统并构建通信连接,接收数据发送端发送的上传文件命令并根据其构建数据连接;
152.接收子模块4012,用于基于所述数据连接利用所述网闸的接收系统基于tcp传输协议接收上传的业务文件数据并按照文件数据上传顺序进行编号;
153.缓存子模块4013,用于启动预设数据预设数据缓存队列并按照编号顺序将业务文件数据发送到所述预设数据缓存队列中进行缓存;
154.销毁子模块4014,用于接收上传文件数据完毕后确定最后数据编号并销毁数据连接。
155.上述技术方案的有益效果为:通过构建数据连接并使用tcp传输协议接收传输数据可以保证数据传输的稳定性和可靠性以及有序性,进一步地,通过将接收业务文件数据进行缓存可以保证接收数据的完整性,提高了实用性,进一步地,通过自适应销毁数据连接可以避免数据遗漏情况的发生,提高了数据安全性和稳定性。
156.在一个实施例中,所述生成模块,包括:
157.第一确定子模块,用于获取每个编号数据的数据头协议并确定其协议格式;
158.第二确定子模块,用于根据每个编号数据的协议格式确定该编号数据的当前协议数据格式;
159.第三确定子模块,用于获取网闸的接收系统的配置文件,根据所述配置文件确定网闸的接收系统可读取的私有协议数据格式;
160.第一生成子模块,用于将每个编号数据的当前协议数据格式转化为私有协议数据格式以进行数据封装,根据封装结果生成发送数据并将其写入到单向数据传输通道中。
161.上述技术方案的有益效果为:通过进行协议数据格式转换可以快速地生成私有协议的封装数据,提高了数据封装效率,同时也保证了数据的隐私性,进一步地,通过使用单向数据传输通道进行数据传输可以保证数据在传输过程中的稳定性,避免数据紊乱情况的发生,提高了实用性。
162.在一个实施例中,所述插入模块,包括:
163.第二生成子模块,用于生成数据发送指令同时在所述网闸的发送系统生成数据接收指令;
164.上传子模块,用于确定所述数据发送指令和数据接收指令是否匹配,若是,将所述发送数据上传到网闸的发送系统中;
165.处理子模块,用于检测所述发送数据中是否存在重复数据,若是,将重复数据进行剔除处理,获取处理后的发送数据;
166.插入子模块,用于将处理后的发送数据插入到一级数据缓存序列中获取输出数据。
167.上述技术方案的有益效果为:通过剔除重复数据可以保证发送数据的完整性和可靠性,同时避免了数据紊乱的概率,进一步地提高了实用性,进一步地,通过判定数据的指令匹配可以进一步地确定对于发送数据传输的设备保证性。保证了发送数据的隐私性和安全性。
168.在一个实施例中,所述发送模块,包括:
169.第四确定子模块,用于确定输出数据中编号数据的最大数据长度,基于所述最大数据长度设置临时缓存数据长度阈值,同时调取二级数据缓存序列作为临时缓存数据池;
170.第五确定子模块,用于获取首个输出数据的第一目标编号,基于所述保序算法确定所述第一目标编号是否为期待编号,若是,将首个输出数据传输到待发送数据序列中;
171.存储子模块,用于若否,将首个输出数据存储到二级数据缓存序列中,同时对后续输出数据进行重复编号判断和二级数据缓存序列存储处理直到输出数据为所述期待编号为止;
172.传输子模块,用于在将期待编号的输出数据传输到待发送数据序列后,优先从二级数据缓存序列中获取后续期待编号对应数据以实现将所有输出数据有序传输到待发送数据序列中;
173.发送子模块,用于将待发送数据序列中的所有输出数据发送到数据接收服务器中。
174.上述技术方案的有益效果为:可以有序地将所有业务数据进行上传,进一步地保证了服务器所接收的业务数据的顺序性与设备上传时保持一致,提高了业务数据传输的稳定性和可靠性。
175.本领域技术人员应当理解的是,本发明中的第一、第二指的是不同应用阶段而已。
176.本领域技术用户员在考虑说明书及实践这里公开的公开后,将容易想到本公开的其它实施方案。本技术旨在涵盖本公开的任何变型、用途或者适应性变化,这些变型、用途或者适应性变化遵循本公开的一般性原理并包括本公开未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的,本公开的真正范围和精神由下面的权利要求指出。
177.应当理解的是,本公开并不局限于上面已经描述并在附图中示出的精确结构,并且可以在不脱离其范围进行各种修改和改变。本公开的范围仅由所附的权利要求来限制。

技术特征:
1.一种提高单向传输系统中数据传输可靠性的方法,其特征在于,包括以下步骤:利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。2.根据权利要求1所述提高单向传输系统中数据传输可靠性的方法,其特征在于,所述利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存,包括:生成通信连接指令并传输到所述网闸的接收系统并构建通信连接,接收上传文件命令并根据其构建数据连接;基于所述数据连接利用所述网闸的接收系统基于tcp传输协议接收上传的业务文件数据并按照文件数据上传顺序进行编号;启动预设数据预设数据缓存队列并按照编号顺序将业务文件数据发送到所述预设数据缓存队列中进行缓存;接收上传文件数据完毕后确定最后数据编号并销毁数据连接。3.根据权利要求1所述提高单向传输系统中数据传输可靠性的方法,其特征在于,所述使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中,包括:获取每个编号数据的数据头协议并确定其协议格式;根据每个编号数据的协议格式确定该编号数据的当前协议数据格式;获取网闸的接收系统的配置文件,根据所述配置文件确定网闸的接收系统可读取的私有协议数据格式;将每个编号数据的当前协议数据格式转化为私有协议数据格式以进行数据封装,根据封装结果生成发送数据并将其写入到单向数据传输通道中。4.根据权利要求1所述提高单向传输系统中数据传输可靠性的方法,其特征在于,所述利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据,包括:生成数据发送指令同时在所述网闸的发送系统生成数据接收指令;确定所述数据发送指令和数据接收指令是否匹配,若是,将所述发送数据上传到网闸的发送系统中;检测所述发送数据中是否存在重复数据,若是,将重复数据进行剔除处理,获取处理后的发送数据;将处理后的发送数据插入到一级数据缓存序列中获取输出数据。5.根据权利要求1所述提高单向传输系统中数据传输可靠性的方法,其特征在于,所述基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待
编号将所有输出数据进行有序发送,包括:确定输出数据中编号数据的最大数据长度,基于所述最大数据长度设置临时缓存数据长度阈值,同时调取二级数据缓存序列作为临时缓存数据池;获取首个输出数据的第一目标编号,基于所述保序算法确定所述第一目标编号是否为期待编号,若是,将首个输出数据传输到待发送数据序列中;若否,将首个输出数据存储到二级数据缓存序列中,同时对后续输出数据进行重复编号判断和二级数据缓存序列存储处理直到输出数据为所述期待编号为止;在将期待编号的输出数据传输到待发送数据序列后,优先从二级数据缓存序列中获取后续期待编号对应数据以实现将所有输出数据有序传输到待发送数据序列中;将待发送数据序列中的所有输出数据发送到数据接收服务器中。6.一种提高单向传输系统中数据传输可靠性的系统,其特征在于,该系统包括:缓存模块,用于利用网闸的接收系统基于tcp传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;生成模块,用于使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;插入模块,用于利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;发送模块,用于基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。7.根据权利要求6所述提高单向传输系统中数据传输可靠性的系统,其特征在于,所述缓存模块,包括:构建子模块,用于生成通信连接指令并传输到所述网闸的接收系统并构建通信连接,接收数据发送端发送的上传文件命令并根据其构建数据连接;接收子模块,用于基于所述数据连接利用所述网闸的接收系统基于tcp传输协议接收上传的业务文件数据并按照文件数据上传顺序进行编号;缓存子模块,用于启动预设数据预设数据缓存队列并按照编号顺序将业务文件数据发送到所述预设数据缓存队列中进行缓存;销毁子模块,用于接收上传文件数据完毕后确定最后数据编号并销毁数据连接。8.根据权利要求6所述提高单向传输系统中数据传输可靠性的系统,其特征在于,所述生成模块,包括:第一确定子模块,用于获取每个编号数据的数据头协议并确定其协议格式;第二确定子模块,用于根据每个编号数据的协议格式确定该编号数据的当前协议数据格式;第三确定子模块,用于获取网闸的接收系统的配置文件,根据所述配置文件确定网闸的接收系统可读取的私有协议数据格式;第一生成子模块,用于将每个编号数据的当前协议数据格式转化为私有协议数据格式以进行数据封装,根据封装结果生成发送数据并将其写入到单向数据传输通道中。9.根据权利要求6所述提高单向传输系统中数据传输可靠性的系统,其特征在于,所述插入模块,包括:
第二生成子模块,用于生成数据发送指令同时在所述网闸的发送系统生成数据接收指令;上传子模块,用于确定所述数据发送指令和数据接收指令是否匹配,若是,将所述发送数据上传到网闸的发送系统中;处理子模块,用于检测所述发送数据中是否存在重复数据,若是,将重复数据进行剔除处理,获取处理后的发送数据;插入子模块,用于将处理后的发送数据插入到一级数据缓存序列中获取输出数据。10.根据权利要求6所述提高单向传输系统中数据传输可靠性的系统,其特征在于,所述发送模块,包括:第四确定子模块,用于确定输出数据中编号数据的最大数据长度,基于所述最大数据长度设置临时缓存数据长度阈值,同时调取二级数据缓存序列作为临时缓存数据池;第五确定子模块,用于获取首个输出数据的第一目标编号,基于所述保序算法确定所述第一目标编号是否为期待编号,若是,将首个输出数据传输到待发送数据序列中;存储子模块,用于若否,将首个输出数据存储到二级数据缓存序列中,同时对后续输出数据进行重复编号判断和二级数据缓存序列存储处理直到输出数据为所述期待编号为止;传输子模块,用于在将期待编号的输出数据传输到待发送数据序列后,优先从二级数据缓存序列中获取后续期待编号对应数据以实现将所有输出数据有序传输到待发送数据序列中;发送子模块,用于将待发送数据序列中的所有输出数据发送到数据接收服务器中。

技术总结
本发明公开了一种提高单向传输系统中数据传输可靠性的方法及系统,其方法包括:利用网闸的接收系统基于TCP传输协议获取待传输业务数据同时对其设置数据编号并进行缓存;使用私有协议对缓存业务数据进行数据封装以生成发送数据,将所述发送数据写入到单向数据传输通道中;利用网闸的发送系统接收发送数据并将发送数据插入到一级数据缓存序列中获取输出数据;基于预设保序算法选择性地将输出数据进行发送或插入到二级数据缓存序列中,根据期待编号将所有输出数据进行有序发送。通过保序算法将发送数据发送到数据接收服务器可以使得服务器所接收的业务数据的顺序性与设备上传时保持一致,避免了数据紊乱情况的发生,提高了业务数据上传的稳定性。了业务数据上传的稳定性。了业务数据上传的稳定性。


技术研发人员:张凯 王志明 张冬
受保护的技术使用者:北京连山科技股份有限公司
技术研发日:2023.06.06
技术公布日:2023/8/24
版权声明

本文仅代表作者观点,不代表航空之家立场。
本文系作者授权航家号发表,未经原创作者书面授权,任何单位或个人不得引用、复制、转载、摘编、链接或以其他任何方式复制发表。任何单位或个人在获得书面授权使用航空之家内容时,须注明作者及来源 “航空之家”。如非法使用航空之家的部分或全部内容的,航空之家将依法追究其法律责任。(航空之家官方QQ:2926969996)

飞行汽车 https://www.autovtol.com/

分享:

扫一扫在手机阅读、分享本文

相关推荐