一种媒体节点的调度方法、装置、计算机设备及存储介质转让专利

申请号 : CN202010665180.0

文献号 : CN111818355B

文献日 :

基本信息:

PDF:

法律信息:

相似专利:

发明人 : 邢宏江张鑫李钢江马义

申请人 : 南京百家云科技有限公司

摘要 :

本申请提供了一种媒体节点的调度方法、装置、计算机设备及存储介质,其中,该方法包括:获取可调度列表,可调度列表中包括满足预设调度条件的第一媒体节点;在接收到客户端发送的调度请求时,从可调度列表包括的第一媒体节点中选取第二媒体节点;将第二媒体节点分配至客户端;其中,第二媒体节点用于将相应的数据流发送给客户端,从而可以优化客户端配置,提高媒体节点利用率,从而提高人机交互效率。

权利要求 :

1.一种媒体节点的调度方法,其特征在于,所述调度方法包括:获取可调度列表,所述可调度列表中包括满足预设调度条件的第一媒体节点;所述调度条件包括:媒体节点的超时阈值、重传率阈值、重传判断带宽阈值、故障节点判断阈值;其中,第一媒体节点的心跳时间小于媒体节点的超时阈值,第一媒体节点的重传率小于重传率阈值,第一媒体节点的重传判断带宽值小于重传判断带宽阈值,以及第一媒体节点的故障次数小于故障节点判断阈值;

其中,通过如下确定可调度列表:

监控中心监控多个媒体节点分别对应的传输状态信息;

所述监控中心基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足调度条件的第一媒体节点,并将所述第一媒体节点加入可调度列表中;

在接收到客户端发送的调度请求时,从所述可调度列表包括的第一媒体节点中选取第二媒体节点;

将所述第二媒体节点分配至所述客户端;其中,所述第二媒体节点用于将相应的数据流发送给所述客户端;

所述调度方法还包括:基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足故障判定条件的第五媒体节点,并将所述第五媒体节点加入故障列表中;其中,所述故障判定条件包括所述媒体节点的故障次数超过预设的故障次数阈值;

检测中心对所述故障列表中的所述第五媒体节点进行检测;其中,通过如下方法进行检测:

以预设的时间间隔,对所述故障列表中的所述第五媒体节点进行检测;

若所述故障列表中的所述第五媒体节点满足预设恢复条件,则将所述第五媒体节点加入所述可调度列表中;其中,所述恢复条件包括以下至少之一:媒体节点的带宽阈值、故障节点恢复阈值。

2.根据权利要求1所述的媒体节点的调度方法,其特征在于,所述调度方法还包括:基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取不满足调度条件的第三媒体节点,并将所述第三媒体节点加入不可调度列表中;

基于所述第三媒体节点加入所述不可调度列表的时间,选取满足预设时间条件的第四媒体节点,并将所述第四媒体节点加入至所述可调度列表中。

3.一种媒体节点的调度装置,其特征在于,所述调度装置包括:获取模块,用于获取可调度列表,所述可调度列表中包括满足预设调度条件的第一媒体节点;所述调度条件包括:媒体节点的超时阈值、重传率阈值、重传判断带宽阈值、故障节点判断阈值;其中,第一媒体节点的心跳时间小于媒体节点的超时阈值,第一媒体节点的重传率小于重传率阈值,第一媒体节点的重传判断带宽值小于重传判断带宽阈值,以及第一媒体节点的故障次数小于故障节点判断阈值;

其中,通过如下确定可调度列表:

监控中心监控多个媒体节点分别对应的传输状态信息;

所述监控中心基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足调度条件的第一媒体节点,并将所述第一媒体节点加入可调度列表中;

第一选取模块,用于在接收到客户端发送的调度请求时,从所述可调度列表包括的第一媒体节点中选取第二媒体节点;

分配模块,用于将所述第二媒体节点分配至所述客户端;其中,所述第二媒体节点用于将相应的数据流发送给所述客户端;

所述调度装置还包括第四选取模块,第四选取模块用于基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足故障判定条件的第五媒体节点,并将所述第五媒体节点加入故障列表中;其中,所述故障判定条件包括所述媒体节点的故障次数超过预设的故障次数阈值;

所述调度装置还包括检测模块,检测模块用于检测中心对所述故障列表中的所述第五媒体节点进行检测;其中,通过如下方法进行检测:以预设的时间间隔,对所述故障列表中的所述第五媒体节点进行检测;

若所述故障列表中的所述第五媒体节点满足预设恢复条件,则将所述第五媒体节点加入所述可调度列表中;其中,所述恢复条件包括以下至少之一:媒体节点的带宽阈值、故障节点恢复阈值。

4.一种计算机设备,其特征在于,包括:处理器、存储器和总线,所述存储器存储有所述处理器可执行的机器可读指令,当电子设备运行时,所述处理器与所述存储器之间通过所述总线进行通信,所述机器可读指令被所述处理器运行时执行如权利要求1至2任一所述的媒体节点的调度方法的步骤。

