数据处理方法、直播方法、鉴权服务器及直播数据服务器转让专利

申请号 : CN202110166233.9

文献号 : CN112995686B

文献日 :

基本信息:

PDF:

法律信息:

相似专利:

发明人 : 孙袁袁

申请人 : 上海哔哩哔哩科技有限公司

摘要 :

本申请提供数据处理方法、直播方法、鉴权服务器及直播数据服务器,其中所述数据处理方法包括:获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址;根据预设时长内获取到的所述连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表。如此,结合播放地址和请求地址,综合判断刷量的黑名单地址,避免了误判,从而提高了确定黑名单地址的准确率。

权利要求 :

1.一种数据处理方法,其特征在于,应用于鉴权服务器,包括:获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址,其中,所述播放地址是指用户通过直播平台访问对应直播间的详细播放地址,所述请求地址是指用户的访问地址;

根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;

在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;

在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表。

2.根据权利要求1所述的数据处理方法,其特征在于,所述根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址,包括:

确定每个第一预设时长内获取到的连接参数;

针对获取到的每个所述连接参数,解析所述连接参数包括的播放地址,获取所述播放地址携带的签名字段和直播流标识;将所述签名字段、所述直播流标识和所述连接参数包括的请求地址确定为一组计数对象;

统计不同的计数对象组的数目;

在目标计数对象组的数目大于对象数目阈值的情况下,将所述目标计数对象组中的请求地址确定为第一黑名单地址。

3.根据权利要求2所述的数据处理方法,其特征在于,所述根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址,包括:

确定每个第二预设时长内获取到的连接参数;

针对获取到的每个所述连接参数,根据所述连接参数包括的播放地址携带的直播流标识,确定所述连接参数包括的请求地址访问的直播流;

统计各个所述连接参数包括的请求地址访问各个直播流的次数;

若同一请求地址访问的目标直播流的次数大于次数阈值,则将所述请求地址确定为第二黑名单地址。

4.根据权利要求3所述的数据处理方法,其特征在于,所述将所述请求地址确定为第二黑名单地址之前,还包括:

确定所述请求地址访问的直播流数目是否小于直播流数目阈值;

若是,则执行将所述请求地址确定为第二黑名单地址的操作步骤。

5.根据权利要求3所述的数据处理方法,其特征在于,所述根据所述黑名单地址生成黑名单列表,包括:

在确定出第一黑名单地址和第二黑名单地址的情况下,合并所述第一黑名单地址和所述第二黑名单地址,生成所述黑名单列表。

6.根据权利要求1所述的数据处理方法,其特征在于,所述在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表,包括:确定当前预设时长内,是否存在上一预设时长内不存在的目标黑名单地址;

若是,则将所述目标黑名单地址添加至上一预设时长生成的黑名单列表中,生成当前预设时长对应的黑名单列表。

7.根据权利要求1所述的数据处理方法,其特征在于,所述在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表,包括:在接收到所述直播数据服务器发送的获取请求的情况下,获取当前预设时长对应的目标黑名单列表;

向所述直播数据服务器返回所述目标黑名单列表。

8.一种直播方法,其特征在于,应用于直播数据服务器,包括:在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;

确定所述请求地址是否为预设黑名单列表中的地址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所述请求方返回直播视频流;

向鉴权服务器上报包括所述播放地址和所述请求地址的连接参数,以使鉴权服务器根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址,其中,所述播放地址是指用户通过直播平台访问对应直播间的详细播放地址,所述请求地址是指用户的访问地址。

9.根据权利要求8所述的直播方法,其特征在于,所述在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址之前,还包括:每隔第三预设时长向所述鉴权服务器发送获取请求;

接收所述鉴权服务器返回的黑名单列表,所述黑名单列表为所述鉴权服务器根据预设时长内上报的连接参数包括的播放地址和请求地址生成;

根据所述鉴权服务器返回的黑名单列表更新所述预设黑名单列表。

10.根据权利要求8或9所述的直播方法,其特征在于,所述确定所述请求地址是否为所述黑名单列表中的地址之后,还包括:在所述请求地址为所述黑名单列表中的地址的情况下,拒绝与所述请求方建立连接。

11.一种鉴权服务器,其特征在于,包括:获取模块,被配置为获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址,其中,所述播放地址是指用户通过直播平台访问对应直播间的详细播放地址,所述请求地址是指用户的访问地址;

第一确定模块,被配置为根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;

生成模块,被配置为在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;

返回模块,被配置为在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表。

12.一种直播数据服务器,其特征在于,包括:第二确定模块,被配置为在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;

第三确定模块,被配置为确定所述请求地址是否为预设黑名单列表中的地址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所述请求方返回直播视频流;

上报模块,被配置为向鉴权服务器上报包括所述播放地址和所述请求地址的连接参数,以使鉴权服务器根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址,其中,所述播放地址是指用户通过直播平台访问对应直播间的详细播放地址,所述请求地址是指用户的访问地址。

13.一种直播系统,其特征在于,所述系统包括直播数据服务器和鉴权服务器;

所述直播数据服务器,被配置为在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;确定所述请求地址是否为预设黑名单列表中的地址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所述请求方返回直播视频流;向鉴权服务器上报包括所述播放地址和所述请求地址的连接参数,其中,所述播放地址是指用户通过直播平台访问对应直播间的详细播放地址,所述请求地址是指用户的访问地址;每隔第三预设时长向所述鉴权服务器发送获取请求;

所述鉴权服务器,被配置为获取所述直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址;根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表;

所述直播数据服务器,进一步被配置为接收所述鉴权服务器返回的黑名单列表,根据所述鉴权服务器返回的黑名单列表更新所述预设黑名单列表。

14.根据权利要求13所述的直播系统,其特征在于,所述系统还包括直播平台和调度服务器;

所述直播平台,被配置为向所述调度服务器发送播放请求,所述播放请求携带请求播放的目标直播间的标识;

所述调度服务器,被配置为根据所述播放请求中携带的所述目标直播间的标识,分配所述目标直播间的播放地址,并向所述直播平台返回所述播放地址;

所述直播平台,进一步被配置为获取所述调度服务器返回的所述播放地址,根据所述播放地址,向所述直播数据服务器发送建立连接请求。

15.一种计算设备,其特征在于,包括:存储器和处理器;

所述存储器用于存储计算机可执行指令,所述处理器用于执行所述计算机可执行指令,以实现下述方法:

获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址,其中,所述播放地址是指用户通过直播平台访问对应直播间的详细播放地址,所述请求地址是指用户的访问地址;

根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;

在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;

在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表;

或者,

在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;

确定所述请求地址是否为预设黑名单列表中的地址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所述请求方返回直播视频流;

