本申请设计通信技术领域，尤其涉及一种会话流量的处理方法、装置及系统。
背景技术：
传统模式的链路检测都是集中式，由一台设备分别检测不同的链路，来探测链路的响应速度和延迟等等指标。传统的链路检测需要工作在路由状态，通过路由来对流量进行分配和转发。传统模式的链路检测的优点在于，实现简单。但是缺点很多，具体如下：
（1）部署很繁琐。因为它采用路由模式部署，所以需要改变现有的网络结构和路由体系。尤其是当内网采用动态路由，比如rip、ospf，这些协议会影响到采用链路检测功能的负载均衡类设备的流量分配。
（2）采用主备机模式需要重复布线，导致网络结构变得复杂。
（3）主备机模式的切换非常复杂。是否能够有效切换依赖于软件厂商的产品稳定性和可靠性，给网络带来了隐患。
技术实现要素：
为了解决上述技术问题或者至少部分地解决上述技术问题，本申请提供了一种会话流量的处理方法、装置及系统。
根据本申请实施例的一个方面，提供了一种会话流量的处理方法，应用于部署在分布式集群中的第一主机设备，所述方法包括：
获取第一主机设备接收到的第一流量数据，以及所述第一流量数据的目标流量类型；
在所述目标流量类型属于入向流量的情况下，查询第一流量数据所属的目标会话信息；
基于所述目标会话信息确定所述目标通信会话对应的第二主机设备，其中，所述第二主机设备为所述目标通信会话的发起方；
在所述第二主机设备与所述第一主机设备不一致的情况下，确定与所述第二主机设备之间的目标心跳线，并将所述第一流量数据通过所述目标心跳线发送至所述第二主机设备，以检测所述分布式集群中的网络链路。
进一步地，在获取第一主机设备接收到的第一流量数据，以及所述第一流量数据的目标流量类型之前，所述方法还包括：
获取与所述第一主机设备具有关联关系的其他主机设备；
接收来自于所述其他主机设备的同步数据，其中，所述同步数据中包括所述其他主机设备对应的第一设备标识以及第一会话信息，所述第一会话信息中包括：所述其他主机设备发起和/或接收的流量数据；
建立所述第一设备标识与所述第一会话信息之间的第一映射关系，并存储所述第一映射关系。
进一步地，所述查询第一流量数据所属的目标会话信息，包括：
从所述第一会话信息中查询与所述第一流量数据相匹配的第二流量数据；
在所述第一会话信息中存在所述第二流量数据，且所述第二流量数据属于出向流量的情况下，将所述第二流量数据所属的会话信息确定所述目标会话信息。
进一步地，所述在所述第二主机设备与所述第一主机设备不一致的情况下，确定与所述第二主机设备之间的心跳线，包括：
确定所述第一主机设备对应的第一专网，以及所述第二主机设备对应的第二专网；
将用于连接所述第一专网与所述第二专网的心跳线，确定为所述目标心跳线。
进一步地，所述方法还包括：
获取所述第一主机设备对应的第二会话信息，其中，所述第二会话信息包括：所述第一主机设备发起和/或接收的流量数据；
在所述第二会话信息中存在与所述第一流量数据相匹配的第三流量数据，且所述第三流量数据属于出向流量类型的情况下，确定所述第二主机设备与所述第一主机设备一致。
进一步地，在确定所述第二主机设备与所述第一主机设备一样的情况下，所述方法还包括：
获取与所述第一流量数据相匹配的第三流量数据；
基于所述第一流量数据和所述第三流量数据对所述第一主机设备对应的网络链路进行检测。
根据本申请实施例的另一方面，还提供了一种流量处理方法，应用于部署在分布式集群中的第二主机设备，所述方法包括：
接收由第一主机设备通过目标心跳线发送的第一流量数据；
获取所述第二主机设备对应的第三会话信息；
从所述第三会话信息中获取与所述第一流量数据相匹配的第四流量数据，以及所述第四流量数据所属的目标会话信息；
基于所述第一流量数据和所述第四流量数据确定所述目标会话信息的完整性。
根据本申请实施例的另一方面，还提供了一种流量处理装置，包括：
获取模块，用于获取第一主机设备接收到的第一流量数据，以及所述第一流量数据的目标流量类型；
查询模块，用于在所述目标流量类型属于入向流量的情况下，查询第一流量数据所属的目标会话信息；
处理模块，用于基于所述目标会话信息确定所述目标通信会话对应的第二主机设备，其中，所述第二主机设备为所述目标通信会话的发起方；
发送模块，用于在所述第二主机设备与所述第一主机设备不一致的情况下，确定与所述第二主机设备之间的目标心跳线，并将所述第一流量数据通过所述目标心跳线发送至所述第二主机设备，以检测分布式集群中的网络链路。
根据本申请实施例的另一方面，还提供了一种流量处理装置，包括：
接收模块，用于接收由第一主机设备通过目标心跳线发送的第一流量数据；
查询模块，用于获取第二主机设备对应的第三会话信息；
获取模块，用于从所述第三会话信息中获取与所述第一流量数据相匹配的第四流量数据，以及所述第四流量数据所属的目标会话信息；
检测模块，用于基于所述第一流量数据和所述第四流量数据确定所述目标会话信息的完整性。
根据本申请实施例的另一方面，还提供了一种流量处理系统，其特征在于，包括：部署在分布式集群中的第一主机设备、第二主机设备，以及用于连接所述第一主机设备与所述第二主机设备的目标心跳线；
所述第一主机设备，用于获取第一主机设备接收到的第一流量数据，以及所述第一流量数据的目标流量类型；在所述目标流量类型属于入向流量的情况下，查询第一流量数据对应的目标通信会话的目标会话信息；基于所述目标会话信息确定所述目标通信会话对应的第二主机设备，其中，所述第二主机设备为所述目标通信会话的发起方；在所述第二主机设备与所述第一主机设备不一致的情况下，确定与所述第二主机设备之间的目标心跳线，并将所述第一流量数据通过所述目标心跳线发送至所述第二主机设备，以检测所述分布式集群中的网络链路；
所述第二主机设备，用于接收由所述第一主机设备通过目标心跳线发送的第一流量数据；获取所述第二主机设备对应的第三会话信息；从所述第三会话信息中获取与所述第一流量数据相匹配的第四流量数据，以及所述第四流量数据所属的目标会话信息；基于所述第一流量数据和所述第四流量数据确定所述目标会话信息的完整性。
根据本申请实施例的另一方面，还提供了一种存储介质，该存储介质包括存储的程序，程序运行时执行上述的步骤。
根据本申请实施例的另一方面，还提供了一种电子装置，包括处理器、通信接口、存储器和通信总线，其中，处理器，通信接口，存储器通过通信总线完成相互间的通信；其中：存储器，用于存放计算机程序；处理器，用于通过运行存储器上所存放的程序来执行上述方法中的步骤。
本申请实施例还提供了一种包含指令的计算机程序产品，当其在计算机上运行时，使得计算机执行上述方法中的步骤。
本申请实施例提供的上述技术方案与现有技术相比具有如下优点：本申请实施例采用分布式部署主机设备的方式提高了部署效率，同时使多台主机设备之间利用会话的方式分配接收的流量数据，能够实现对全部网络链路的检测。
附图说明
此处的附图被并入说明书中并构成本说明书的一部分，示出了符合本申请的实施例，并与说明书一起用于解释本申请的原理。
为了更清楚地说明本申请实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，对于本领域普通技术人员而言，在不付出创造性劳动性的前提下，还可以根据这些附图获得其他的附图。
图1为本申请实施例提供的一种会话流量的处理方法的流程图；
图2为本申请实施例提供的一种会话流量的处理过程示意图；
图3为本申请实施例提供的一种会话流量的处理过程示意图；
图4为本申请另一实施例提供的一种会话流量的处理方法的流程图；
图5为本申请实施例提供的一种会话流量的处理装置的框图；
图6为本申请另一实施例提供的一种会话流量的处理装置的框图；
图7为本申请实施例提供的一种会话流量的处理装置的框图；
图8为本申请实施例提供的一种会话流量的处理过程示意图；
图9为本申请实施例提供的一种电子设备的结构示意图。
具体实施方式
为使本申请实施例的目的、技术方案和优点更加清楚，下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本申请的一部分实施例，而不是全部的实施例，本申请的示意性实施例及其说明用于解释本申请，并不构成对本申请的不当限定。基于本申请中的实施例，本领域普通技术人员在没有做出创造性劳动的前提下所获得的所有其他实施例，都属于本申请保护的范围。
需要说明的是，在本文中，诸如“第一”和“第二”等之类的关系术语仅仅用来将一个实体或者操作与另一个类似的实体或操作区分开来，而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。
本申请实施例提供了一种会话流量的处理方法、装置及系统。本发明实施例所提供的方法可以应用于任意需要的电子设备，例如，可以为服务器、终端等电子设备，在此不做具体限定，为描述方便，后续简称为电子设备。
根据本申请实施例的一方面，提供了一种会话流量的处理方法实施例，应用于部署在分布式集群中的第一主机设备，图1为本申请实施例提供的一种会话流量的处理方法的流程图，如图1所示，该方法包括：
步骤s11，获取第一主机设备接收到的第一流量数据，以及第一流量数据的目标流量类型。
在本申请实施例中，步骤s11，在获取第一主机设备接收到的第一流量数据，以及第一流量数据的目标流量类型之前，方法还包括以下步骤a1-a3：
步骤a1，获取与第一主机设备具有关联关系的其他主机设备。
在本申请实施例中，与第一主机设备具有关联关系的其他主机设备可以是用于与第一主机设备进行数据同步的主机设备。如图2所示，主机1与主机2之间具有关联关系。
步骤a2，接收来自于其他主机设备的同步数据，其中，同步数据中包括其他主机设备对应的第一设备标识以及第一会话信息，第一会话信息中包括：其他主机设备发起和/或接收的流量数据。
步骤a3，建立第一设备标识与第一会话信息之间的第一映射关系，并存储第一映射关系。
在本申请实施例中，由于主机设备接收的流量数据包括自身处理的和其他主机设备处理的。因此建立其他主机设备的第一设备标识与第一会话信息之间的第一映射关系，能够确定接收到的流量数据是否应该由其他主机设备处理。另一方面，本申请实施例通过主机设备之间的数据同步，能够确定每个其他主机设备对应网络链路的状态。
作为一个示例，如图2所示，主机2向主机1发送的同步数据包括：主机2的设备标识以及主机2产生的会话信息，会话信息包括：主机2发起和/或接收的流量数据。主机1接收到主机2发送的同步数据后，则确定主机2对应的网络链路处于正常状态，此时主机1会根据同步数据中的设备标识与会话信息建立映射关系。
步骤s12，在目标流量类型属于入向流量的情况下，查询第一流量数据所属的目标会话信息。
在本申请实施例中，步骤s12，查询第一流量数据所属的目标会话信息，包括以下步骤b1-b2：
步骤b1，从第一会话信息中查询与第一流量数据相匹配的第二流量数据。
步骤b2，在第一会话信息中存在第二流量数据，且第二流量数据属于出向流量的情况下，将第二流量数据所属的会话信息确定目标会话信息。
在本申请实施例中，由于第一流量数据的目标类型属于入向流量，因此读取第一流量数据中的标识信息，通过标识信息直接从第一会话信息中获取与第一流量数据相匹配的第二流量数据。如果第一会话信息中存在第二流量数据，且第二流量数据属于出向流量，则表示第一流量数据所属的目标会话信息是其他主机设备发起的，此时将第二流量所属的会话信息确定为目标会话信息。
步骤s13，基于目标会话信息确定目标通信会话对应的第二主机设备，其中，第二主机设备为目标通信会话的发起方。
在本申请实施例中，由于第一主机设备中存储有第一设备标识与第一会话信息之间的映射关系，因此可以基于该映射关系确定目标会话信息对应的目标设备标识，将目标设备标识对应的主机设备确定为第二主机设备。
步骤s14，在第二主机设备与第一主机设备不一致的情况下，确定与第二主机设备之间的目标心跳线，并将第一流量数据通过目标心跳线发送至第二主机设备，以检测分布式集群中的网络链路。
在本申请实施例中，在第二主机设备与第一主机设备不一致的情况下，确定与第二主机设备之间的心跳线，包括以下步骤c1-c2：
步骤c1，确定第一主机设备对应的第一专网，以及第二主机设备对应的第二专网；
步骤c2，将用于连接第一专网与第二专网的心跳线，确定为目标心跳线。
作为一个示例，如图3所示，不同链路的专网sd-wan通过心跳线互联。专网sd-wan2和sd-wan1进行会话同步，获取会话状态是在专网sd-wan1上，当收到流量数据为入向流量时，将该流量通过心跳线转发回专网sd-wan1。因此，属于同一会话信息的流量数据是发生在一条网络链路上的，从而还可以基于流量数据检测会话的完整性。
在本申请实施例中，分布式链路检测需要多个主机设备共同完成，本申请实施例在网络链路上部署一台主机设备，便于该主机设备完成检测各自对应网络链路。同时采用多台设备之间采用数据交互的方式，实现对分布式集群中全部网络链路的检测。
在除了数据交互之外，本申请实施例将流量数据按照会话的方式进行处理。因为采用分布式的部署方式，流量数据可能被送到其中任何一台设备上，从而实现流量数据的分配。
在本申请的另一实施例中，方法还包括以下步骤d1-d2：
步骤d1，获取第一主机设备对应的第二会话信息，其中，第二会话信息包括：第一主机设备发起和/或接收的流量数据。
在本申请实施例中，第一主机设备除了存储其他主机设备发来的第一会话信息之外，还存储自身产生的第二会话信息。便于在后续接收到为入向流量的流量数据的情况下，确定该流量数据是否属于自身产生的会话信息。
步骤d2，在第二会话信息中存在与第一流量数据相匹配的第三流量数据，且第三流量数据属于出向流量类型的情况下，确定第二主机设备与第一主机设备一致。
在本申请实施例中，在确定第二主机设备与第一主机设备一样的情况下，方法还包括：获取与第一流量数据相匹配的第三流量数据；基于第一流量数据和第三流量数据对第一主机设备对应的网络链路进行检测。
在本申请实施例中，当第二会话信息中存在与第一流量数据相匹配的第三流量数据，且第三流量数据属于出向流量类型时，则确定第三流量数据该由第一主机设备进行处理，此时第一主机设备可以根据第一流量数据和第三流量数据检测第一主机设备对应的网络链路，同时还可以根据第一流量数据和第三流量数据对会话的完整性进行检测。
在本申请的另一个实施例中，方法还包括以下步骤e1-e2：
步骤e1，确定第一流量数据对应的发送结果；
步骤e2，在发送结果用于指示第一主机设备向第二主机设备发送第一流量数据失败的情况下，确定第二主机设备对应的网络链路异常，并执行异常处理信息。
在本申请实施例中，由于第一主机设备能够接收到外部返回的第一流量数据，则确定第一主机设备对应的网络链路是正常的。在当第一主机设备向第二主机设备发送流量数据失败后，则确定当前第二主机设备对应的网络链路出现异常，此时执行异常处理操作，例如：发送提示信息或者发送异常报警信号等等。
图4为本申请实施例提供的一种会话流量的处理方法的流程图，应用于第二主机设备，如图4所示，该方法可以包括以下步骤：
步骤s21，接收由第一主机设备通过目标心跳线发送的第一流量数据。
步骤s22，获取第二主机设备对应的第三会话信息。
步骤s23，从第三会话信息中获取与第一流量数据相匹配的第四流量数据，以及第四流量数据所属的目标会话信息。
步骤s24，基于第一流量数据和第四流量数据确定目标会话信息的完整性。
在本申请实施例中，往往会出现流量数据异步的情况，例如：第二主机设备上某个会话对应的流量数据发出后，其返回的流量数据被第一主机设备接收。刘慧导致流量数据异步，即往返路径不一致。因此本申请实施例为了解决该问题，使第一主机设备通过心跳线的方式将异步的流量数据转发给第二主机设备。
因此，当第二主机设备接收到第一主机设备通过目标心跳线发送的第一流量数据后，会对第一流量数据进行解析，确定第一流量数据的目标流量类型，如果目标流量类型数据入向流量的情况下，第二主机设备会获取本地的会话信息（即第三会话信息），从第三会话信息中获取与第一流量数据相匹配，且属于出向流量的第三流量数据，然后根据第一流量数据和第三流量数据进行会话完整性检测。
图5为本申请实施例提供的一种会话流量的处理装置的框图，该装置可以通过软件、硬件或者两者的结合实现成为电子设备的部分或者全部。如图5所示，该装置包括：
获取模块51，用于获取第一主机设备接收到的第一流量数据；
查询模块52，用于在目标流量类型属于入向流量的情况下，查询第一流量数据所属的目标会话信息；
处理模块53，用于在会话状态用于指示第一流量数据属于返回流量的情况下，根据会话状态确定目标通信会话对应的第二主机设备，其中，第二主机设备为目标通信会话的发起方；
发送模块54，用于在第二主机设备与第一主机设备不一致的情况下，确定与第二主机设备之间的目标心跳线，并将第一流量数据通过目标心跳线发送至第二主机设备，以检测分布式集群中的网络链路。
在本申请实施例中的装置还包括：构建模块，用于获取与第一主机设备具有关联关系的其他主机设备；接收来自于其他主机设备的同步数据，其中，同步数据中包括其他主机设备对应的第一设备标识以及第一会话信息，第一会话信息中包括：其他主机设备发起和/或接收的流量数据；建立第一设备标识与第一会话信息之间的第一映射关系，并存储第一映射关系。
在本申请实施例中，查询模块52，用于从第一会话信息中查询与第一流量数据相匹配的第二流量数据；在第二流量数据的流量类型为出向流量类型的情况下，基于第一映射关系，确定第二流量数据对目标设备标识；将第二流量数据以及目标设备标识确定为目标会话信息。
在本申请实施例中，发送模块54，用于确定第一主机设备对应的第一专网，以及第二主机设备对应的第二专网；将用于连接第一专网与第二专网的心跳线，确定为目标心跳线。
在本申请实施例中的装置还包括：存储模块，用于获取第一主机设备对应的第二会话信息，其中，第二会话信息包括：第一主机设备发起和/或接收的流量数据；在第二会话信息中存在与第一流量数据相匹配的第三流量数据，且第三流量数据属于出向流量类型的情况下，确定第二主机设备与第一主机设备一致。
在本申请实施例中的装置还包括：检测模块，用于获取与第一流量数据相匹配的第三流量数据；基于第一流量数据和第三流量数据对第一主机设备对应的网络链路进行检测。
图6为本申请实施例提供的一种会话流量的处理装置的框图，该装置可以通过软件、硬件或者两者的结合实现成为电子设备的部分或者全部。如图6所示，该装置包括：
接收模块61，用于接收由第一主机设备通过目标心跳线发送的第一流量数据；
查询模块62，用于获取第二主机设备对应的第三会话信息；
获取模块63，用于从第三会话信息中获取与第一流量数据相匹配的第四流量数据，以及第四流量数据所属的目标会话信息；
检测模块64，用于基于第一流量数据和第四流量数据确定目标会话信息的完整性。
图7为本申请实施例提供的一种会话流量的处理系统的框图，该装置可以通过软件、硬件或者两者的结合实现成为电子设备的部分或者全部。如图7所示，该系统包括：第一主机设备10、第二主机设备20以及用于连接第一主机设备与第二主机设备的目标心跳线30；
第一主机设备10，用于获取第一主机设备10接收到的第一流量数据，以及第一流量数据的目标流量类型；在目标流量类型属于入向流量的情况下，查询第一流量数据对应的目标通信会话的目标会话信息；基于目标会话信息确定目标通信会话对应的第二主机设备20，其中，第二主机设备为目标通信会话的发起方；在第二主机设备20与第一主机设备10不一致的情况下，确定与第二主机设备20之间的目标心跳线，并将第一流量数据通过目标心跳线发送至第二主机设备20，以使第二主机设备20根据第一流量数据检测分布式集群中的网络链路；
第二主机设备20，用于接收由第一主机设备通过目标心跳线发送的第一流量数据；获取第二主机设备对应的第三会话信息；从第三会话信息中获取与第一流量数据相匹配的第四流量数据，以及第四流量数据所属的目标会话信息；基于第一流量数据和第四流量数据确定目标会话信息的完整性。
作为一个示例，如图8所示，发到主机设备1的流量分为两种，一种是由主机设备1来处理的，比如会话信息1，另外一种是由主机设备2处理，比如会话信息2。主机设备1需要将会话信息2的流量转发到主机设备2上，从而实现流量数据的负载均衡。
本申请实施例相比传统模式不同的是，分布式可以工作在路由模式下，而且可以工作在透明模式下。也就是说，分布式流量分配设备可以更为容易部署。
本申请实施例还提供一种电子设备，如图9所示，电子设备可以包括：处理器1501、通信接口1502、存储器1503和通信总线1504，其中，处理器1501，通信接口1502，存储器1503通过通信总线1504完成相互间的通信。
存储器1503，用于存放计算机程序；
处理器1501，用于执行存储器1503上所存放的计算机程序时，实现上述实施例的步骤。
上述终端提到的通信总线可以是外设部件互连标准(peripheralcomponentinterconnect，简称pci)总线或扩展工业标准结构(extendedindustrystandardarchitecture，简称eisa)总线等。该通信总线可以分为地址总线、数据总线、控制总线等。为便于表示，图中仅用一条粗线表示，但并不表示仅有一根总线或一种类型的总线。
通信接口用于上述终端与其他设备之间的通信。
存储器可以包括随机存取存储器(randomaccessmemory，简称ram)，也可以包括非易失性存储器(non-volatilememory)，例如至少一个磁盘存储器。可选的，存储器还可以是至少一个位于远离前述处理器的存储装置。
上述的处理器可以是通用处理器，包括中央处理器(centralprocessingunit，简称cpu)、网络处理器(networkprocessor，简称np)等；还可以是数字信号处理器(digitalsignalprocessing，简称dsp)、专用集成电路(applicationspecificintegratedcircuit，简称asic)、现场可编程门阵列(field－programmablegatearray，简称fpga)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件。
在本申请提供的又一实施例中，还提供了一种计算机可读存储介质，该计算机可读存储介质中存储有指令，当其在计算机上运行时，使得计算机执行上述实施例中任一所述的会话流量的处理方法。
在本申请提供的又一实施例中，还提供了一种包含指令的计算机程序产品，当其在计算机上运行时，使得计算机执行上述实施例中任一所述的会话流量的处理方法。
在上述实施例中，可以全部或部分地通过软件、硬件、固件或者其任意组合来实现。当使用软件实现时，可以全部或部分地以计算机程序产品的形式实现。所述计算机程序产品包括一个或多个计算机指令。在计算机上加载和执行所述计算机程序指令时，全部或部分地产生按照本申请实施例所述的流程或功能。所述计算机可以是通用计算机、专用计算机、计算机网络、或者其他可编程装置。所述计算机指令可以存储在计算机可读存储介质中，或者从一个计算机可读存储介质向另一个计算机可读存储介质传输，例如，所述计算机指令可以从一个网站站点、计算机、服务器或数据中心通过有线（例如同轴电缆、光纤、数字用户线）或无线（例如红外、无线、微波等）方式向另一个网站站点、计算机、服务器或数据中心进行传输。所述计算机可读存储介质可以是计算机能够存取的任何可用介质或者是包含一个或多个可用介质集成的服务器、数据中心等数据存储设备。所述可用介质可以是磁性介质，(例如，软盘、硬盘、磁带)、光介质(例如，dvd)、或者半导体介质（例如固态硬盘solidstatedisk）等。
以上所述仅为本申请的较佳实施例而已，并非用于限定本申请的保护范围。凡在本申请的精神和原则之内所作的任何修改、等同替换、改进等，均包含在本申请的保护范围内。
以上所述仅是本申请的具体实施方式，使本领域技术人员能够理解或实现本申请。对这些实施例的多种修改对本领域的技术人员来说将是显而易见的，本文中所定义的一般原理可以在不脱离本申请的精神或范围的情况下，在其它实施例中实现。因此，本申请将不会被限制于本文所示的这些实施例，而是要符合与本文所申请的原理和新颖特点相一致的最宽的范围。
1.一种会话流量的处理方法，其特征在于，应用于部署在分布式集群中的第一主机设备，所述方法包括：
获取第一主机设备接收到的第一流量数据，以及所述第一流量数据的目标流量类型；
在所述目标流量类型属于入向流量的情况下，查询第一流量数据所属的目标会话信息；
基于所述目标会话信息确定所述目标通信会话对应的第二主机设备，其中，所述第二主机设备为所述目标通信会话的发起方；
在所述第二主机设备与所述第一主机设备不一致的情况下，确定与所述第二主机设备之间的目标心跳线，并将所述第一流量数据通过所述目标心跳线发送至所述第二主机设备，以检测所述分布式集群中的网络链路。
2.根据权利要求1所述的方法，其特征在于，在获取第一主机设备接收到的第一流量数据，以及所述第一流量数据的目标流量类型之前，所述方法还包括：
获取与所述第一主机设备具有关联关系的其他主机设备；
接收来自于所述其他主机设备的同步数据，其中，所述同步数据中包括所述其他主机设备对应的第一设备标识以及第一会话信息，所述第一会话信息中包括：所述其他主机设备发起和/或接收的流量数据；
建立所述第一设备标识与所述第一会话信息之间的第一映射关系，并存储所述第一映射关系。
3.根据权利要求2所述的方法，其特征在于，所述查询第一流量数据所属的目标会话信息，包括：
从所述第一会话信息中查询与所述第一流量数据相匹配的第二流量数据；
在所述第一会话信息中存在所述第二流量数据，且所述第二流量数据属于出向流量的情况下，将所述第二流量数据所属的会话信息确定所述目标会话信息。
4.根据权利要求1所述的方法，其特征在于，所述在所述第二主机设备与所述第一主机设备不一致的情况下，确定与所述第二主机设备之间的心跳线，包括：
确定所述第一主机设备对应的第一专网，以及所述第二主机设备对应的第二专网；
将用于连接所述第一专网与所述第二专网的心跳线，确定为所述目标心跳线。
5.根据权利要求1所述的方法，其特征在于，所述方法还包括：
获取所述第一主机设备对应的第二会话信息，其中，所述第二会话信息包括：所述第一主机设备发起和/或接收的流量数据；
在所述第二会话信息中存在与所述第一流量数据相匹配的第三流量数据，且所述第三流量数据属于出向流量类型的情况下，确定所述第二主机设备与所述第一主机设备一致。
6.根据权利要求5所述的方法，其特征在于，在确定所述第二主机设备与所述第一主机设备一样的情况下，所述方法还包括：
获取与所述第一流量数据相匹配的第三流量数据；
基于所述第一流量数据和所述第三流量数据对所述第一主机设备对应的网络链路进行检测。
7.一种流量处理方法，其特征在于，应用于部署在分布式集群中的第二主机设备，所述方法包括：
接收由第一主机设备通过目标心跳线发送的第一流量数据；
获取所述第二主机设备对应的第三会话信息；
从所述第三会话信息中获取与所述第一流量数据相匹配的第四流量数据，以及所述第四流量数据所属的目标会话信息；
基于所述第一流量数据和所述第四流量数据确定所述目标会话信息的完整性。
8.一种流量处理装置，其特征在于，包括：
获取模块，用于获取第一主机设备接收到的第一流量数据，以及所述第一流量数据的目标流量类型；
查询模块，用于在所述目标流量类型属于入向流量的情况下，查询第一流量数据所属的目标会话信息；
处理模块，用于基于所述目标会话信息确定所述目标通信会话对应的第二主机设备，其中，所述第二主机设备为所述目标通信会话的发起方；
发送模块，用于在所述第二主机设备与所述第一主机设备不一致的情况下，确定与所述第二主机设备之间的目标心跳线，并将所述第一流量数据通过所述目标心跳线发送至所述第二主机设备，以检测分布式集群中的网络链路。
9.一种流量处理装置，其特征在于，包括：
接收模块，用于接收由第一主机设备通过目标心跳线发送的第一流量数据；
查询模块，用于获取第二主机设备对应的第三会话信息；
获取模块，用于从所述第三会话信息中获取与所述第一流量数据相匹配的第四流量数据，以及所述第四流量数据所属的目标会话信息；
检测模块，用于基于所述第一流量数据和所述第四流量数据确定所述目标会话信息的完整性。
10.一种流量处理系统，其特征在于，包括：部署在分布式集群中的第一主机设备、第二主机设备，以及用于连接所述第一主机设备与所述第二主机设备的目标心跳线；
所述第一主机设备，用于获取第一主机设备接收到的第一流量数据，以及所述第一流量数据的目标流量类型；在所述目标流量类型属于入向流量的情况下，查询第一流量数据对应的目标通信会话的目标会话信息；基于所述目标会话信息确定所述目标通信会话对应的第二主机设备，其中，所述第二主机设备为所述目标通信会话的发起方；在所述第二主机设备与所述第一主机设备不一致的情况下，确定与所述第二主机设备之间的目标心跳线，并将所述第一流量数据通过所述目标心跳线发送至所述第二主机设备，以检测所述分布式集群中的网络链路；
所述第二主机设备，用于接收由所述第一主机设备通过目标心跳线发送的第一流量数据；获取所述第二主机设备对应的第三会话信息；从所述第三会话信息中获取与所述第一流量数据相匹配的第四流量数据，以及所述第四流量数据所属的目标会话信息；基于所述第一流量数据和所述第四流量数据确定所述目标会话信息的完整性。
技术总结