5.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质上存储有计算机程序,所述计算机程序被处理器运行时执行如权利要求1至2任一所述的媒体节点的调度方法的步骤。

说明书 :

一种媒体节点的调度方法、装置、计算机设备及存储介质

技术领域

[0001] 本申请涉及媒体网络技术领域,尤其涉及一种媒体节点的调度方法、装置、计算机设备及存储介质。

背景技术

[0002] 随着网络技术的不断发展,直播会议、直播教学等逐渐走入到日常工作和学习中。伴随着对于直播过程中稳定性的需求不断增加,对应网络配置的要求也在逐渐增大。
[0003] 在云平台的直播服务中,大部分的直播服务中云端流媒体节点调度是完全依赖于客户端对于网络质量的反馈,来选择合适的边缘流媒体节点进行音视频数据的传输。
[0004] 但是,目前服务商所提供的媒体服务质量参差不齐,并且各个网络链路的质量差异性也比较大,因此会对音视频数据的传输造成一定的干扰,影响人机交互效率。

发明内容

[0005] 有鉴于此,本申请实施例至少提供一种媒体节点的调度方法、装置、计算机设备及存储介质,可以基于各媒体节点的状态信息,对其进行调度,以优化客户端配置,提高媒体
节点利用率,从而提高人机交互效率。
[0006] 本申请主要包括以下几个方面:
[0007] 第一方面,本申请实施例提供一种媒体节点的调度方法,所述调度方法包括:
[0008] 获取可调度列表,所述可调度列表中包括满足预设调度条件的第一媒体节点;
[0009] 在接收到客户端发送的调度请求时,从所述可调度列表包括的第一媒体节点中选取第二媒体节点;
[0010] 将所述第二媒体节点分配至所述客户端;其中,所述第二媒体节点用于将相应的数据流发送给所述客户端。
[0011] 在一种可能的实施方式中,通过如下确定可调度列表:
[0012] 监控中心监控多个媒体节点分别对应的传输状态信息;
[0013] 所述监控中心基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足调度条件的第一媒体节点,并将所述第一媒体节点加入可调度列表中。
[0014] 在一种可能的实施方式中,所述调度条件包括以下至少之一:
[0015] 媒体节点的超时阈值、重传率阈值、重传判断带宽阈值、故障节点判断阈值。
[0016] 在一种可能的实施方式中,所述调度方法还包括:
[0017] 基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取不满足调度条件的第三媒体节点,并将所述第三媒体节点加入不可调度列表中;
[0018] 基于所述第三媒体节点加入所述不可调度列表的时间,经过预设时间后,将所述第三媒体节点加入至所述可调度列表中。
[0019] 在一种可能的实施方式中,所述调度方法还包括:
[0020] 基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足故障判定条件的第五媒体节点,并将所述第五媒体节点加入故障列表中;
[0021] 其中,所述故障判定条件包括所述媒体节点的故障次数超过预设的故障次数阈值。
[0022] 在一种可能的实施方式中,所述调度方法还包括:
[0023] 检测中心对所述故障列表中的所述第五媒体节点进行检测。
[0024] 若所述故障列表中的所述第五媒体节点满足预设恢复条件,则将所述第五媒体节点加入所述可调度列表中;
[0025] 在一种可能的实施方式中,通过如下方法进行检测:
[0026] 以预设的时间间隔,对所述故障列表中的所述第五媒体节点进行检测;
[0027] 若所述故障列表中的所述第五媒体节点满足预设恢复条件,则将所述第五媒体节点加入所述可调度列表中;
[0028] 其中,所述恢复条件包括以下至少之一:媒体节点的带宽阈值、故障节点恢复阈值。
[0029] 第二方面,本申请实施例还提供一种媒体节点的调度装置,所述调度装置包括:
[0030] 获取模块,用于获取可调度列表,所述可调度列表中包括满足预设调度条件的第一媒体节点;
[0031] 第一选取模块,用于在接收到客户端发送的调度请求时,从所述可调度列表包括的第一媒体节点中选取第二媒体节点;
[0032] 分配模块,用于将所述第二媒体节点分配至所述客户端;其中,所述第二媒体节点用于将相应的数据流发送给所述客户端。
[0033] 在一种可能的实施方式中,通过如下确定可调度列表:
[0034] 监控中心监控多个媒体节点分别对应的传输状态信息;
[0035] 所述监控中心基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足调度条件的第一媒体节点,并将所述第一媒体节点加入可调度列表中。
[0036] 在一种可能的实施方式中,所述调度条件包括以下至少之一:
[0037] 媒体节点的超时阈值、重传率阈值、重传判断带宽阈值、故障节点判断阈值。
[0038] 在一种可能的实施方式中,所述调度装置还包括:
[0039] 第二选取模块,用于基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取不满足调度条件的第三媒体节点,并将所述第三媒体节点加入不可调度
列表中;
[0040] 第三选取模块,用于基于所述第三媒体节点加入所述不可调度列表的时间,选取满足预设时间条件的第四媒体节点,并将所述第四媒体节点加入至所述可调度列表中。
[0041] 在一种可能的实施方式中,所述调度装置还包括:
[0042] 第四选取模块,用于基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足故障判定条件的第五媒体节点,并将所述第五媒体节点加入故障列
表中;其中,所述故障判定条件包括所述媒体节点的故障次数超过预设的故障次数阈值。
[0043] 在一种可能的实施方式中,所述调度装置还包括:
[0044] 检测模块,用于检测中心对所述故障列表中的所述第五媒体节点进行检测。
[0045] 在一种可能的实施方式中,通过如下方法进行检测:
[0046] 以预设的时间间隔,对所述故障列表中的所述第五媒体节点进行检测;
[0047] 若所述故障列表中的所述第五媒体节点满足预设恢复条件,则将所述第五媒体节点加入所述可调度列表中;
[0048] 其中,所述恢复条件包括以下至少之一:媒体节点的带宽阈值、故障节点恢复阈值。
[0049] 第三方面,本申请实施例还提供一种计算机设备,包括:处理器、存储器和总线,所述存储器存储有所述处理器可执行的机器可读指令,当电子设备运行时,所述处理器与所
述存储器之间通过所述总线进行通信,所述机器可读指令被所述处理器运行时执行上述第
一方面或第一方面中任一种可能的实施方式中所述的媒体节点的调度方法的步骤。
[0050] 第四方面,本申请实施例还提供了一种计算机可读存储介质,所述计算机可读存储介质上存储有计算机程序,所述计算机程序被处理器运行时执行上述第一方面或第一方
面中任一种可能的实施方式中所述的媒体节点的调度的步骤。
[0051] 本申请实施例提供的一种媒体节点的调度方法、装置、计算机设备及存储介质,包括:获取可调度列表,可调度列表中包括满足预设调度条件的第一媒体节点;在接收到客户
端发送的调度请求时,从可调度列表包括的第一媒体节点中选取第二媒体节点;将第二媒
体节点分配至客户端;其中,第二媒体节点用于将相应的数据流发送给客户端,从而可以优
化客户端配置,提高媒体节点利用率,从而提高人机交互效率。
[0052] 为使本申请的上述目的、特征和优点能更明显易懂,下文特举较佳实施例,并配合所附附图,作详细说明如下。