向鉴权服务器上报包括所述播放地址和所述请求地址的连接参数,以使鉴权服务器根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址,其中,所述播放地址是指用户通过直播平台访问对应直播间的详细播放地址,所述请求地址是指用户的访问地址。

16.一种计算机可读存储介质,其特征在于,其存储有计算机可执行指令,该计算机可执行指令被处理器执行时实现权利要求1至7所述的数据处理方法或者权利要求8‑10任意一项所述直播方法的步骤。

说明书 :

数据处理方法、直播方法、鉴权服务器及直播数据服务器

技术领域

[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] 图1是本申请一实施例提供的一种数据处理方法的流程图;
[0043] 图2是本申请一实施例提供的一种直播方法的流程图;
[0044] 图3是本申请一实施例提供的一种直播数据服务器校验流程示意图;
[0045] 图4是本申请一实施例提供的另一种直播方法的流程图;
[0046] 图5是本申请一实施例提供的一种直播访问流程的示意图;
[0047] 图6是本申请一实施例提供的一种鉴权服务器的结构示意图;
[0048] 图7是本申请一实施例提供的一种直播数据服务器的结构示意图;
[0049] 图8是本申请一实施例提供的一种直播系统的结构示意图;
[0050] 图9是本申请一实施例提供的一种计算设备的结构框图。

具体实施方式

