CN114827260B - 一种数据传输方法及相关装置 - Google Patents
一种数据传输方法及相关装置 Download PDFInfo
- Publication number
- CN114827260B CN114827260B CN202210384489.1A CN202210384489A CN114827260B CN 114827260 B CN114827260 B CN 114827260B CN 202210384489 A CN202210384489 A CN 202210384489A CN 114827260 B CN114827260 B CN 114827260B
- Authority
- CN
- China
- Prior art keywords
- component
- packet
- data
- proxy
- data receiving
- 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.)
- Active
Links
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本申请实施例提供了一种数据传输方法及相关装置，数据发送组件的代理组件获取数据发送组件发送的原始数据包和数据接收组件的标识，在依据预设的判别条件确定数据接收组件的代理组件的运行状态正常的情况下，基于原始数据包生成代理数据包，并将代理数据包发送至数据接收组件的代理组件，以使数据接收组件的代理组件转发原始数据包至数据接收组件。在依据判别条件确定数据接收组件的代理组件的运行状态异常的情况下，将原始数据包发送至数据接收组件。可见，本方案通过依据数据接收组件的代理组件的运行状态，切换原始数据包的接收方，避免由于数据接收组件的代理组件的运行异常导致的原始数据包的发送失败，从而提高了数据传输的稳定性。
Description
技术领域
本申请涉及数据处理技术领域，尤其涉及一种数据传输方法及相关装置。
背景技术
在微服务系统中，为每一微服务配置对应的代理组件，目的在于实现对微服务的数据监控和数据转发，但是当代理组件出现运行异常时，往往导致微服务间无法通信，进而影响整个微服务系统的运行稳定性。
发明内容
本申请提供了一种数据传输方法及相关装置，如下：
一种数据传输方法，应用于数据发送组件的代理组件，包括：
获取原始数据包和数据接收组件的标识，所述原始数据包由所述数据发送组件发送；
在依据预设的判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件，以使所述数据接收组件的代理组件转发所述原始数据包至所述数据接收组件；
在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件；
所述判别条件包括：在第一预设时长内接收到应答包，且所述应答包满足应答规则，所述应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送，所述问询包包括用于所述数据接收组件的代理组件生成所述应答包的应答规则。
可选地，应答规则包括：
第一预设字段的字段值等于第一标准值，所述第一标准值为指示所述运行状态为正常的预设值。
可选地，本方法还包括：
周期性地发送所述问询包至所述数据接收组件的代理组件；
若在任意周期发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足所述应答规则，标记所述任意周期的状态标识为异常。
可选地，依据所述判别条件确定所述数据接收组件的代理组件的运行状态是否正常的过程，包括：
获取历史周期的状态标识；
若所述历史周期的状态标识满足异常条件，确定所述数据接收组件的代理组件的运行状态异常，所述异常条件包括：最近连续n个周期的状态标识为异常，和/或状态标识为异常的周期的数量大于预设的数量阈值，其中，所述n为预设数值。
可选地，在所述获取原始数据包和数据接收组件的标识之后，还包括：
若确定所述历史周期的状态标识满足所述异常条件，发送所述问询包至所述数据接收组件的代理组件；
若在所述发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足应答规则，确定所述数据接收组件的代理组件的运行状态异常；
若在所述发送所述问询包后的所述第一预设时长内接收到的应答包满足应答规则，确定所述数据接收组件的代理组件的运行状态正常。
可选地，将所述代理数据包发送至所述数据接收组件的代理组件之后，还包括：
接收响应包，所述响应包由所述数据接收组件的代理组件响应于接收到所述代理数据包生成；
判断所述响应包中的预设字段的字段值是否等于第二标准值，所述第二标准值；所述响应包用于反馈所述数据接收组件的代理组件是否成功转发所述原始数据包至所述数据接收组件，所述第二标准值为指示成功转发的预设值；
若否，将所述原始数据包发送至所述数据接收组件。
一种数据传输装置，包括：
数据接收单元，用于获取原始数据包和数据接收组件的标识，所述原始数据包由所述数据发送组件发送；
第一数据发送单元，用于在依据预设的判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件，以使所述数据接收组件的代理组件转发所述原始数据包至所述数据接收组件；
第二数据发送单元，用于在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件；
所述判别条件包括：在第一预设时长内接收到应答包，且所述应答包满足应答规则，所述应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送，所述问询包包括用于所述数据接收组件的代理组件生成所述应答包的应答规则。
一种数据传输系统，包括：数据发送组件、所述数据发送组件的代理组件、数据接收组件的代理组件、和所述数据接收组件；
所述数据发送组件用于发送原始数据包至所述数据发送组件的代理组件；
所述数据发送组件的代理组件用于：
获取所述原始数据包和所述数据接收组件的标识；
在依据预设的判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件；
在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件；
所述判别条件包括：在第一预设时长内接收到应答包，且所述应答包满足应答规则，所述应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送，所述问询包包括用于所述数据接收组件的代理组件生成所述应答包的应答规则。
所述数据接收组件的代理组件用于基于所述代理数据包，获取并转发所述原始数据包至所述数据接收组件。
一种数据传输设备，包括：存储器和处理器；
所述存储器，用于存储程序；
所述处理器，用于执行所述程序，实现数据传输方法的各个步骤。
一种可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时，实现数据传输方法的各个步骤。
由上述技术方案可以看出，本申请实施例提供的数据传输方法及相关装置，数据发送组件的代理组件获取数据发送组件发送的原始数据包和数据接收组件的标识，在依据预设的判别条件确定数据接收组件的代理组件的运行状态正常的情况下，基于原始数据包生成代理数据包，并将代理数据包发送至数据接收组件的代理组件，以使数据接收组件的代理组件转发原始数据包至数据接收组件。在依据判别条件确定数据接收组件的代理组件的运行状态异常的情况下，将原始数据包发送至数据接收组件。其中，判别条件包括：在第一预设时长内接收到应答包，且应答包满足应答规则，由于，应答包为数据接收组件的代理组件响应于接收到数据发送组件的代理组件发送的问询包生成并发送，其中，问询包包括用于数据接收组件的代理组件生成应答包的应答规则。因此，判定条件用于确定数据接收组件的代理组件是否成功接收并解析问询包以及是否运行正常。可见，本方案通过依据数据接收组件的代理组件的运行状态，切换原始数据包的接收方，能够在数据接收组件的代理组件的运行正常情况下，通过数据接收组件的代理组件转发原始数据包，以实现预设的数据控制和流量监控的功能，在数据接收组件的代理组件的运行异常情况下，直接发送原始数据包至数据接收组件，避免由于数据接收组件的代理组件的运行异常导致的原始数据包的发送失败，从而提高了数据传输的稳定性。
附图说明
为了更清楚地说明本申请实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本申请的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
图1为本申请实施例提供的一种数据传输系统的结构示意图；
图2为本申请实施例提供的一种数据传输方法的流程示意图；
图3为本申请实施例提供的一种数据传输方法的具体实施方式的流程示意图；
图4为本申请实施例提供的一种数据传输装置的结构示意图；
图5为本申请实施例提供的一种数据传输设备的结构示意图。
具体实施方式
下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本申请一部分实施例，而不是全部的实施例。基于本申请中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本申请保护的范围。
本申请实施例提供的一种数据传输方法应用于但不限于数据传输系统中各个服务组件之间的数据传输过程，服务组件包括数据发送组件和数据接收组件，图1示例了本申请实施例提供的一种数据传输系统的具体结构示意图，如图1所示，数据传输系统包括数据发送组件101、数据发送组件的代理组件(图1中的第一代理组件)102、数据接收组件的代理组件(图1中的第二代理组件)103、和数据接收组件104。需要说明的是，对应的服务组件和代理组件预先绑定，且设置于同一设备或容器中，具体参见现有技术。
图2示例了本申请实施例提供的一种数据传输方法的流程示意图，如图1所示，本方法包括：
S201、数据发送组件发送原始数据包至数据发送组件的代理组件。
可选地，原始数据包中包括数据接收组件的标识，例如，数据接收组件的名称或者编号。第一代理组件获取原始数据包并发送的方法参见现有技术。
需要说明的是，数据发送组件为服务组件，具体可以为微服务或其他组件，数据发送组件向数据接收组件发送的原始数据包不限于用于调用数据接收组件的服务，本实施例对此不做限定。
S202、数据发送组件的代理组件接收原始数据包和数据接收组件的标识，并依据预设的判别条件确定数据接收组件的代理组件的运行状态是否正常。
本实施例中，运行状态正常指的是数据接收组件的代理组件和数据接收组件的数据传输链路正常运行、且数据接收组件的代理组件和数据发送组件的代理组件的数据传输链路正常运行，也即数据接收组件的代理组件具备接收并解析数据发送组件的代理组件的发送的数据并成功将数据转发到数据接收组件的能力。
本实施例中，判别条件包括：在第一预设时长内接收到应答包，且应答包满足应答规则，应答包为数据接收组件的代理组件响应于接收到数据发送组件的代理组件发送的问询包生成并发送，问询包包括用于数据接收组件的代理组件生成应答包的应答规则。
可选地，具体的应答规则包括多种，一种可选的应答规则包括第一预设字段的字段值等于第一标准值，例如，状态码等于200。另一种可选的应答规则包括用于指示接收到问询包的时间的字段。需要说明的是，判断数据接收组件的代理组件的运行状态是否正常的具体实现方法包括多种，具体可以参见下述实施例。
S203、数据发送组件的代理组件在确定数据接收组件的代理组件的运行状态正常的情况下，基于原始数据包生成代理数据包，并将代理数据包发送至数据接收组件的代理组件。
本实施例中，可选的一种基于原始数据包生成代理数据包的方法包括：使用预设的通信协议对原始数据包进行封装，得到代理数据包，其中，通信协议为数据发送组件的代理组件和数据接收组件的代理组件预先约定的协议。具体的协议约定方法参见现有技术。
S204、数据接收组件的代理组件接收代理数据包，基于代理数据包获取并发送原始数据包至数据接收组件。
本实施例中，数据接收组件的代理组件基于代理数据包获取原始数据包的方法包括基于预设的通信协议解析代理数据包，得到原始数据包。
S205、数据发送组件的代理组件在确定数据接收组件的代理组件的运行状态异常的情况下，将原始数据包发送至数据接收组件。
由上述技术方案可以看出，本申请实施例提供的一种数据传输方法，通过依据数据接收组件的代理组件的运行状态，切换原始数据包的接收方，能够在数据接收组件的代理组件的运行正常情况下，通过数据接收组件的代理组件转发原始数据包，以实现预设的数据控制和流量监控的功能，在数据接收组件的代理组件的运行异常情况下，直接发送原始数据包至数据接收组件，避免由于数据接收组件的代理组件的运行异常导致的原始数据包的发送失败，从而提高了数据传输的稳定性。
图3示例了本申请实施例提供的一种数据接收组件的代理组件的运行状态判别方法的具体实现流程，如图3所示，以数据发送组件的代理组件为第一代理组件，数据接收组件的代理组件为第二代理组件，且应答规则包括第一预设字段的字段值等于第一标准值为例，本方法具体包括：
S301、第一代理组件周期性地发送问询包至第二代理组件。
本实施例中，按照预设规则划分周期，例如，每5秒划分一个周期。具体地，在每一周期指示的发送时间发送问询包至第二代理组件，其中，问询包用于请求数据接收组件的代理组件的运行状态，可选地，问询包包括用于数据接收组件的代理组件生成应答包的应答规则，也即，问询包包括用于指示数据接收组件的代理组件若运行状态正常，则生成的应答包中的第一预设字段的字段值等于第一标准值，其中第一标准值为指示运行状态为正常的预设值。
S302、第二代理组件响应于接收到问询包，判断第二代理组件的运行状态是否正常。
本实施例中，运行状态包括转发状态，转发状态正常表示第二代理组件和数据接收组件的通信链路运行状态正常。第二代理组件判断第二代理组件的转发状态是否正常的方法包括多种，例如，发送预设的测试信息至数据接收组件，若在第二预设时间内接收到数据接收组件反馈的用于应答测试信息的反馈信息，则确定第二代理组件的运行状态正常。
S303、第二代理组件基于运行状态和应答规则，生成应答包，并将应答包发送至第一代理组件。
本实施例中，第二代理组件仅在成功接收并解析问询包且转发状态正常的情况下，生成的应答包中第一预设字段的字段值等于第一标准值。
需要说明的是，第二代理组件在运行状态异常的情况下，生成的应答包中第一预设字段的字段值不等于第一标准值，或者，第二代理组件在运行状态异常的情况下，不执行生成应答包的操作，也即，当第二代理组件运行状态异常，不发送应答包。
S304、第一代理组件在发送问询包后的第一预设时长内接收到应答包，若应答包中第一预设字段的字段值不等于第一标准值，标记对应的周期的状态标识为异常。
本实施例中，第一标准值第一标准值为指示运行状态为正常的预设值，例如，第一预设字段为状态码，第一标准值为200，则若应答包中的状态码不等于200时，标记对应的周期的状态标识为异常。
S305、第一代理组件在发送问询包后的第一预设时长内没有接收到应答包，标记对应的周期的状态标识为异常。
本实施例中，第一代理组件按照周期轮询所有与第一代理组件通信相连的代理组件，针对每一轮询到的代理组件都执行上述S301～S305，得到每一代理组件的每一周期的状态标识，并对应存储至预设数据库中。
S306、第一代理组件响应于接收到原始数据包和数据接收组件的标识，获取历史周期的状态标识。
本实施例中，原始数据包由所述数据发送组件发送，历史周期包括当前时间之前的预设时间段内的周期，例如，获取24小时内的所有周期的的状态标识。需要说明的是，第一代理组件从数据库中获取历史周围的状态标识。
S307、第一代理组件在历史周期的状态标识满足异常条件时，确定第二代理组件的运行状态异常。
本实施例中，异常条件包括：最近连续n个周期的状态标识为异常，或状态标识为异常的周期的数量大于预设的数量阈值，其中，n为预设数值。以n＝3为例且数量阈值＝10为例，当历史周期中距当前时间最近且连续的3个周期的状态标识均为异常，则确定第二代理组件的运行状态异常。或者，历史周期中状态标识为异常的周期的数量大于10，则确定第二代理组件的运行状态异常。
需要说明的是，异常条件可以依据历史运行日志和原始数据包的预设重要等级配置。例如，原始数据包的重要等级高，则为了更稳定的传输原始数据包，将n预设为较小数值，或者，将数量阈值设置为较小数值。
S308、第一代理组件在历史周期的状态标识满足异常条件时，发送问询包至数据接收组件的代理组件。
S309、第一代理组件在发送问询包后的第一预设时长内，没有接收到应答包或者应答包中第一预设字段的字段值不等于第一标准值，确定第二代理组件运行异常。
S310、第一代理组件在发送问询包后的第一预设时长内，接收到的应答包中第一预设字段的字段值等于第一标准值，确定第二代理组件运行状态正常。
由上述技术方案可以看出，本申请实施例提供的第二代理组件的运行状态的获取方法，通过周期性问询数据接收组件的代理组件的运行状态并标记，在接收到原始数据包和数据接收组件的标识后，获取数据接收组件的代理组件的状态标识，在通过状态标识和异常条件判断数据接收组件的代理组件当前时间的运行状态为异常时，无需等待数据接收组件的代理组件的即时应答，确定数据接收组件的代理组件的运行状态异常，提高了数据传输的速度。进一步，依据历史周期内的数据接收组件的代理组件的运行状态，能够更准确的判定当前时间下的数据接收组件的代理组件的运行状态。
进一步，在不能通过状态标识和异常条件判断数据接收组件的代理组件当前时间的运行状态为异常时，通过即时发送问询包，确定数据接收组件的代理组件的运行状态是否正常，能够进一步提高运行状态的判断准确性。
需要说明的是，上述实施例仅为本实施例提供的一种数据传输方法可选的具体实现方式，本申请还包括其他的具体实现方式。
例如，本方法还包括第一代理组件在发送问询包后的第一预设时长内接收到的应答包中的第一预设字段的字段值等于第一标准值，则标记对应的周期的状态标识为正常，则S304中，还可以根据历史周期的状态标识为正常的规律及特征，判断第二代理组件运行状态是否正常，具体参见现有技术，本实施例不做赘述。再例如，图3仅示例了一种可选的应答规则，问询包中的应答规则包括多种，例如，应答规则包括规则码，规则码用于指示预设的规则中的一种，预设的规则和规则码的对应关系预先存储。也即，应答规则为动态规则。
再例如，本方法还包括依据响应条件，确定第二代理组件的是否正常的步骤，具体包括：
1、第一代理组件发送代理数据包至第二代理组件之后，接收响应包。
本实施例中，响应包由第二代理组件响应于接收到代理数据包生成。响应包用于反馈数据接收组件的代理组件是否成功转发原始数据包述数据接收组件，生成响应包的具体方法参见现有技术。
2、判断响应包中的第二预设字段的字段值是否等于第二标准值。
本实施例中，第二标准值为指示成功转发的预设值。
3、若否，第一代理组件将原始数据包发送至数据接收组件。
可见，在发送代理数据包后，仍可以通过接收的响应包判断数据接收组件的代理组件的运行状态是否正常，实现运行转态的被动探测，能够进一步提高数据传输的稳定性和运行状态的判断结果的实时性。
图4示出了本申请实施例提供的一种数据传输装置的结构示意图，如图4所示，该装置可以包括：
数据接收单元，用于获取原始数据包和数据接收组件的标识，所述原始数据包由所述数据发送组件发送；
第一数据发送单元，用于在依据预设的判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件，以使所述数据接收组件的代理组件转发所述原始数据包至所述数据接收组件；
第二数据发送单元，用于在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件；
所述判别条件包括：在第一预设时长内接收到应答包，且所述应答包满足应答规则，所述应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送，所述问询包包括用于所述数据接收组件的代理组件生成所述应答包的应答规则。
可选地，应答规则包括：
第一预设字段的字段值等于第一标准值，所述第一标准值为指示所述运行状态为正常的预设值。
可选地，本装置还包括：第一问询单元，用于：
周期性地发送所述问询包至所述数据接收组件的代理组件；
若在任意周期发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足所述应答规则，标记所述任意周期的状态标识为异常。
可选地，本装置还包括：状态判断单元，用于依据所述判别条件确定所述数据接收组件的代理组件的运行状态是否正常，状态判断单元具体用于：
获取历史周期的状态标识；
若所述历史周期的状态标识满足异常条件，确定所述数据接收组件的代理组件的运行状态异常，所述异常条件包括：最近连续n个周期的状态标识为异常，和/或状态标识为异常的周期的数量大于预设的数量阈值，其中，所述n为预设数值。
可选地，本装置还包括第二问询单元，用于在所述获取原始数据包和数据接收组件的标识之后，若确定所述历史周期的状态标识满足所述异常条件，发送所述问询包至所述数据接收组件的代理组件；
若在所述发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足应答规则，确定所述数据接收组件的代理组件的运行状态异常；
若在所述发送所述问询包后的所述第一预设时长内接收到的应答包满足应答规则，确定所述数据接收组件的代理组件的运行状态正常。
可选地，本装置还包括第三数据发送单元，用于在将所述代理数据包发送至所述数据接收组件的代理组件之后，接收响应包，所述响应包由所述数据接收组件的代理组件响应于接收到所述代理数据包生成；
判断所述响应包中的预设字段的字段值是否等于第二标准值，所述第二标准值；所述响应包用于反馈所述数据接收组件的代理组件是否成功转发所述原始数据包至所述数据接收组件，所述第二标准值为指示成功转发的预设值；
若否，将所述原始数据包发送至所述数据接收组件。
图5示出了该数据传输设备的结构示意图，该设备可以包括：至少一个处理器501，至少一个通信接口502，至少一个存储器503和至少一个通信总线504；
在本申请实施例中，处理器501、通信接口502、存储器503、通信总线504的数量为至少一个，且处理器501、通信接口502、存储器503通过通信总线504完成相互间的通信；
处理器501可能是一个中央处理器CPU，或者是特定集成电路ASIC(ApplicationSpecific Integrated Circuit)，或者是被配置成实施本发明实施例的一个或多个集成电路等；
存储器503可能包含高速RAM存储器，也可能还包括非易失性存储器(non-volatile memory)等，例如至少一个磁盘存储器；
其中，存储器存储有程序，处理器可执行存储器存储的程序，实现本申请实施例提供的一种数据传输方法的各个步骤，如下：
一种数据传输方法，应用于数据发送组件的代理组件，包括：
获取原始数据包和数据接收组件的标识，所述原始数据包由所述数据发送组件发送；
在依据预设的判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件，以使所述数据接收组件的代理组件转发所述原始数据包至所述数据接收组件；
在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件；
所述判别条件包括：在第一预设时长内接收到应答包，且所述应答包满足应答规则，所述应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送，所述问询包包括用于所述数据接收组件的代理组件生成所述应答包的应答规则。
可选地，应答规则包括：
第一预设字段的字段值等于第一标准值，所述第一标准值为指示所述运行状态为正常的预设值。
可选地，本方法还包括：
周期性地发送所述问询包至所述数据接收组件的代理组件；
若在任意周期发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足所述应答规则，标记所述任意周期的状态标识为异常。
可选地，依据所述判别条件确定所述数据接收组件的代理组件的运行状态是否正常的过程，包括：
获取历史周期的状态标识；
若所述历史周期的状态标识满足异常条件，确定所述数据接收组件的代理组件的运行状态异常，所述异常条件包括：最近连续n个周期的状态标识为异常，和/或状态标识为异常的周期的数量大于预设的数量阈值，其中，所述n为预设数值。
可选地，在所述获取原始数据包和数据接收组件的标识之后，还包括：
若确定所述历史周期的状态标识满足所述异常条件，发送所述问询包至所述数据接收组件的代理组件；
若在所述发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足应答规则，确定所述数据接收组件的代理组件的运行状态异常；
若在所述发送所述问询包后的所述第一预设时长内接收到的应答包满足应答规则，确定所述数据接收组件的代理组件的运行状态正常。
可选地，将所述代理数据包发送至所述数据接收组件的代理组件之后，还包括：
接收响应包，所述响应包由所述数据接收组件的代理组件响应于接收到所述代理数据包生成；
判断所述响应包中的预设字段的字段值是否等于第二标准值，所述第二标准值；所述响应包用于反馈所述数据接收组件的代理组件是否成功转发所述原始数据包至所述数据接收组件，所述第二标准值为指示成功转发的预设值；
若否，将所述原始数据包发送至所述数据接收组件。
本申请实施例还提供一种可读存储介质，该可读存储介质可存储有适于处理器执行的计算机程序，计算机程序被处理器执行时，实现本申请实施例提供的一种数据传输方法的各个步骤，如下：
一种数据传输方法，应用于数据发送组件的代理组件，包括：
获取原始数据包和数据接收组件的标识，所述原始数据包由所述数据发送组件发送；
在依据预设的判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件，以使所述数据接收组件的代理组件转发所述原始数据包至所述数据接收组件；
在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件；
所述判别条件包括：在第一预设时长内接收到应答包，且所述应答包满足应答规则，所述应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送，所述问询包包括用于所述数据接收组件的代理组件生成所述应答包的应答规则。
可选地，应答规则包括：
第一预设字段的字段值等于第一标准值，所述第一标准值为指示所述运行状态为正常的预设值。
可选地，本方法还包括：
周期性地发送所述问询包至所述数据接收组件的代理组件；
若在任意周期发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足所述应答规则，标记所述任意周期的状态标识为异常。
可选地，依据所述判别条件确定所述数据接收组件的代理组件的运行状态是否正常的过程，包括：
获取历史周期的状态标识；
若所述历史周期的状态标识满足异常条件，确定所述数据接收组件的代理组件的运行状态异常，所述异常条件包括：最近连续n个周期的状态标识为异常，和/或状态标识为异常的周期的数量大于预设的数量阈值，其中，所述n为预设数值。
可选地，在所述获取原始数据包和数据接收组件的标识之后，还包括：
若确定所述历史周期的状态标识满足所述异常条件，发送所述问询包至所述数据接收组件的代理组件；
若在所述发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足应答规则，确定所述数据接收组件的代理组件的运行状态异常；
若在所述发送所述问询包后的所述第一预设时长内接收到的应答包满足应答规则，确定所述数据接收组件的代理组件的运行状态正常。
可选地，将所述代理数据包发送至所述数据接收组件的代理组件之后，还包括：
接收响应包，所述响应包由所述数据接收组件的代理组件响应于接收到所述代理数据包生成；
判断所述响应包中的预设字段的字段值是否等于第二标准值，所述第二标准值；所述响应包用于反馈所述数据接收组件的代理组件是否成功转发所述原始数据包至所述数据接收组件，所述第二标准值为指示成功转发的预设值；
若否，将所述原始数据包发送至所述数据接收组件。
最后，还需要说明的是，在本文中，诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来，而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。
本说明书中各个实施例采用递进的方式描述，每个实施例重点说明的都是与其他实施例的不同之处，各个实施例之间相同相似部分互相参见即可。
对所公开的实施例的上述说明，使本领域专业技术人员能够实现或使用本申请。对这些实施例的多种修改对本领域的专业技术人员来说将是显而易见的，本文中所定义的一般原理可以在不脱离本申请的精神或范围的情况下，在其它实施例中实现。因此，本申请将不会被限制于本文所示的这些实施例，而是要符合与本文所公开的原理和新颖特点相一致的最宽的范围。
Claims (8)
1.一种数据传输方法，其特征在于，应用于数据发送组件的代理组件，包括：
获取原始数据包和数据接收组件的标识，所述原始数据包由所述数据发送组件发送；
周期性地发送问询包至所述数据接收组件的代理组件，所述问询包包括用于所述数据接收组件的代理组件生成应答包的应答规则；
若在任意周期发送所述问询包后的第一预设时长内没有接收到应答包，或者，接收到的应答包不满足所述应答规则，标记所述任意周期的状态标识为异常；
依据预设的判别条件确定所述数据接收组件的代理组件的运行状态是否正常，所述判别条件包括：在所述第一预设时长内接收到应答包，且应答包满足所述应答规则，应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送；
其中，所述依据所述判别条件确定所述数据接收组件的代理组件的运行状态是否正常的过程，包括：获取历史周期的状态标识；若所述历史周期的状态标识满足异常条件，确定所述数据接收组件的代理组件的运行状态异常，所述异常条件包括：最近连续n个周期的状态标识为异常，和/或状态标识为异常的周期的数量大于预设的数量阈值，其中，所述n为预设数值；
在依据所述判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件，以使所述数据接收组件的代理组件转发所述原始数据包至所述数据接收组件；
在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件。
2.根据权利要求1所述的方法，其特征在于，所述应答规则包括：
第一预设字段的字段值等于第一标准值，所述第一标准值为指示所述运行状态为正常的预设值。
3.根据权利要求2所述的方法，其特征在于，在所述获取原始数据包和数据接收组件的标识之后，还包括：
若确定所述历史周期的状态标识满足所述异常条件，发送所述问询包至所述数据接收组件的代理组件；
若在所述发送所述问询包后的所述第一预设时长内没有接收到应答包，或者，接收到的应答包不满足应答规则，确定所述数据接收组件的代理组件的运行状态异常；
若在所述发送所述问询包后的所述第一预设时长内接收到的应答包满足应答规则，确定所述数据接收组件的代理组件的运行状态正常。
4.根据权利要求1或2所述的方法，其特征在于，所述将所述代理数据包发送至所述数据接收组件的代理组件之后，还包括：
接收响应包，所述响应包由所述数据接收组件的代理组件响应于接收到所述代理数据包生成；
判断所述响应包中的预设字段的字段值是否等于第二标准值，所述第二标准值；所述响应包用于反馈所述数据接收组件的代理组件是否成功转发所述原始数据包至所述数据接收组件，所述第二标准值为指示成功转发的预设值；
若否，将所述原始数据包发送至所述数据接收组件。
5.一种数据传输装置，其特征在于，应用于数据发送组件的代理组件，包括：
数据接收单元，用于获取原始数据包和数据接收组件的标识，所述原始数据包由所述数据发送组件发送；
第一问询单元，用于周期性地发送问询包至所述数据接收组件的代理组件，所述问询包包括用于所述数据接收组件的代理组件生成应答包的应答规则；若在任意周期发送所述问询包后的第一预设时长内没有接收到应答包，或者，接收到的应答包不满足所述应答规则，标记所述任意周期的状态标识为异常；
状态判断单元，用于依据预设的判别条件确定所述数据接收组件的代理组件的运行状态是否正常，所述判别条件包括：在所述第一预设时长内接收到应答包，且应答包满足所述应答规则，应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送；
其中，所述依据所述判别条件确定所述数据接收组件的代理组件的运行状态是否正常的过程，包括：获取历史周期的状态标识；若所述历史周期的状态标识满足异常条件，确定所述数据接收组件的代理组件的运行状态异常，所述异常条件包括：最近连续n个周期的状态标识为异常，和/或状态标识为异常的周期的数量大于预设的数量阈值，其中，所述n为预设数值；
第一数据发送单元，用于在依据所述判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件，以使所述数据接收组件的代理组件转发所述原始数据包至所述数据接收组件；
第二数据发送单元，用于在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件。
6.一种数据传输系统，其特征在于，包括：数据发送组件、所述数据发送组件的代理组件、数据接收组件的代理组件、和所述数据接收组件；
所述数据发送组件用于发送原始数据包至所述数据发送组件的代理组件；
所述数据发送组件的代理组件用于：
获取所述原始数据包和所述数据接收组件的标识；
周期性地发送问询包至所述数据接收组件的代理组件，所述问询包包括用于所述数据接收组件的代理组件生成应答包的应答规则；
若在任意周期发送所述问询包后的第一预设时长内没有接收到应答包，或者，接收到的应答包不满足所述应答规则，标记所述任意周期的状态标识为异常；
依据预设的判别条件确定所述数据接收组件的代理组件的运行状态是否正常，所述判别条件包括：在所述第一预设时长内接收到应答包，且应答包满足所述应答规则，应答包为所述数据接收组件的代理组件响应于接收到所述数据发送组件的代理组件发送的问询包生成并发送；
其中，所述依据所述判别条件确定所述数据接收组件的代理组件的运行状态是否正常的过程，包括：获取历史周期的状态标识；若所述历史周期的状态标识满足异常条件，确定所述数据接收组件的代理组件的运行状态异常，所述异常条件包括：最近连续n个周期的状态标识为异常，和/或状态标识为异常的周期的数量大于预设的数量阈值，其中，所述n为预设数值；
在依据所述判别条件确定所述数据接收组件的代理组件的运行状态正常的情况下，基于所述原始数据包生成代理数据包，并将所述代理数据包发送至所述数据接收组件的代理组件，以使所述数据接收组件的代理组件转发所述原始数据包至所述数据接收组件；
在依据所述判别条件确定所述数据接收组件的代理组件的运行状态异常的情况下，将所述原始数据包发送至所述数据接收组件；
所述数据接收组件的代理组件用于基于所述代理数据包，获取并转发所述原始数据包至所述数据接收组件。
7.一种数据传输设备，其特征在于，包括：存储器和处理器；
所述存储器，用于存储程序；
所述处理器，用于执行所述程序，实现如权利要求1～4中任一项所述的数据传输方法的各个步骤。
8.一种可读存储介质，其上存储有计算机程序，其特征在于，所述计算机程序被处理器执行时，实现如权利要求1～4中任一项所述的数据传输方法的各个步骤。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210384489.1A CN114827260B (zh) | 2022-04-13 | 2022-04-13 | 一种数据传输方法及相关装置 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210384489.1A CN114827260B (zh) | 2022-04-13 | 2022-04-13 | 一种数据传输方法及相关装置 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114827260A CN114827260A (zh) | 2022-07-29 |
| CN114827260B true CN114827260B (zh) | 2023-08-25 |
Family
ID=82534130
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202210384489.1A Active CN114827260B (zh) | 2022-04-13 | 2022-04-13 | 一种数据传输方法及相关装置 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114827260B (zh) |
Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2007009255A1 (en) * | 2005-07-22 | 2007-01-25 | Research In Motion Limited | A method of controlling delivery of multi-part content from an origin server to a mobile device browser via a server |
| CN101005698A (zh) * | 2006-01-20 | 2007-07-25 | 华为技术有限公司 | 一种移动IPv6中路由优化的方法和系统 |
| CN111835737A (zh) * | 2020-06-29 | 2020-10-27 | 中国平安财产保险股份有限公司 | 基于自动学习的web攻击防护方法、及其相关设备 |
| CN112738284A (zh) * | 2021-04-01 | 2021-04-30 | 腾讯科技（深圳）有限公司 | 服务集成中的数据传输方法、装置、设备及存储介质 |
| CN112764956A (zh) * | 2021-01-14 | 2021-05-07 | 网宿科技股份有限公司 | 数据库的异常处理系统、数据库的异常处理方法及装置 |
| CN114090338A (zh) * | 2021-11-19 | 2022-02-25 | 中国银行股份有限公司 | 一种请求处理方法、装置及电子设备 |
| CN114185743A (zh) * | 2021-12-14 | 2022-03-15 | 中国平安财产保险股份有限公司 | 一种数据处理方法、装置、计算机设备和存储介质 |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP4648182B2 (ja) * | 2005-12-19 | 2011-03-09 | 富士通株式会社 | パケット中継システム |
| US8958291B2 (en) * | 2009-10-09 | 2015-02-17 | At&T Intellectual Property I, L.P. | Data routing in hybrid wireless communication networks |
-
2022
- 2022-04-13 CN CN202210384489.1A patent/CN114827260B/zh active Active
Patent Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2007009255A1 (en) * | 2005-07-22 | 2007-01-25 | Research In Motion Limited | A method of controlling delivery of multi-part content from an origin server to a mobile device browser via a server |
| CN101005698A (zh) * | 2006-01-20 | 2007-07-25 | 华为技术有限公司 | 一种移动IPv6中路由优化的方法和系统 |
| CN111835737A (zh) * | 2020-06-29 | 2020-10-27 | 中国平安财产保险股份有限公司 | 基于自动学习的web攻击防护方法、及其相关设备 |
| CN112764956A (zh) * | 2021-01-14 | 2021-05-07 | 网宿科技股份有限公司 | 数据库的异常处理系统、数据库的异常处理方法及装置 |
| CN112738284A (zh) * | 2021-04-01 | 2021-04-30 | 腾讯科技（深圳）有限公司 | 服务集成中的数据传输方法、装置、设备及存储介质 |
| CN114090338A (zh) * | 2021-11-19 | 2022-02-25 | 中国银行股份有限公司 | 一种请求处理方法、装置及电子设备 |
| CN114185743A (zh) * | 2021-12-14 | 2022-03-15 | 中国平安财产保险股份有限公司 | 一种数据处理方法、装置、计算机设备和存储介质 |
Non-Patent Citations (1)
| Title |
|---|
| Boukhlouf Djemaa ; Kazar Okba.Intrusion detection system: Hybrid approach based mobile agent.International Conference on Education and e-Learning Innovations.2012,全文. * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN114827260A (zh) | 2022-07-29 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110719199B (zh) | 一种网络自动测试及故障定位方法及装置 | |
| JP2001051859A (ja) | 負荷情報連絡方法 | |
| CN108111346B (zh) | 告警关联分析中频繁项集的确定方法、装置及存储介质 | |
| CN110971485A (zh) | 业务指标的监控系统及方法 | |
| CN111539499B (zh) | 天线设备的检测方法及装置和计算机可读存储介质 | |
| CN110995522B (zh) | 一种信息处理方法及装置 | |
| CN114827260B (zh) | 一种数据传输方法及相关装置 | |
| CN110505177B (zh) | 一种信息收集系统、终端设备及远程主机 | |
| CN111198804A (zh) | 基于网关的工业互联网平台第三方微服务监控预警方法 | |
| CN112615700B (zh) | 数据的发送方法、网关、系统、电子设备及可读存储介质 | |
| CN110572315A (zh) | 一种信息交互的方法及装置、机器人、存储介质 | |
| CN107018060A (zh) | 消息回复方法和装置 | |
| CN105490837A (zh) | 一种网络监控处理方法以及装置 | |
| CN111064729B (zh) | 报文的处理方法及装置、存储介质和电子装置 | |
| CN111787102A (zh) | 多应用平台的业务处理方法、装置、电子设备和存储介质 | |
| CN111314356A (zh) | 通信数据传输方法、装置和电子设备 | |
| CN110611602A (zh) | 一种二层点对点通道状态监测方法及系统 | |
| CN106998282B (zh) | 通信设定通知装置 | |
| CN115658343A (zh) | 一种检测、处理分布式系统中消息顺序的方法及装置 | |
| CN111880949B (zh) | 一种业务信息的处理方法、系统、装置、服务器及终端 | |
| CN111708689B (zh) | 一种修改ab实验的方法、装置及电子设备 | |
| CN113938844A (zh) | 网络连接监控方法、系统、计算机设备和存储介质 | |
| CN107566216A (zh) | 一种监控方法、装置及业务系统 | |
| EP3171529A1 (en) | Method and device for polling and detecting links | |
| CN110855785B (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 | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant | ||
| TR01 | Transfer of patent right | ||
| TR01 | Transfer of patent right |
Effective date of registration: 20240104 Address after: Room 301, 3rd Floor, Building 4, West District, No.10 Northwest Wangdong Road, Haidian District, Beijing, 100085 Patentee after: Beijing Duxiaoman Payment Technology Co.,Ltd. Patentee after: Du Xiaoman Technology (Beijing) Co.,Ltd. Address before: 100193 Room 606, 6 / F, building 4, West District, courtyard 10, northwest Wangdong Road, Haidian District, Beijing Patentee before: Du Xiaoman Technology (Beijing) Co.,Ltd. |