附图说明

[0053] 为了更清楚地说明本申请实施例的技术方案,下面将对实施例中所需要使用的附图作简单地介绍,此处的附图被并入说明书中并构成本说明书中的一部分,这些附图示出
了符合本申请的实施例,并与说明书一起用于说明本申请的技术方案。应当理解,以下附图
仅示出了本申请的某些实施例,因此不应被看作是对范围的限定,对于本领域普通技术人
员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他相关的附图。
[0054] 图1示出了本申请实施例所提供的一种媒体节点的调度方法的流程图;
[0055] 图2示出了本申请实施例所提供的确定可调度列表的流程图;
[0056] 图3示出了本申请实施例所提供的不可调度列表中的媒体节点加入可调度列表的流程图;
[0057] 图4示出了本申请实施例所提供的检测方法的流程图;
[0058] 图5示出了本申请实施例所提供的一种媒体节点的调度装置的示意图;
[0059] 图6示出了本申请实施例所提供的另一种媒体节点的调度装置的示意图;
[0060] 图7示出了本申请实施例所提供的一种计算机设备的示意图。

具体实施方式

[0061] 为使本申请实施例的目的、技术方案和优点更加清楚,下面将结合本申请实施例中附图,对本申请实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅
是本申请一部分实施例,而不是全部的实施例。通常在此处附图中描述和示出的本申请实
施例的组件可以以各种不同的配置来布置和设计。因此,以下对在附图中提供的本申请的
实施例的详细描述并非旨在限制要求保护的本申请的范围,而是仅仅表示本申请的选定实
施例。基于本申请的实施例,本领域技术人员在没有做出创造性劳动的前提下所获得的所
有其他实施例,都属于本申请保护的范围。
[0062] 经研究发现,在云平台的直播服务中,大部分的直播服务中云端流媒体节点调度是完全依赖于客户端对于网络质量的反馈,来选择合适的边缘流媒体节点进行音视频数据
的传输。但是,由于服务商所提供的媒体服务质量参差不齐,并且各个网络链路的质量差异
性也比较大,因此会对音视频数据的传输造成一定的干扰,影响人机交互效率。
[0063] 基于上述研究,本申请实施例通过获取可调度列表,可调度列表中包括满足预设调度条件的第一媒体节点;在接收到客户端发送的调度请求时,从可调度列表包括的第一
媒体节点中选取第二媒体节点;将第二媒体节点分配至客户端;其中,第二媒体节点用于将
相应的数据流发送给客户端,从而可以优化客户端配置,提高媒体节点利用率,从而提高人
机交互效率。
[0064] 针对以上方案所存在的缺陷,均是发明人在经过实践并仔细研究后得出的结果,因此,上述问题的发现过程以及下文中本申请针对上述问题所提出的解决方案,都应该是
发明人在本申请过程中对本申请做出的贡献。
[0065] 应注意到:相似的标号和字母在下面的附图中表示类似项,因此,一旦某一项在一个附图中被定义,则在随后的附图中不需要对其进行进一步定义和解释。
[0066] 为便于对本实施例进行理解,首先对本申请实施例所公开的一种媒体节点的调度方法进行详细介绍,本申请实施例所提供的媒体节点的调度方法的执行主体一般为具有一
定计算能力的计算机设备,该计算机设备例如包括:终端设备或服务器或其它处理设备,终
端设备可以为用户设备(User Equipment,UE)、移动设备、用户终端、终端、蜂窝电话、无绳
电话、个人数字处理(Personal Digital Assistant,PDA)、手持设备、计算设备、车载设备、
可穿戴设备等。在一些可能的实现方式中,该媒体节点的调度方法可以通过处理器调用存
储器中存储的计算机可读指令的方式来实现。
[0067] 下面以执行主体为终端设备为例对本申请实施例提供的媒体节点的调度方法加以说明。
[0068] 参见图1所示,为本申请实施例提供的媒体节点的调度方法的流程图,所述方法包括步骤S101~S103,其中:
[0069] S101:获取可调度列表,所述可调度列表中包括满足预设调度条件的第一媒体节点;
[0070] S102:在接收到客户端发送的调度请求时,从所述可调度列表包括的第一媒体节点中选取第二媒体节点;
[0071] S103:将所述第二媒体节点分配至所述客户端;其中,所述第二媒体节点用于将相应的数据流发送给所述客户端。
[0072] 下面分别对上述S101~S103加以详细说明。
[0073] 一:在上述S101中,在可调度列表中,包括多个第一媒体节点,其中,每一个第一媒体节点都是由监控中心基于多个媒体节点分别对应的传输状态信息选取的。其中,监控中
心接收各个媒体节点的传输状态信息,将所有媒体节点进行存储,同时标记处理每个媒体
节点的可用状态。
[0074] 示例性的,传输状态信息主要包括各媒体节点的心跳信息,可以包括以下信息:外网出带宽、外网出吞吐率(Packets per Second,pps)、内网出带宽、内网出吞吐率(Packets 
per Second,pps)、入重传率(ratio retransfer in,Rrti)、出重传率(ratio retransfer 
out,Rrto)等。
[0075] 请参阅图2,图2为本申请实施例中确定可调度列表的流程图。监控中心在接受到传输状态信息之后,便可以基于各媒体节点的传输状态信息来确定可调度列表,具体包括
步骤S1011~S1012,其中:
[0076] S1011:监控中心监控多个媒体节点分别对应的传输状态信息;
[0077] S1012:所述监控中心基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足调度条件的第一媒体节点,并将所述第一媒体节点加入可调度列表
中。
[0078] 下面分别对上述S1011~S1012加以详细说明。
[0079] 在上述S1011中,监控中心可以按照预设的时间间隔接收各个媒体节点的传输状态信息。
[0080] 示例性的,各媒体节点每2秒发送一次传输状态信息到监控中心,同时监控中心每2秒接受一次传输状态信息。
[0081] 在上述S1012中,基于获取的传输状态信息,将传输状态信息与调度条件进行对照,并将满足调度条件的第一媒体节点,加入可调度列表中。
[0082] 其中,所述调度条件包括以下至少之一:
[0083] 媒体节点的超时阈值、重传率阈值、重传判断带宽阈值、故障节点判断阈值。
[0084] 具体的,该判断过程是基于一定的数据包(NACK)进行的,数据包是实时数据控制消息(Real‑time Transport Control Protocol,RTCP)中的一种,接收端通过该数据包反
馈给发送端哪些数据包没有收到,接收端重新发送该数据到接收端。
[0085] 下面对每个调度条件进行详述:
[0086] (1)媒体节点的超时阈值(Thbd):预设的时间阈值,若媒体节点的传输状态信息中对应的媒体节点心跳时间超过该阈值,则认为该媒体节点发生异常,通常,媒体节点的超时
阈值默认为6秒。
[0087] (2)重传率阈值:对每个网络区域内的多个在线上用户的数据包进行重传次数统计,可以得到的每个网络区域的数据包重传率。重传率可以分为入(NACK in)重传率和出
(NACK ou)重传率,分别表示为Rrti和Rrto,对应的,入重传率阈值和出重传率阈值分别表
示为Trrti和Trrto,通常都默认为0.3,当重传率大于对应阈值时,意味着该流媒体节点的
下行网络联路质量较差。
[0088] 具体的,入重传率为媒体节点统计该媒体节点上每1分钟内收到的数据包中重传的包的数量表示为Nnai,同时保存同一分钟内发送的数据包总量(不包含重传包的数量),
表示为Nto,两者的比值为重传率Rrti=Nnai/Nto。类似的,出重传率为媒体节点统计该媒
体节点上每1分钟内发送的数据包中重传的包的数量,表示为Nnao,同时保存同一分钟内应
该接受到的数据包总量(不包含重传包的数量),表示为Nti,两者的比值为重传率Rrto=
Nnao/Nti。
[0089] (3)重传判断带宽阈值(Tbwl):通常指的是重传判断的最低带宽值,默认为50Mbps。
[0090] (4)故障节点判断阈值(Tfault):每当一媒体节点出现故障,都会对应的在故障次数加一,如果该媒体节点的故障次数大于故障节点判断阈值,则会转移到故障节点列表
(Lfault)中,通常默认为3次。
[0091] 对应的,将传输状态信息与调度条件进行对照的过程包括一下几种情况:
[0092] 对于不满足调度条件的情况分为以下几种:
[0093] (1)若一媒体节点的连续心跳时间大于媒体节点的超时阈值,则该媒体节点下线,并转移到无心跳列表(Lhbn)中。
[0094] (2)若一媒体节点的带宽大于重传判断带宽阈值,并且入重传率大于入重传率阈值,则该媒体节点下线,并转移到不可调度列表(Loff)中。
[0095] (3)若一媒体节点的带宽大于重传判断带宽阈值,并且出重传率大于出重传率阈值,则该媒体节点下线,并转移到不可调度列表(Loff)中。
[0096] (4)若一媒体的故障次数大于故障节点判断阈值,则将该节点转移到故障节点列表(Lfault)中。这里,可以将每个媒体节点的故障次数按照预设时长而进行置零操作,例
如:将每个媒体节点的故障次数每天重置为0。
[0097] 当排除掉上述加入至不可调度列表的媒体节点时,余下的便可以确认为是可以加入可调度列表中的第一媒体节点。
[0098] 此外,还包括:若一媒体节点的连续心跳时间大于媒体节点的上线恢复阈值(Thbu),通常为600秒,并且该节点在无心跳列表(Lhbn)中,则对该媒体节点恢复调度,从无
心跳节点列表(Lhbn)转移到可调度列表(Lon)中。
[0099] 请参阅图3,图3为本申请实施例中不可调度列表中的媒体节点加入可调度列表的流程图。由于节点具有一定的自我复原功能,那么就可以在一定时间之后将不可调度列表
中的媒体节点转移至可调度列表中,具体包括步骤S1013~S1014,其中:
[0100] S1013:基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取不满足调度条件的第三媒体节点,并将所述第三媒体节点加入不可调度列表中;
[0101] S1014:基于所述第三媒体节点加入所述不可调度列表的时间,选取满足预设时间条件的第四媒体节点,并将所述第四媒体节点加入至所述可调度列表中。
[0102] 下面分别对上述S1013~S1014加以详细说明。
[0103] 在上述S1013中,将传输状态信息与调度条件进行对照的过程包括一下几种情况:
[0104] 对于不满足调度条件的情况分为以下几种:
[0105] (1)若一媒体节点的连续心跳时间大于媒体节点的超时阈值,则该媒体节点下线,并转移到无心跳列表(Lhbn)中。
[0106] (2)若一媒体节点的带宽大于重传判断带宽阈值,并且入重传率大于入重传率阈值,则该媒体节点下线,并转移到不可调度列表(Loff)中。
[0107] (3)若一媒体节点的带宽大于重传判断带宽阈值,并且出重传率大于出重传率阈值,则该媒体节点下线,并转移到不可调度列表(Loff)中。
[0108] 若满足上述任一条件,则可以认为该媒体节点出现异常,并将该媒体节点加入至不可调度列表中。
[0109] 在上述S1014中,基于监测日志,可以获取到一媒体节点加入至不可调度列表中的时间,在确定自加入时间至当前时间的时间区间满足预设时间条件时,确定该媒体节点为
可调度的第四媒体节点,并将所述第四媒体节点加入至所述可调度列表中。
[0110] 此外,在本申请的另一实施例中,所述调度方法还包括:
[0111] 基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足故障判定条件的第五媒体节点,并将所述第五媒体节点加入故障列表中;其中,所述故障
判定条件包括所述媒体节点的故障次数超过预设的故障次数阈值。
[0112] 示例性的,所述故障次数为该节点在加入可调度列表和不可调度列表之前发生故障的次数。
[0113] 由于检测中心进行媒体节点检测的时间与资源成本较高,为了节约成本,在本申请的另一个实施例中,可以利用检测中心对第五媒体节点进行检测。
[0114] 示例性的,检测中心接收监控中心上报的故障节点列表,在故障节点上部署网络性能测试工具(iperf)测试程序,进行双向用户数据报协议(User Datagram Protocol,
UDP)测试,检测中心对故障列表中的节点进行检测。如果测试通过,则通知监控中心重新上
线故障节点。示例性的,检测中心可以分别在A、B、C、D部署4个检测节点,分别测试该4个节
点与故障节点间的双向UDP丢包率(Packet Loss Rate)。
[0115] 请参阅图4,图4为本申请实施例中检测方法的流程图。具体包括步骤S1015~S1016,其中:
[0116] S1015:以预设的时间间隔,对所述故障列表中的所述第五媒体节点进行检测;
[0117] S1016:若所述故障列表中的所述第五媒体节点满足预设恢复条件,则将所述第五媒体节点加入所述可调度列表中;
[0118] 其中,所述恢复条件包括以下至少之一:
[0119] 媒体节点的带宽阈值、故障节点恢复阈值。
[0120] 具体的,检测中心在接收到监控中心上报的故障节点后,以预设频率开始检测节点带宽,在出入带宽值满足预设条件时,开始正式的检测流程。
[0121] 示例性的,检测中心在接收到监控中心上报的故障节点后,以10分钟一次的频率开始检测节点带宽,在出入带宽值小于50kbps后,开始正式的检测流程。
[0122] 具体的,可以在故障节点上安装部署iperf测试程序,检测中心的四个不同地区的测试节点与该故障节点测试双向的UDP包丢包率,在每天的预设时间段分别测试预设时长,
连续若干台测试的双向UDP丢包率,若小于故障节点恢复阈值(Trc),通常默认为0.5%,则
判定该节点网络恢复正常,并通知监控中心,将该节点从故障列表中转移到可调度列表中。
[0123] 示例性的,检测中心可以在A、B、C、D四个不同地区,对应测试节点与该故障节点测试双向的UDP包丢包率,在每天的三个高峰时段,例如10:00,16:00,19:00分别测试1个小
时,连续7天测试,若双向UDP丢包率小于故障节点恢复阈值,则判定该节点网络恢复正常。
[0124] 二:在上述S102中,调度中心基于接收到的、客户端发送的调度请求,从可调度列表中的多个第一媒体节点中选取第二媒体节点,分配到用户端上发送或者接收数据流。
[0125] 具体的,本申请实施例可用于用户端(Client),不限于推流或者拉流的形式,具体包括:个人计算机(Personal Computer,PC)网页端、个人计算机(Personal Computer,PC)
客户端、超文本5.0(Hyper Text Markup Language 5,HTML5,H5)端、安卓(android)端、苹
果(IOS)端等多个用户端。
[0126] 其中,调度中心可以在不同的区域做双机热备份,提供整个平台的调度服务。具体的,双机热备份就是用网络把两台服务器连接起来,平时互相备份,共同执行同一服务。当
一台服务器停机时,可以由双机中的另一台服务器自动将停机服务器的业务接管,从而在
不需要人工干预的情况下,保证系统能持续提供服务,从而能够保证系统能持续提供服务。
[0127] 示例性的,在调度中心收到每个端上的请求时,可以从监控中心对应地区的可调度列表中读取媒体节点,并分配到用户端上发送或者接收数据流。
[0128] 其中,监控中心对应地区的个媒体节点可以表示如下:
[0129] 运营商A在C区的媒体节点表示为Ca1~Can;
[0130] 运营商B在C区的媒体节点表示为Cb1~Cbn;
[0131] 运营商A在D区的媒体节点表示为Da1~Dan;
[0132] 运营商B在D区的媒体节点表示为Db1~Dbn;
[0133] 运营商A在E区的媒体节点表示为Ea1~Ean;
[0134] 运营商B在E区的媒体节点表示为Eb1~Ebn。
[0135] 具体的,调度中心在接收到客户端的请求时,调度中心的所有节点按照地区、底层运营商分类,C、D、E为邻近区域,用户端上的重联请求会按照本地区其他运营商节点、邻近
区域同一运营商节点、邻近区域其他运营商节点、其他区域同一运营商节点、其他地区其他
运营商节点的顺序分配节点。
[0136] 三:在上述S103中,将选取出第二媒体节点分配至所述客户端,用于将相应的数据流发送给对应的客户端。
[0137] 在本申请实施例中,基于底层的多个运营平台,每个运营平台又区分为多个服务区域,当某个运营平台的某个区域出现问题,或者所有平台的整个区域出现问题时,根据本
申请实施例中的调度方法可以快速发现问题,通过其他运营平台或者其他地区的媒体节
点,降低出现问题时的故障恢复时间,提高整个服务平台的稳定性。此外,本申请实施例在
调度媒体节点时添加了基于云端的各媒体服务器之间的媒体节点质量的监控,充分考虑了
不同云平台服务器之间、不同地区之间的服务器质量的区别,相比较于用户端上的质量检
测,可以更快速的发现云端服务器问题,调度到其他可用的媒体节点。
[0138] 本申请实施例提供了一种媒体节点的调度方法,包括:获取可调度列表,可调度列表中包括满足预设调度条件的第一媒体节点;在接收到客户端发送的调度请求时,从可调
度列表包括的第一媒体节点中选取第二媒体节点;将第二媒体节点分配至客户端;其中,第
二媒体节点用于将相应的数据流发送给客户端,从而可以优化客户端配置,提高媒体节点
利用率,从而提高人机交互效率。
[0139] 本领域技术人员可以理解,在具体实施方式的上述方法中,各步骤的撰写顺序并不意味着严格的执行顺序而对实施过程构成任何限定,各步骤的具体执行顺序应当以其功
能和可能的内在逻辑确定。
[0140] 基于同一发明构思,本申请实施例中还提供了与媒体节点的调度方法对应的媒体节点的调度装置,由于本申请实施例中的装置解决问题的原理与本申请实施例上述媒体节
点的调度方法相似,因此装置的实施可以参见方法的实施,重复之处不再赘述。
[0141] 参照图5、6所示,图5为本申请实施例提供的一种媒体节点的调度装置的示意图;图6为本申请实施例提供的另一种媒体节点的调度装置的示意图。所述媒体节点的调度装
置包括:获取模块510、第一选取模块520、以及分配模块530,其中:
[0142] 获取模块510,用于获取可调度列表,所述可调度列表中包括满足预设调度条件的第一媒体节点;
[0143] 第一选取模块520,用于在接收到客户端发送的调度请求时,从所述可调度列表包括的第一媒体节点中选取第二媒体节点;
[0144] 分配模块530,用于将所述第二媒体节点分配至所述客户端;其中,所述第二媒体节点用于将相应的数据流发送给所述客户端。
[0145] 本申请实施例提供了一种媒体节点的调度装置,包括:获取可调度列表,可调度列表中包括满足预设调度条件的第一媒体节点;在接收到客户端发送的调度请求时,从可调
度列表包括的第一媒体节点中选取第二媒体节点;将第二媒体节点分配至客户端;其中,第
二媒体节点用于将相应的数据流发送给客户端,从而可以优化客户端配置,提高媒体节点
利用率,从而提高人机交互效率。
[0146] 在一种可能的实施方式中,通过如下确定可调度列表:
[0147] 监控中心监控多个媒体节点分别对应的传输状态信息;
[0148] 所述监控中心基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足调度条件的第一媒体节点,并将所述第一媒体节点加入可调度列表中。
[0149] 在一种可能的实施方式中,所述调度条件包括以下至少之一:
[0150] 媒体节点的超时阈值、重传率阈值、重传判断带宽阈值、故障节点判断阈值。
[0151] 在一种可能的实施方式中,如图6所示,所述调度装置还包括:
[0152] 第二选取模块540,用于基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取不满足调度条件的第三媒体节点,并将所述第三媒体节点加入不可调
度列表中;
[0153] 第三选取模块550,用于基于所述第三媒体节点加入所述不可调度列表的时间,选取满足预设时间条件的第四媒体节点,并将所述第四媒体节点加入至所述可调度列表中。
[0154] 在一种可能的实施方式中,所述调度装置还包括:
[0155] 第四选取模块560,用于基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足故障判定条件的第五媒体节点,并将所述第五媒体节点加入故障
列表中;其中,所述故障判定条件包括所述媒体节点的故障次数超过预设的故障次数阈值。
[0156] 在一种可能的实施方式中,所述调度装置还包括:
[0157] 检测模块570,用于检测中心对所述不可调度列表中的所述第三媒体节点进行检测。
[0158] 在一种可能的实施方式中,通过如下方法进行检测:
[0159] 以预设的时间间隔,对所述故障列表中的所述第五媒体节点进行检测;
[0160] 若所述故障列表中的所述第五媒体节点满足预设恢复条件,则将所述第五媒体节点加入所述可调度列表中;其中,所述恢复条件包括以下至少之一:媒体节点的带宽阈值、
故障节点恢复阈值。
[0161] 本申请实施例还提供了一种计算机设备,如图7所示,为本申请实施例提供的计算机设备结构示意图,包括:
[0162] 处理器11和存储器12;所述存储器12存储有所述处理器11可执行的机器可读指令,当计算机设备运行时,所述机器可读指令被所述处理器执行以实现下述步骤:
[0163] 获取可调度列表,所述可调度列表中包括满足预设调度条件的第一媒体节点;
[0164] 在接收到客户端发送的调度请求时,从所述可调度列表包括的第一媒体节点中选取第二媒体节点;
[0165] 将所述第二媒体节点分配至所述客户端;其中,所述第二媒体节点用于将相应的数据流发送给所述客户端。
[0166] 一种可选的实施方式中,处理器11执行的指令中,通过如下确定可调度列表:
[0167] 监控中心监控多个媒体节点分别对应的传输状态信息;
[0168] 所述监控中心基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足调度条件的第一媒体节点,并将所述第一媒体节点加入可调度列表中。
[0169] 一种可选的实施方式中,处理器11执行的指令中,所述调度条件包括以下至少之一:
[0170] 媒体节点的超时阈值、重传率阈值、重传判断带宽阈值、故障节点判断阈值。
[0171] 一种可选的实施方式中,处理器11执行的指令中,所述调度方法还包括:
[0172] 基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取不满足调度条件的第三媒体节点,并将所述第三媒体节点加入不可调度列表中;
[0173] 基于所述第三媒体节点加入所述不可调度列表的时间,选取满足预设时间条件的第四媒体节点,并将所述第四媒体节点加入至所述可调度列表中。
[0174] 一种可选的实施方式中,处理器11执行的指令中,所述调度方法还包括:
[0175] 所述调度方法还包括:
[0176] 基于多个所述媒体节点分别对应的传输状态信息,从所述多个媒体节点中选取满足故障判定条件的第五媒体节点,并将所述第五媒体节点加入故障列表中;
[0177] 其中,所述故障判定条件包括所述媒体节点的故障次数超过预设的故障次数阈值。
[0178] 一种可选的实施方式中,处理器11执行的指令中,所述调度方法还包括:
[0179] 检测中心对所述故障列表中的所述第五媒体节点进行检测。
[0180] 一种可选的实施方式中,处理器11执行的指令中,通过如下方法进行检测:
[0181] 以预设的时间间隔,对所述故障列表中的所述第五媒体节点进行检测;
[0182] 若所述故障列表中的所述第五媒体节点满足预设恢复条件,则将所述第五媒体节点加入所述可调度列表中;其中,所述恢复条件包括以下至少之一:媒体节点的带宽阈值、
故障节点恢复阈值。
[0183] 本申请实施例还提供一种计算机可读存储介质,该计算机可读存储介质上存储有计算机程序,该计算机程序被处理器运行时执行上述方法实施例中所述的媒体节点的调度
方法的步骤。其中,该存储介质可以是易失性或非易失的计算机可读取存储介质。
[0184] 本申请实施例所提供的媒体节点的调度方法的计算机程序产品,包括存储了程序代码的计算机可读存储介质,所述程序代码包括的指令可用于执行上述方法实施例中所述
的媒体节点的调度方法的步骤,具体可参见上述方法实施例,在此不再赘述。
[0185] 本申请实施例还提供一种计算机程序,该计算机程序被处理器执行时实现前述实施例的任意一种方法。该计算机程序产品可以具体通过硬件、软件或其结合的方式实现。在
一个可选实施例中,所述计算机程序产品具体体现为计算机存储介质,在另一个可选实施
例中,计算机程序产品具体体现为软件产品,例如软件开发包(Software Development 
Kit,SDK)等等。
[0186] 所属领域的技术人员可以清楚地了解到,为描述的方便和简洁,上述描述的系统和装置的具体工作过程,可以参考前述方法实施例中的对应过程,在此不再赘述。在本申请
所提供的几个实施例中,应该理解到,所揭露的系统、装置和方法,可以通过其它的方式实
现。以上所描述的装置实施例仅仅是示意性的,例如,所述单元的划分,仅仅为一种逻辑功
能划分,实际实现时可以有另外的划分方式,又例如,多个单元或组件可以结合或者可以集
成到另一个系统,或一些特征可以忽略,或不执行。另一点,所显示或讨论的相互之间的耦
合或直接耦合或通信连接可以是通过一些通信接口,装置或单元的间接耦合或通信连接,
可以是电性,机械或其它的形式。
[0187] 所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个
网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目
的。
[0188] 另外,在本申请各个实施例中的各功能单元可以集成在一个处理单元中,也可以是各个单元单独物理存在,也可以两个或两个以上单元集成在一个单元中。
[0189] 所述功能如果以软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在一个处理器可执行的非易失的计算机可读取存储介质中。基于这样的理解,本申请
的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件
产品的形式体现出来,该计算机软件产品存储在一个存储介质中,包括若干指令用以使得
一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行本申请各个实施例所
述方法的全部或部分步骤。而前述的存储介质包括:U盘、移动硬盘、只读存储器(Read‑Only 
Memory,ROM)、随机存取存储器(Random Access Memory,RAM)、磁碟或者光盘等各种可以存
储程序代码的介质。
[0190] 最后应说明的是:以上所述实施例,仅为本申请的具体实施方式,用以说明本申请的技术方案,而非对其限制,本申请的保护范围并不局限于此,尽管参照前述实施例对本申
请进行了详细的说明,本领域的普通技术人员应当理解:任何熟悉本技术领域的技术人员
在本申请揭露的技术范围内,其依然可以对前述实施例所记载的技术方案进行修改或可轻
易想到变化,或者对其中部分技术特征进行等同替换;而这些修改、变化或者替换,并不使
相应技术方案的本质脱离本申请实施例技术方案的精神和范围,都应涵盖在本申请的保护
范围之内。因此,本申请的保护范围应所述以权利要求的保护范围为准。