[0051] 在下面的描述中阐述了很多具体细节以便于充分理解本申请。但是本申请能够以很多不同于在此描述的其它方式来实施,本领域技术人员可以在不违背本申请内涵的情况
下做类似推广,因此本申请不受下面公开的具体实施的限制。
[0052] 在本申请一个或多个实施例中使用的术语是仅仅出于描述特定实施例的目的,而非旨在限制本申请一个或多个实施例。在本申请一个或多个实施例和所附权利要求书中所
使用的单数形式的“一种”、“所述”和“该”也旨在包括多数形式,除非上下文清楚地表示其
他含义。还应当理解,本申请一个或多个实施例中使用的术语“和/或”是指并包含一个或多
个相关联的列出项目的任何或所有可能组合。
[0053] 应当理解,尽管在本申请一个或多个实施例中可能采用术语第一、第二等来描述各种信息,但这些信息不应限于这些术语。这些术语仅用来将同一类型的信息彼此区分开。
例如,在不脱离本申请一个或多个实施例范围的情况下,第一也可以被称为第二,类似地,
第二也可以被称为第一。取决于语境,如在此所使用的词语“如果”可以被解释成为“在……
时”或“当……时”或“响应于确定”。
[0054] 首先,对本申请一个或多个实施例涉及的名词术语进行解释。
[0055] 直播流:直播音视频数据的传输,它能够被作为一个稳定的和连续的流通过网络传输给观众观看。
[0056] 推流:主播通过业务服务端(即主播客户端)从直播平台获取到推流地址,将采集的流媒体通过推流地址实时的推送至直播平台的接收端。
[0057] 拉流:拉流是指用户通过直播平台到指定的源站拉取直播流的过程。
[0058] 直播人气:综合观看人数、弹幕数、礼物数等按照一定比例算出的数值,用于在直播平台按照人气的高低进行排名。
[0059] 直播人数:实时观看直播间的真实人数。
[0060] 刷量:通过模拟正常用户访问,产生大量虚假观看的情况,即通过非法手段模拟观看直播间。
[0061] 防刷:通过技术手段,识别非法访问的请求,即识别刷量的黑名单地址的访问请求,并拒绝该非法请求。
[0062] CDN(Content Delivery Network,内容分发网络):是构建在网络之上的内容分发网络,CDN的基本原理是广泛采用各种缓存服务器,将这些缓存服务器分布到用户访问相对
集中的地区或网络中,在用户访问网站时,利用全局负载技术将用户的访问指向距离最近
的工作正常的缓存服务器上,由缓存服务器直接响应用户请求,提高用户访问响应速度和
命中率。CDN的关键技术主要有内容存储技术、内容分发技术和负载均衡技术。
[0063] 带宽:指信号所占据的频带宽度,在被用来描述信道时,带宽是指能够有效通过该信道的信号的最大频带宽度。以比特/秒为单位的带宽也可以指消耗的带宽,对应于实现的
吞吐量,即成功通过通信路径传输的数据的平均速率。在研究的时间间隔内,比特流的带宽
与以赫兹为单位的平均消耗信号带宽(代表比特流的模拟信号的平均频谱带宽)成正比。
[0064] 在本申请中,提供了一种数据处理方法,本申请同时涉及一种直播方法,一种鉴权服务器,一种直播服务器,一种直播系统,一种计算设备,以及一种计算机可读存储介质,在
下面的实施例中逐一进行详细说明。
[0065] 图1示出了根据本申请一实施例提供的一种数据处理方法的流程图,应用于鉴权服务器,具体包括以下步骤:
[0066] 步骤102:获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址。
[0067] 需要说明的是,直播可以通过直播平台推流,从而将采集的流媒体通过推流地址实时的推送至直播平台的接收端;用户可以通过直播平台拉流,即通过直播平台到指定的
源站拉取直播流,从而进行观看。某一直播间实时的观看人数决定了该直播间的人气,而直
播间的直播人数的数据来源计算方式之一是CDN的观看人数,即CDN计算直播流的拉流连接
数作为人数来源。因而,为了模拟正常用户观看直播间,可以通过工具进行实际拉流,伪造
直播间的观看人数,但是持续性拉流会产生带宽,通过大量的模拟连接数不仅会产生虚假
的直播人气,也会产生大量带宽,给直播平台带来损失。
[0068] 实际应用中的防刷方案一般有两种,其一是在统计直播间人气时,扣除刷量人数,但不对刷量情况进行遏制,只能保证直播人气的公平性,无法减少刷量所产生的带宽,导致
不必要的带宽浪费,可能会造成直播平台、直播数据服务器的压力过大,易瘫痪;其二是,由
工作人员在刷量发生后的第二天分析直播日志数据,统计各个请求地址的访问次数,确定
出刷量的黑名单地址,同步给内容分发网络,使其拒绝刷量的黑名单地址的访问,但前一天
的刷量已经产生,无法避免之前刷量带来的带宽成本,时效性低,且非常容易误判,导致确
定刷量的黑名单地址的准确率较低。再者,如学校/住宅区等人口密集区域,为少数几个出
口地址,某一出口地址的访问次数相对较多,仅仅通过统计请求地址的访问次数,确定是否
为刷量的黑名单地址,非常容易误判,进一步导致确定刷量的黑名单地址的准确率较低。
[0069] 因而,本申请中为了提高确定刷量的黑名单地址的时效性和准确性,提供了一种数据处理方法,鉴权服务器可以获取直播数据服务器上报的连接参数,所述连接参数包括
播放地址和请求地址;根据预设时长内获取到的连接参数包括的播放地址和请求地址,确
定所述连接参数包括的请求地址是否为黑名单地址;在所述请求地址为黑名单地址的情况
下,根据所述黑名单地址生成黑名单列表;在接收到所述直播数据服务器发送的获取请求
的情况下,向所述直播数据服务器返回所述黑名单列表。如此,鉴权服务器可以自动对一段
时间的连接参数进行分析处理,确定出刷量的黑名单地址,从而解放了人力,提高了确定黑
名单地址的时效性;且结合播放地址和请求地址,综合判断刷量的黑名单地址,避免了误
判,从而提高了黑名单地址的确定准确率。
[0070] 具体的,直播数据服务器是向直播平台提供直播数据的服务器,即直播数据服务器可以向直播平台返回用户请求观看的视频流,使得用户可以通过直播平台观看想要看的
直播。本申请中以该直播数据服务器为CDN(内容分发网络)为例进行说明。
[0071] 另外,连接参数是直播数据服务器与直播平台建立连接后,向鉴权服务器上报的正常建立的连接的相关参数,使得鉴权服务器可以对获取到的各个连接参数进行统计分
析,确定出刷量的黑名单地址。其中,鉴权服务器用于接收直播数据服务器上报的连接参
数,通过对一段时间内的播放地址和请求地址进行分析统计,确定出是否存在刷量的黑名
单地址,生成并维护刷量的黑名单列表。
[0072] 需要说明的是,用户通过直播平台进入自己想要看的直播间后,直播平台会向调度服务器请求播放地址,用户进入直播间只会请求一次播放地址,且每个用户,每次进入直
播间请求的播放地址都是不同的。因而为了对每次的连接情况进行统计,直播数据服务器
上报的连接参数中可以包括播放地址和请求地址,该播放地址是指用户通过直播平台访问
对应直播间的详细播放地址,如该播放地址可以包括签名字段和直播流标识,即访问直播
间,具体是通过哪个播放地址获取到哪个直播流;请求地址是指用户的访问地址,如请求地
址可以为用户IP。
[0073] 步骤104:根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址。
[0074] 具体的,在获取直播数据服务器上报的连接参数的基础上,进一步的,将根据预设时长内获取到的所述连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求
地址是否为黑名单地址。其中,预设时长是预先设置的时间段,对于不同的统计方式,该预
设时长可以不同,如预设时长可以为1分钟、5分钟或30分钟、1小时等。
[0075] 需要说明的是,由于在一个请求地址刷量的时候,无法直接知道这个请求地址在非法访问,刚开始时访问是正常的,在直播数据服务器上报了足够多的连接参数后,鉴权服
务器才可以发现这个请求地址访问量过大,此时才可以将该请求地址确定为刷量的黑名单
地址。因而,鉴权服务器可以累积直播数据服务器上报的连接参数,每隔预设时长分析一
次,确定是否存在访问过量的黑名单地址。也就是说,以预设时长为一个周期,根据该周期
内获取到的连接参数的播放地址和请求地址,确定该周期内是否存在刷量的黑名单地址。
[0076] 本实施例一个可选的实施方式中,可以以直播流为统计对象,统计一个直播流、一次签名字段、使用同一个请求地址,访问直播间的次数,从而确定黑名单地址,因而根据预
设时长内获取到的所述连接参数包括的播放地址和请求地址,确定所述连接参数包括的请
求地址是否为黑名单地址,具体实现过程可以如下:
[0077] 确定每个第一预设时长内获取到的连接参数;
[0078] 针对获取到的每个所述连接参数,解析所述连接参数包括的播放地址,获取所述播放地址携带的签名字段和直播流标识;将所述签名字段、所述直播流标识和所述连接参
数包括的请求地址确定为一组计数对象;
[0079] 统计不同的计数对象组的数目;
[0080] 在目标计数对象组的数目大于对象数目阈值的情况下,将所述目标计数对象组中的请求地址确定为第一黑名单地址。
[0081] 具体的,第一预设时长是预先设置的时间段,由于第一预设时长是统计一个直播流、一次签名字段、使用同一个请求地址进行访问的次数,从而判断访问是否异常的周期,
因而该第一预设时长应该设置的较小,如第一预设时长可以为1分钟、5分钟等。目标计数对
象组是确定出的计数对象组中出现次数大于对象数目阈值的计数对象组。对象数目阈值是
预先设置的数值,用于判断同一计数对象组出现的次数是否异常,即用于判断一个直播流、
一次签名字段、使用同一请求地址进行访问的次数是否异常,如该对象数目阈值可以为
1000次。
[0082] 需要说明的是,对于正常用户而言,直播平台获取播放地址后,会自动播放,向CDN(即直播数据服务器)发起一次建立连接请求,但是模拟观看(即刷量)需要大量复制该播放
地址,建立大量模拟观看请求,因而CDN会接收到大量同样播放地址的请求,CDN向鉴权服务
器上报的次数也是大量的。也就是说,正常情况下,一个直播流、一次签名字段、使用同一个
请求地址进行访问的次数不会过大,若次数过大,则说明可能存在大量复制该播放地址进
行访问的情况,因而可以将访问次数过量的请求地址确定为刷量的黑名单地址。
[0083] 另外,由于用户网络不好、网络卡顿的情况下,会进行重试,此时一个直播流、一次签名字段、使用同一个请求地址,也会访问多次,但是该数量不会过大,本申请中设置的对
象数目阈值要远远大于用户重试可能产生的访问次数,即该对象数目阈值是人为无法达到
的访问次数,以此排除网络异常的情况,如最多一分钟也不会重试超过100次,此时对象数
目阈值可以设置为1000。
[0084] 实际实现时,对于获取到的直播数据上报服务器上报的连接参数,可以解析其包括的播放地址,得到签名字段和直播流标识,其中签名字段可以为sign字段,该sign字段按
照一定的算法生成,可保证全直播平台唯一,直播流标识可以为stream_name字段,即流名
字段,每条直播流的唯一标识符(一个直播房间对应一个流,成映射关系)。之后,可以以第
一预设时长为周期,以直播流标识+签名字段+请求地址为计数对象组,统计第一预设时长
内每个不同计数对象组出现的次数,如果某一计数对象组(即目标计数对象组)出现的次数
大于对象数目阈值,则说明该计数对象组中的请求地址为非法模拟观看的地址,即刷量的
黑名单地址。
[0085] 示例的,5分钟内获取到的连接参数为:直播流A1、签名字段B1、请求地址C1;直播流A1、签名字段B2、请求地址C2;直播流A1、签名字段B1、请求地址C1;直播流A1、签名字段
B1、请求地址C1;直播流A1、签名字段B1、请求地址C1;直播流A2、签名字段B3、请求地址C3。
由上可知,直播流A1、签名字段B1、请求地址C1的数目为4,直播流A1、签名字段B2、请求地址
C2为1,直播流A2、签名字段B3、请求地址C3为1,假设对象数目阈值为3,则直播流A1、签名字
段B1、请求地址C1为目标计数对象组,请求地址C1为第一黑名单地址。
[0086] 本申请中可以以直播流为统计对象,统计一个直播流、一次签名字段、使用同一个请求地址,访问直播间的次数,从而在一个直播流、一次签名字段、使用同一个请求地址进
行访问的次数过大时,将其中的请求地址确定为刷量的黑名单地址;如此,只有在一个直播
流、一次签名字段、使用同一个请求地址进行访问的次数异常时,才会将其确定为刷量的黑
名单地址,避免了误判,从而提高了黑名单地址的确定准确率。
[0087] 本实施例一个可选的实施方式中,可以以请求地址为统计对象,统计同个时间段内,一个请求地址访问的全部直播流和对应的访问次数,从而确定黑名单地址,因而根据预
设时长内获取到的所述连接参数包括的播放地址和请求地址,确定所述连接参数包括的请
求地址是否为黑名单地址,包括:
[0088] 确定每个第二预设时长内获取到的连接参数;
[0089] 针对获取到的每个所述连接参数,根据所述连接参数包括的播放地址携带的直播流标识,确定所述连接参数包括的请求地址访问的直播流;
[0090] 统计各个所述连接参数包括的请求地址访问各个直播流的次数;
[0091] 若同一请求地址访问的目标直播流的次数大于次数阈值,则将所述请求地址确定为第二黑名单地址。
[0092] 具体的,第二预设时长是预先设置的时间段,由于第二预设时长是统计一个请求地址访问的全部直播流数目和对应的访问次数是否异常的周期,而每个直播间不一定是一
起直播的,只有在直播时间内,才存在刷量行为,因而第二预设时长应该比第一预设时大,
即第二预设时长应该设置的较大,如第二预设时长可以为30分钟、1个小时等。次数阈值是
预先设置的数值,用于判断某一请求地址访问某直播流的次数是否异常,如该次数阈值可
以为1000次。需要说明的是,如果一个请求地址访问一个直播流过大,则说明可能存在大量
复制播放地址以访问该直播流的情况,因而可以将该请求地址确定为刷量的黑名单地址。
[0093] 另外,由于刷量行为受限于服务器带宽/性能等原因,模拟观看多个直播间的观看行为,机器本身无法支撑,需要将原来访问一个直播间的模拟请求,分一部分访问其他直播
间,因而所述次数阈值应该小于所述对象数目阈值。
[0094] 本实施例一个可选的实施方式中,在将所述请求地址确定为第二黑名单地址之前,还包括:
[0095] 确定所述请求地址访问的直播流数目是否小于直播流数目阈值;
[0096] 若是,则执行将所述请求地址确定为第二黑名单地址的操作步骤。
[0097] 具体的,直播流数目阈值是预先设置的数值,用于判断某一请求地址访问的全部直播流的数目是否异常,即访问的直播流的分散情况,如该直播流数目阈值可以为1000个。
需要说明的是,如果一个请求地址访问的全部直播流数目过小且对应的访问次数过大,则
说明可能只针对固定的几个直播间刷量,因而可以将该请求地址确定为刷量的黑名单地
址。
[0098] 需要说明的是,如果是专业从事刷量,则必然会接收很多主播的刷量订单,只会刷固定的几个直播间,也就是说,刷量情况下访问的直播流比较集中,即访问的直播流数目必
然较少。而如果是学校/小区等人员密集的区域,由于喜好的原因,大家会观看不同的直播
间,即访问的直播流比较分散,因而可以结合一个请求地址访问的全部直播流的数目以及
对应的访问次数,精细化识别刷量情况,避免出现误判。
[0099] 实际实现时,对于获取到直播数据上报服务器上报的连接参数,可以解析其包括的播放地址,得到直播流标识,根据该直播流标识可以确定出该请求地址访问的直播流。之
后,可以以第二预设时长为周期,以请求地址为统计对象,统计第二预设时长内各个请求地
址下所有访问的直播流和对应的次数,如果同一请求地址下访问的所有直播流的数目小于
直播流数目阈值,且某个或某些直播流的访问次数大于次数阈值,则说明该请求地址为非
法模拟观看的地址,即刷量的黑名单地址。
[0100] 示例的,30分钟内9.9.9.9这个请求地址下,直播流1访问了100次,直播流2访问了1000次,直播流3访问了40000次。假设直播流数目阈值为100个,次数阈值为500次,由于30
分钟内9.9.9.9这个请求地址共访问了3个直播流,且直播流2和直播流3的访问次数均超过
了次数阈值,因而将请求地址9.9.9.9确定为第二黑名单地址。
[0101] 本申请中可以以请求地址为统计对象,确定请求地址访问的所有直播流及对应的访问次数,从而在某请求地址访问的直播流数目较少,且次数较多时,将该请求地址确定为
刷量的黑名单地址,避免了误判,从而提高了黑名单地址的确定准确率。
[0102] 步骤106:在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表。
[0103] 具体的,在根据预设时长内获取到的所述连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址的基础上,进一步的,将在所述请求
地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表。
[0104] 本实施例一个可选的实施方式中,根据所述黑名单地址生成黑名单列表,具体实现过程可以为:
[0105] 在确定出第一黑名单地址和第二黑名单地址的情况下,合并所述第一黑名单地址和所述第二黑名单地址,生成所述黑名单列表。
[0106] 需要说明的是,可以仅统计一个直播流、一次签名字段、使用同一个请求地址进行访问的次数,确定出第一黑名单地址,仅将第一黑名单地址作为黑名单列表;也可以仅统计
请求地址访问的所有直播流数目及对应的访问次数,确定出第二黑名单地址,仅将第二黑
名单地址作为黑名单列表。还可以结合第一黑名单地址和第二黑名单地址,生成黑名单列
表。
[0107] 具体实现时,若要结合第一黑名单地址和第二黑名单地址,生成黑名单列表,由于生成第一黑名单地址的第一预设时长要大于生成第二黑名单地址的第二预设时长,因而在
仅确定出第一黑名单地址的情况下,可以将确定出的各个第一黑名单地址先作为所述黑名
单列表,在之后确定出第二黑名单地址后,再将确定出的各个第二黑名单地址添加至之前
生成的黑名单列表中。
[0108] 本实施例一个可选的实施方式中,在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表,包括:
[0109] 确定当前预设时长内,是否存在上一预设时长内不存在的目标黑名单地址;
[0110] 若是,则将所述目标黑名单地址添加至上一预设时长生成的黑名单列表中,生成当前预设时长对应的黑名单列表。
[0111] 需要说明的是,由于每隔第一预设时长会确定出第一黑名单地址,且每隔第二预设时长会确定出第二黑名单地址,因而每确定出新的黑名单地址后,需要添加至上一次生
成的黑名单列表中,此时的预设时长为第一预设时长和第二预设时长,即只要达到第一预
设时长或第二预设时长,均更新一次黑名单列表,如此可以不断根据新确定出的黑名单地
址对黑名单列表进行更新,保证生成的黑名单列表的实时性。
[0112] 步骤108:在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表。
[0113] 具体的,在根据所述黑名单地址生成黑名单列表的基础上,进一步的,将在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列
表。
[0114] 本实施例一个可选的实施方式中,在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表,具体实现过程可以如下:
[0115] 在接收到所述直播数据服务器发送的获取请求的情况下,获取当前第一预设时长对应的目标黑名单列表;
[0116] 向所述直播数据服务器返回所述目标黑名单列表。
[0117] 需要说明的是,直播数据服务器会定时从鉴权服务器中读取黑名单列表,用于后续连接请求的校验,因而鉴权服务器在接收到获取请求时,可以向直播数据服务器返回最
新生成的黑名单列表,即根据当前预设时长内获取到的连接参数生成的黑名单列表。
[0118] 本申请提供一种数据处理方法,鉴权服务器可以获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址;在每个第一预设时长,根据获取到的连接参
数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;在
所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;在接收到所
述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列
表。这种情况下,直播数据服务器与直播平台建立连接后,可以将对应的连接参数实时上报
给鉴权服务器,鉴权服务器可以统计一段时间内一个直播流、一次签名字段、使用同一个请
求地址进行访问的次数,还可以进一步统计请求地址访问的所有直播流及对应的访问次
数,根据两个统计结果综合确定上报的连接参数中是否存在刷量的黑名单地址,从而生成
黑名单列表,返回给直播数据服务器,用于后续连接请求的校验。如此,可以以直播流为对
象进行统计,进一步结合以请求地址为对象的统计结果,即同一请求地址访问直播流的分
散情况,精细化统计用户的访问行为,避免了误判,从而提高了黑名单地址的确定准确率,
且时效性较高。另外,鉴权服务器还可以将自身维护的黑名单列表同步给各个直播数据服
务器,从而达到防刷目的,节省带宽且时效性高,降低直播平台和直播数据服务器的处理压
力。
[0119] 图2示出了根据本申请一实施例提供的一种直播方法的流程图,应用于直播数据服务器,具体包括以下步骤:
[0120] 步骤202:在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址。
[0121] 实际应用中的防刷手段一般都是刷量情况发生后的第二天或者后续计算直播人气的时候,才会确定相应的刷量数目,再进行扣除,此种方式时效性较差,只能保证直播人
气的公平性,无法避免刷量带来的带宽浪费。
[0122] 因而,为了节省带宽,本申请提供了一种直播方法,直播数据服务器在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;确定所述请求地
址是否为预设黑名单列表中的地址,在所述请求地址不为所述预设黑名单列表中的地址的
情况下,与请求方建立连接,向所述请求方返回直播视频流;并向鉴权服务器上报包括所述
播放地址和所述请求地址的连接参数。如此,只有不是刷量的黑名单地址的正常用户才可
以与直播数据服务器建立连接,观看直播,从拉流根源上限制刷量的非法访问,断开刷量的
非法连接,避免了刷量产生不必要的带宽,防止刷量,节省带宽且时效性高,降低直播平台
和直播数据服务器的处理压力。
[0123] 具体的,建立连接请求是直播平台根据获取到的播放地址(即签名字段和直播流标识)发起的请求,用于请求和直播数据服务器建立连接,从而获取直播视频流,因而该建
立连接请求中会携带对应的请求地址和播放地址,用于后续向鉴权服务器上报连接参数。
[0124] 本实施例一个可选的实施方式中,直播数据服务器可以定时从鉴权服务器中读取黑名单列表,以对接收到的建立连接请求进行鉴权,因而所述在接收到建立连接请求的情
况下,确定所述建立连接请求对应的请求地址和播放地址之前,还包括:
[0125] 每隔第三预设时长向所述鉴权服务器发送获取请求;
[0126] 接收所述鉴权服务器返回的黑名单列表,所述黑名单列表为所述鉴权服务器根据预设时长内上报的连接参数包括的播放地址和请求地址生成;
[0127] 根据所述鉴权服务器返回的黑名单列表更新所述预设黑名单列表。
[0128] 具体的,第三预设时长是预先设置的时间段,该第三预设时长是直播数据服务器从鉴权服务器中读取黑名单列表的时间间隔,如每10分钟读取一次,第三预设时长为10分
钟。
[0129] 需要说明的是,直播数据服务器中可以预设有一个黑名单列表,该黑名单列表可以为空,也可以包括一些被公开的黑名单地址,后续再根据从鉴权服务器中读取的黑名单
列表对预设的黑名单列表进行实时更新,从而保证实现防刷的时效性。
[0130] 步骤204:确定所述请求地址是否为预设黑名单列表中的地址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所述请求方返回直播视
频流。
[0131] 具体的,请求方是指发送建立连接请求的一方,如直播平台。需要说明的是,直播数据服务器在接收到建立连接请求后,可以对该建立连接请求中的请求地址进行校验,确
定其是否为黑名单列表中的黑名单地址,若建立连接请求中的请求地址不是黑名单地址,
则说明当前该请求地址是正常用户的访问地址,允许其建立连接,观看直播,向请求方返回
直播视频流。
[0132] 本实施例一个可选的实施方式中,确定所述请求地址是否为所述黑名单列表中的地址之后,还包括:
[0133] 在所述请求地址为所述黑名单列表中的地址的情况下,拒绝与所述请求方建立连接。
[0134] 实际应用中,在直播数据服务器确定出请求地址为黑名单列表中的地址时,不需要再将此建立连接请求发送到鉴权服务器,因为已经达到了禁止访问的目的。
[0135] 需要说明的是,若建立连接请求中的请求地址是黑名单地址,则说明当前该请求地址是非法的访问地址(即刷量的访问地址),拒绝与其建立连接,禁止其访问,从而从拉流
根源上限制刷量的非法访问,断开刷量的非法连接,避免了刷量产生不必要的带宽,防止刷
量,节省带宽且时效性高,降低直播平台和直播数据服务器的处理压力。
[0136] 步骤206:向鉴权服务器上报包括所述播放地址和所述请求地址的连接参数。
[0137] 需要说明的是,由于在一个请求地址刷量的时候,无法直接知道这个请求地址是非法访问,刚开始时访问是正常的,在直播数据服务器上报了足够多的连接参数后,鉴权服
务器才可以发现这个请求地址访问量过大,此时才可以将该请求地址确定为刷量的黑名单
地址。因而,直播数据服务器在建立连接请求通过校验,允许与请求方建立连接后,还可以
进一步将建立的连接对应的连接参数上报给鉴权服务器,使得鉴权服务器可以累积数据,
分析是否存在刷量的黑名单地址,从而更新黑名单列表,保证从鉴权服务器获取到的黑名
单列表的时效性和准确性。
[0138] 示例的,图3是本申请一实施例提供的一种直播数据服务器校验流程示意图,如图3所示,直播数据服务器定时读取鉴权服务器生成的黑名单列表,得到更新后的预设黑名单
列表。在用户通过直播平台发起建立连接请求时,直播数据服务器确定该建立连接请求是
否为黑名单地址,若是,则拒绝与请求方建立连接(即拒绝本次拉流),用户无法观看直播;
若否,则允许与请求方建立连接,用户正常观看,并向鉴权服务器上报该建立连接请求的连
接参数。
[0139] 本申请提供的直播方法,直播数据服务器在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;确定所述请求地址是否为预设黑名单列表
中的地址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连
接,向所述请求方返回直播视频流;并向鉴权服务器上报包括所述播放地址和所述请求地
址的连接参数。如此,只有不是刷量的黑名单地址的正常用户才可以与直播数据服务器建
立连接,观看直播,从拉流根源上限制刷量的非法访问,断开刷量的非法连接,避免了刷量
产生不必要的带宽,防止刷量,节省带宽且时效性高,降低直播平台和直播数据服务器的处
理压力。
[0140] 图4示出了根据本申请一实施例提供的一种直播方法的流程图,具体包括以下步骤:
[0141] 步骤402:直播平台向调度服务器发送播放请求,所述播放请求携带请求播放的目标直播间的标识。
[0142] 步骤404:调度服务器根据所述播放请求中携带的所述目标直播间的标识,分配所述目标直播间的播放地址,并向所述直播平台返回所述播放地址。
[0143] 步骤406:直播平台获取所述调度服务器返回的所述播放地址,根据所述播放地址,向直播数据服务器发送建立连接请求。
[0144] 步骤408:直播数据服务器每隔第三预设时长向所述鉴权服务器发送获取请求,并接收所述鉴权服务器返回的黑名单列表,根据所述鉴权服务器返回的黑名单列表更新预设
黑名单列表。
[0145] 步骤410:直播数据服务器在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;确定所述请求地址是否为预设黑名单列表中的地址,在所
述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所述请求
方返回直播视频流;并向鉴权服务器上报包括所述播放地址和所述请求地址的连接参数。
[0146] 步骤412:鉴权服务器获取所述直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址;根据预设时长内获取到的连接参数包括的播放地址和请求地址,
确定所述连接参数包括的请求地址是否为黑名单地址;在所述请求地址为黑名单地址的情
况下,根据所述黑名单地址生成黑名单列表。
[0147] 步骤414:在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表。
[0148] 需要说明的是,用户进入直播间,直播平台自动向调度服务器请求该直播间的播放地址,调度系统可以根据播放请求中目标直播间的标识,分配该直播间对应的播放地址,
该播放地址中包括签名字段地段(sign字段)和直播流标识字段(stream_name字段)。直播
平台获取到调度系统返回的播放地址后,存在两种操作方式,其一是正常用户直接在直播
平台正常播放观看,即直播平台的播放器自动向直播数据服务器请求建立链接,待直播数
据服务器校验播放请求合法后,即可观看;其二是非法模拟观看用户,复制播放地址,通过
工具,批量请求该播放地址,向直播数据服务器请求建立连接,待直播数据服务器校验播放
请求合法后,即可观看。因而直播数据服务器在接收到建立连接请求后,需要判断该请求是
正常的访问请求,还是非法刷量的访问请求,从而确定是否允许访问。
[0149] 示例的,图5是本申请一实施例提供的一种直播访问流程的示意图,如图5所示,用户进入直播间,直播平台向调度服务器请求播放地址,调度服务器分配并返回播放地址;直
播平台获取到该播放地址后,向CDN发起建立连接请求,CDN根据黑名单列表确定并返回是
否允许建立连接;直播平台接收到CDN返回的是否允许建立连接,向用户返回是否允许观
看。
[0150] 本申请提供的直播方法,直播数据服务器在接收到建立连接请求后,可以对该建立连接请求中的请求地址进行校验,确定其是否为黑名单列表中的黑名单地址,若建立连
接请求中的请求地址不是黑名单地址,则说明当前该请求地址是正常用户的访问地址,允
许其建立连接,观看直播;若是黑名单地址,则说明当前该请求地址是非法刷量的访问地
址,拒绝与其建立连接,禁止观看直播。如此,只有不是刷量的黑名单地址的正常用户才可
以与直播数据服务器建立连接,观看直播,从拉流根源上限制刷量的非法访问,断开刷量的
非法连接,避免了刷量产生不必要的带宽,防止刷量,节省带宽且时效性高,降低直播平台
和直播数据服务器的处理压力。
[0151] 与上述方法实施例相对应,本申请还提供了鉴权服务器实施例,图6示出了本申请一实施例提供的一种鉴权服务器的结构示意图。如图6所示,该服务器包括:
[0152] 获取模块602,被配置为获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址;
[0153] 第一确定模块604,被配置为根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;
[0154] 生成模块606,被配置为在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;
[0155] 返回模块608,被配置为在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表。
[0156] 可选地,第一确定模块604进一步被配置为:
[0157] 确定每个第一预设时长内获取到的连接参数;
[0158] 针对获取到的每个所述连接参数,解析所述连接参数包括的播放地址,获取所述播放地址携带的签名字段和直播流标识;将所述签名字段、所述直播流标识和所述连接参
数包括的请求地址确定为一组计数对象;
[0159] 统计不同的计数对象组的数目;
[0160] 在目标计数对象组的数目大于对象数目阈值的情况下,将所述目标计数对象组中的请求地址确定为第一黑名单地址。
[0161] 可选地,第一确定模块604进一步被配置为:
[0162] 确定每个第二预设时长内获取到的连接参数;
[0163] 针对获取到的每个所述连接参数,根据所述连接参数包括的播放地址携带的直播流标识,确定所述连接参数包括的请求地址访问的直播流;
[0164] 统计各个所述连接参数包括的请求地址访问各个直播流的次数;
[0165] 若同一请求地址访问的目标直播流的次数大于次数阈值,则将所述请求地址确定为第二黑名单地址。
[0166] 可选地,第一确定模块604进一步被配置为:
[0167] 确定所述请求地址访问的直播流数目是否小于直播流数目阈值;
[0168] 若是,则执行将所述请求地址确定为第二黑名单地址的操作步骤。
[0169] 可选地,生成模块606进一步被配置为:
[0170] 在确定出第一黑名单地址和第二黑名单地址的情况下,合并所述第一黑名单地址和所述第二黑名单地址,生成所述黑名单列表。
[0171] 可选地,生成模块606进一步被配置为:
[0172] 确定当前预设时长内,是否存在上一预设时长内不存在的目标黑名单地址;
[0173] 若是,则将所述目标黑名单地址添加至上一预设时长生成的黑名单列表中,生成当前预设时长对应的黑名单列表。
[0174] 可选地,返回模块608进一步被配置为:
[0175] 在接收到所述直播数据服务器发送的获取请求的情况下,获取当前预设时长对应的目标黑名单列表;
[0176] 向所述直播数据服务器返回所述目标黑名单列表。
[0177] 本申请提供一种鉴权服务器,可以获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址;在每个第一预设时长,根据获取到的连接参数包括的播
放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;在所述请求地
址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;在接收到所述直播数据
服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表。这种情况
下,直播数据服务器与直播平台建立连接后,可以将对应的连接参数实时上报给鉴权服务
器,鉴权服务器可以统计一段时间内在一个直播流、一次签名字段、使用同一个请求地址进
行访问的次数,还可以进一步统计请求地址访问的所有直播流及对应的访问次数,根据两
个统计结果综合确定上报的连接参数中是否存在刷量的黑名单地址,从而生成黑名单列
表,返回给直播数据服务器,用于后续连接请求的校验。如此,可以通过以直播流为对象进
行统计,进一步结合以请求地址为对象的统计结果,即同一请求地址访问直播流的分散情
况,精细化统计用户的访问行为,避免了误判,从而提高了黑名单地址的确定准确率,且时
效性较高。另外,鉴权服务器还可以将自身维护的黑名单列表同步给各个直播数据服务器,
从而达到防刷目的,节省带宽且时效性高,降低直播平台和直播数据服务器的处理压力。
[0178] 上述为本实施例的一种鉴权服务器的示意性方案。需要说明的是,该鉴权服务器的技术方案与上述的数据处理方法的技术方案属于同一构思,鉴权服务器的技术方案未详
细描述的细节内容,均可以参见上述数据处理方法的技术方案的描述。
[0179] 与上述方法实施例相对应,本申请还提供了直播数据服务器实施例,图7示出了本申请一实施例提供的一种直播数据服务器的结构示意图。如图7所示,该服务器包括:
[0180] 第二确定模块702,被配置为在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;
[0181] 第三确定模块704,被配置为确定所述请求地址是否为预设黑名单列表中的地址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所述
请求方返回直播视频流;
[0182] 上报模块706,被配置为向鉴权服务器上报包括所述播放地址和所述请求地址的连接参数。
[0183] 可选地,所述服务器还包括更新模块,所述更新模块被配置为:
[0184] 每隔第三预设时长向所述鉴权服务器发送获取请求;
[0185] 接收所述鉴权服务器返回的黑名单列表,所述黑名单列表为所述鉴权服务器根据预设时长内上报的连接参数包括的播放地址和请求地址生成;
[0186] 根据所述鉴权服务器返回的黑名单列表更新所述预设黑名单列表。
[0187] 可选地,所述服务器还包括:
[0188] 拒绝模块,被配置为在所述请求地址为所述黑名单列表中的地址的情况下,拒绝与所述请求方建立连接。
[0189] 本申请提供的直播数据服务器,在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;确定所述请求地址是否为预设黑名单列表中的地
址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所
述请求方返回直播视频流;并向鉴权服务器上报包括所述播放地址和所述请求地址的连接
参数。如此,只有不是刷量的黑名单地址的正常用户才可以与直播数据服务器建立连接,观
看直播,从拉流根源上限制刷量的非法访问,断开刷量的非法连接,避免了刷量产生不必要
的带宽,防止刷量,节省带宽且时效性高,降低直播平台和直播数据服务器的处理压力。
[0190] 上述为本实施例的一种直播数据服务器的示意性方案。需要说明的是,该直播数据服务器的技术方案与上述的直播方法的技术方案属于同一构思,直播数据服务器的技术
方案未详细描述的细节内容,均可以参见上述直播方法的技术方案的描述。
[0191] 与上述方法实施例相对应,本申请还提供了直播系统实施例,图8示出了本申请一实施例提供的一种直播系统的结构示意图。如图8所示,该系统包括直播数据服务器802和
鉴权服务器804;
[0192] 所述直播数据服务器802,被配置为在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;确定所述请求地址是否为预设黑名单列表中的地
址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所
述请求方返回直播视频流;向鉴权服务器上报包括所述播放地址和所述请求地址的连接参
数;每隔第三预设时长向所述鉴权服务器发送获取请求;
[0193] 所述鉴权服务器804,被配置为获取所述直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址;根据预设时长内获取到的连接参数包括的播放地址和请
求地址,确定所述连接参数包括的请求地址是否为黑名单地址;在所述请求地址为黑名单
地址的情况下,根据所述黑名单地址生成黑名单列表;在接收到所述直播数据服务器发送
的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表;
[0194] 所述直播数据服务器802,进一步被配置为接收所述鉴权服务器返回的黑名单列表,根据所述鉴权服务器返回的黑名单列表更新所述预设黑名单列表。
[0195] 可选地,所述系统还包括直播平台和调度服务器;
[0196] 所述直播平台,被配置为向所述调度服务器发送播放请求,所述播放请求携带请求播放的目标直播间的标识;
[0197] 所述调度服务器,被配置为根据所述播放请求中携带的所述目标直播间的标识,分配所述目标直播间的播放地址,并向所述直播平台返回所述播放地址;
[0198] 所述直播平台,进一步被配置为获取所述调度服务器返回的所述播放地址,根据所述播放地址,向所述直播数据服务器发送建立连接请求。
[0199] 本申请提供的直播系统,直播数据服务器在接收到建立连接请求后,可以对该建立连接请求中的请求地址进行校验,确定其是否为黑名单列表中的黑名单地址,若建立连
接请求中的请求地址不是黑名单地址,则说明当前该请求地址是正常用户的访问地址,允
许其建立连接,观看直播;若是黑名单地址,则说明当前该请求地址是非法刷量的访问地
址,拒绝与其建立连接,禁止观看直播。如此,只有不是刷量的黑名单地址的正常用户才可
以与直播数据服务器建立连接,观看直播,从拉流根源上限制刷量的非法访问,断开刷量的
非法连接,避免了刷量产生不必要的带宽,防止刷量,节省带宽且时效性高,降低直播平台
和直播数据服务器的处理压力。
[0200] 上述为本实施例的一种直播系统的示意性方案。需要说明的是,该直播系统的技术方案与上述的数据处理方法、直播方法的技术方案属于同一构思,直播系统的技术方案
未详细描述的细节内容,均可以参见上述数据处理方法、直播方法的技术方案的描述。
[0201] 图9示出了根据本申请一实施例提供的一种计算设备900的结构框图。该计算设备900的部件包括但不限于存储器910和处理器920。处理器920与存储器910通过总线930相连
接,数据库950用于保存数据。
[0202] 计算设备900还包括接入设备940,接入设备940使得计算设备900能够经由一个或多个网络960通信。这些网络的示例包括公用交换电话网(PSTN)、局域网(LAN)、广域网
(WAN)、个域网(PAN)或诸如因特网的通信网络的组合。接入设备940可以包括有线或无线的
任何类型的网络接口(例如,网络接口卡(NIC))中的一个或多个,诸如IEEE802.11无线局域
网(WLAN)无线接口、全球微波互联接入(Wi‑MAX)接口、以太网接口、通用串行总线(USB)接
口、蜂窝网络接口、蓝牙接口、近场通信(NFC)接口,等等。
[0203] 在本申请的一个实施例中,计算设备900的上述部件以及图9中未示出的其他部件也可以彼此相连接,例如通过总线。应当理解,图9所示的计算设备结构框图仅仅是出于示
例的目的,而不是对本申请范围的限制。本领域技术人员可以根据需要,增添或替换其他部
件。
[0204] 计算设备900可以是任何类型的静止或移动计算设备,包括移动计算机或移动计算设备(例如,平板计算机、个人数字助理、膝上型计算机、笔记本计算机、上网本等)、移动
电话(例如,智能手机)、可佩戴的计算设备(例如,智能手表、智能眼镜等)或其他类型的移
动设备,或者诸如台式计算机或PC的静止计算设备。计算设备900还可以是移动式或静止式
的服务器。
[0205] 其中,处理器920用于执行如下计算机可执行指令,以实现下述方法:
[0206] 获取直播数据服务器上报的连接参数,所述连接参数包括播放地址和请求地址;
[0207] 根据预设时长内获取到的连接参数包括的播放地址和请求地址,确定所述连接参数包括的请求地址是否为黑名单地址;
[0208] 在所述请求地址为黑名单地址的情况下,根据所述黑名单地址生成黑名单列表;
[0209] 在接收到所述直播数据服务器发送的获取请求的情况下,向所述直播数据服务器返回所述黑名单列表;
[0210] 或者,
[0211] 在接收到建立连接请求的情况下,确定所述建立连接请求对应的请求地址和播放地址;
[0212] 确定所述请求地址是否为预设黑名单列表中的地址,在所述请求地址不为所述预设黑名单列表中的地址的情况下,与请求方建立连接,向所述请求方返回直播视频流;
[0213] 向鉴权服务器上报包括所述播放地址和所述请求地址的连接参数。
[0214] 上述为本实施例的一种计算设备的示意性方案。需要说明的是,该计算设备的技术方案与上述的数据处理方法、直播方法的技术方案属于同一构思,计算设备的技术方案
未详细描述的细节内容,均可以参见上述数据处理方法、直播方法的技术方案的描述。
[0215] 本申请一实施例还提供一种计算机可读存储介质,其存储有计算机指令,该指令被处理器执行时以用于实现所述数据处理方法或直播方法的操作步骤。
[0216] 上述为本实施例的一种计算机可读存储介质的示意性方案。需要说明的是,该存储介质的技术方案与上述的数据处理方法、直播方法的技术方案属于同一构思,存储介质
的技术方案未详细描述的细节内容,均可以参见上述数据处理方法、直播方法的技术方案
的描述。
[0217] 上述对本申请特定实施例进行了描述。其它实施例在所附权利要求书的范围内。在一些情况下,在权利要求书中记载的动作或步骤可以按照不同于实施例中的顺序来执行
并且仍然可以实现期望的结果。另外,在附图中描绘的过程不一定要求示出的特定顺序或
者连续顺序才能实现期望的结果。在某些实施方式中,多任务处理和并行处理也是可以的
或者可能是有利的。
[0218] 所述计算机指令包括计算机程序代码,所述计算机程序代码可以为源代码形式、对象代码形式、可执行文件或某些中间形式等。所述计算机可读介质可以包括:能够携带所
述计算机程序代码的任何实体或装置、记录介质、U盘、移动硬盘、磁碟、光盘、计算机存储
器、只读存储器(ROM,Read‑Only Memory)、随机存取存储器(RAM,Random Access Memory)、
电载波信号、电信信号以及软件分发介质等。需要说明的是,所述计算机可读介质包含的内
容可以根据司法管辖区内立法和专利实践的要求进行适当的增减,例如在某些司法管辖
区,根据立法和专利实践,计算机可读介质不包括电载波信号和电信信号。
[0219] 需要说明的是,对于前述的各方法实施例,为了简便描述,故将其都表述为一系列的动作组合,但是本领域技术人员应该知悉,本申请并不受所描述的动作顺序的限制,因为
依据本申请,某些步骤可以采用其它顺序或者同时进行。其次,本领域技术人员也应该知
悉,说明书中所描述的实施例均属于优选实施例,所涉及的动作和模块并不一定都是本申
请所必须的。
[0220] 在上述实施例中,对各个实施例的描述都各有侧重,某个实施例中没有详述的部分,可以参见其它实施例的相关描述。
[0221] 以上公开的本申请优选实施例只是用于帮助阐述本申请。可选实施例并没有详尽叙述所有的细节,也不限制该发明仅为所述的具体实施方式。显然,根据本申请的内容,可
作很多的修改和变化。本申请选取并具体描述这些实施例,是为了更好地解释本申请的原
理和实际应用,从而使所属技术领域技术人员能很好地理解和利用本申请。本申请仅受权
利要求书及其全部范围和等效物的限制。