集群节点分流方法、装置、计算设备及存储介质与流程

1.本技术涉及计算机技术领域，具体涉及一种集群节点分流方法、装置、计算设备及存储介质。


背景技术：

2.目前，集群分流方案一般是利用负载均衡的方式，将外部发送的请求均匀分配到集群的服务器上，配合内容分发网络进行加速，保持服务器集群的整体性能。
3.但是，集群负载均衡的方式适用于长链接，基于短连接的直播模式的数据一般是文件形式的，负载均衡措施容易将多个节点接收到的针对某些热度较高的直播文件请求分配到一台服务器上，通过该服务器进行回源，会对后端的部分机器造成比较大的压力，容易导致单个节点不可用。


技术实现要素：

4.本技术实施例的目的是提供一种集群节点分流方法、装置、计算设备及存储介质，以解决现有技术中多个节点接收到的针对于同一直播文件的请求被汇聚到单独一个节点上进行回源容易造成节点不可用的问题。
5.根据本技术的一个方面，提供了一种集群节点分流方法，包括：
6.接收用户端发起的直播文件请求；
7.检测已缓存的有效节点列表是否已经过期，若已经过期，触发向存储服务器请求更新有效节点列表，对更新后的有效节点列表进行缓存并设定有效期；其中，存储服务器定时刷新有效节点列表；
8.从更新后的有效节点列表包含的多个有效节点中筛选汇聚节点；
9.将直播文件请求转发至汇聚节点，以供汇聚节点发起直播文件的回源请求。
10.在一种可选的方式中，从更新后的有效节点列表包含的多个有效节点中筛选汇聚节点进一步包括：
11.根据更新后的有效节点列表包含的多个有效节点的节点信息以及直播文件请求的文件标识信息，进行一致性哈希计算，根据计算结果确定汇聚节点。
12.在一种可选的方式中，方法进一步包括：
13.定时向存储服务器上报性能信息，以供存储服务器根据集群内各个节点上报的性能信息，识别各个节点中的各个有效节点，将各个有效节点的节点信息更新至有效节点列表中。
14.在一种可选的方式中，接收用户端发起的直播文件请求之后，方法还包括：
15.判断直播文件的直播热度是否满足预设条件；
16.检测已缓存的有效节点列表是否已经过期进一步包括：
17.在直播文件的直播热度满足预设条件的情况下，检测已缓存的有效节点列表是否已经过期。
18.在一种可选的方式中，方法进一步包括：
19.在直播文件的直播热度不满足预设条件的情况下，发起对直播文件的回源请求。
20.在一种可选的方式中，性能信息包括以下信息中的一项或多项：带宽信息、内存信息、cpu信息、磁盘信息、负载信息。
21.在一种可选的方式中，对更新后的有效节点列表设定有效期进一步包括：
22.根据有效期配置信息，设定更新后的有效节点列表的有效期。
23.根据本技术的另一方面，提供了一种集群节点分流装置，包括：
24.接收模块，适于接收用户端发起的直播文件请求；
25.检测模块，适于检测已缓存的有效节点列表是否已经过期；
26.请求模块，适于若已经过期，触发向存储服务器请求更新有效节点列表；
27.处理模块，适于对更新后的有效节点列表进行缓存并设定有效期；其中，存储服务器定时刷新有效节点列表；
28.筛选模块，适于从更新后的有效节点列表包含的多个有效节点中筛选汇聚节点；
29.发送模块，适于将直播文件请求转发至汇聚节点，以供汇聚节点发起直播文件的回源请求。
30.在一种可选的方式中，筛选模块进一步适于：根据更新后的有效节点列表包含的多个有效节点的节点信息以及直播文件请求的文件标识信息，进行一致性哈希计算，根据计算结果确定汇聚节点。
31.在一种可选的方式中，装置还包括上报模块，适于定时向存储服务器上报性能信息，以供存储服务器根据集群内各个节点上报的性能信息，识别各个节点中的各个有效节点，将各个有效节点的节点信息更新至有效节点列表中。
32.在一种可选的方式中，装置还包括热度判断模块，适于判断直播文件的直播热度是否满足预设条件；
33.检测模块进一步适于：在直播文件的直播热度满足预设条件的情况下，检测已缓存的有效节点列表是否已经过期。
34.在一种可选的方式中，装置还包括回源模块，适于在直播文件的直播热度不满足预设条件的情况下，发起对直播文件的回源请求。
35.在一种可选的方式中，性能信息包括以下信息中的一项或多项：带宽信息、内存信息、cpu信息、磁盘信息、负载信息。
36.在一种可选的方式中，处理模块进一步适于：根据有效期配置信息，设定更新后的有效节点列表的有效期。
37.根据本技术的又一方面，提供了一种计算设备，包括：处理器、存储器、通信接口和通信总线，所述处理器、所述存储器和所述通信接口通过所述通信总线完成相互间的通信；
38.所述存储器用于存放至少一可执行指令，所述可执行指令使所述处理器执行上述集群节点分流方法对应的操作。
39.根据本技术的再一方面，提供了一种计算机存储介质，所述存储介质中存储有至少一可执行指令，所述可执行指令使处理器执行如上述集群节点分流方法对应的操作。
40.根据本技术的集群节点分流方法、装置、计算设备及存储介质，当检测已缓存的有效节点列表已经过期时，则确定为更新汇聚节点的时机，向存储服务器请求更新有效节点
列表，根据更新后的有效节点列表重新筛选汇聚节点。各个节点所缓存的有效节点列表是动态变化的，且直播文件请求到达各个节点的时间不一致，使得直播文件请求到达各个节点时节点所缓存的有效节点列表也是不一致的，进而使得各个节点所计算出的汇聚节点是不一致的，能够避免多个对于同一个直播文件的请求被分配到单独一个汇聚节点的情况，能够实现将同一个直播文件的多个请求分配到不同的汇聚节点，通过集群中的多个汇聚节点分散请求回源，避免造成集群中单独某个节点所承载的压力过大的情况，保证单个节点的可用性，进而保证集群的可用性；进一步地，对于热门直播文件的请求通过汇聚模式进行回源，对于非热门直播文件的请求在节点本地进行回源，能够通过集群中的多个汇聚节点分散热门直播文件的回源请求，同时也能够避免不必要的计算，保证整个集群的性能。
41.上述说明仅是本技术技术方案的概述，为了能够更清楚了解本技术的技术手段，而可依照说明书的内容予以实施，并且为了让本技术的上述和其它目的、特征和优点能够更明显易懂，以下特举本技术的具体实施方式。
附图说明
42.通过阅读下文优选实施方式的详细描述，各种其他的优点和益处对于本领域普通技术人员将变得清楚明了。附图仅用于示出优选实施方式的目的，而并不认为是对本技术的限制。而且在整个附图中，用相同的参考符号表示相同的部件。在附图中：
43.图1示出了本技术实施例提供的集群节点分流方法的流程图；
44.图2示出了本技术另一实施例提供的集群节点分流方法的流程图；
45.图3a示出了单节点汇聚模式的示意图；
46.图3b示出了多层汇聚模式的示意图；
47.图4示出了本技术实施例提供的集群节点分流装置的结构示意图；
48.图5示出了本技术实施例提供的计算设备的结构示意图。
具体实施方式
49.下面将参照附图更详细地描述本技术的示例性实施例。虽然附图中显示了本技术的示例性实施例，然而应当理解，可以以各种形式实现本技术而不应被这里阐述的实施例所限制。相反，提供这些实施例是为了能够更透彻地理解本技术，并且能够将本技术的范围完整的传达给本领域的技术人员。
50.首先，对本技术一个或多个实施例涉及的名词术语进行解释。
51.集群：分布式系统的一种形式，由多个独立计算机(节点)组成的。这些计算机通过互联网相互连接，并且可以共同完成一项任务。集群可以用于多个应用场景，例如分布式计算、存储和数据库等。在集群中，每个计算机都可以处理不同的任务，从而提高系统的性能和效率。
52.内容分发网络：(content delivery network，cdn)，是一种分布式的网络，将内容分布在全球范围内多个数据中心中。每个数据中心都运行着多个服务器，这些服务器通过网络相互连接，将网络流量分散到各个服务器上，提高网站性能，减少响应时间，提高用户体验。
53.短链接：一种链接到网站或网页的链接，通常只有几秒钟或几分钟的时间。短链接
通常用于提高网站的加载速度，因为它们比长链接更短，所以它们可以更快地加载。短链接通常由网站管理员手动添加到网站，并且可以通过更改url(uniform resource locator，统一资源定位器)来更改链接。一些网站可能使用自动的短链接生成器，这些工具会自动生成短链接，从而节省时间和精力。
54.一致性哈希：一种用于确定散列值(hash)的算法，用于在分布式系统中实现安全的散列函数。
55.直播文件：短连接的直播形式中，直播数据以文件形式出现。
56.图1示出了本技术实施例提供的集群节点分流方法的流程图，该方法应用于任意具有计算能力的设备中，本技术实施例的方法应用于节点本地未缓存所请求的直播文件需要进行回源的场景。如图1所示，方法包括以下步骤：
57.步骤s110，接收用户端发起的直播文件请求。
58.步骤s120，检测已缓存的有效节点列表是否已经过期，若已经过期，触发向存储服务器请求更新有效节点列表，对更新后的有效节点列表进行缓存并设定有效期。
59.有效节点列表中记录有集群中的多个有效节点的相关信息，并且，有效节点列表是定时刷新的，使得有效节点列表能够记录集群中实时的有效可用的节点。
60.当检测到本地缓存的有效节点列表已经过期时，此时为更新汇聚节点的时机，触发向存储服务器请求更新有效节点列表，以便通过请求到的更新后的有效节点列表重新计算汇聚节点，对请求到的更新后的有效节点列表进行缓存，并对缓存的更新后的有效节点列表设置有效期。
61.步骤s130，从更新后的有效节点列表包含的多个有效节点中筛选汇聚节点。
62.通过预设算法进行计算，以从更新后的有效节点列表包含的多个有效节点中筛选出汇聚节点。需要说明的是，对于接收到针对于同一直播文件的请求的多个不同节点而言，若多个不同的节点根据同样的有效节点列表筛选汇聚节点，则多个不同的节点所筛选的汇聚节点是一致的。
63.步骤s140，将直播文件请求转发至汇聚节点，以供汇聚节点发起直播文件的回源请求。
64.将直播文件请求转发至汇聚节点，汇聚节点向源站发起直播文件的回源请求，接收源站所返回的直播文件，再将直播文件返回给用户端。
65.需要说明的是，由于存储服务器对有效节点列表是定时刷新的、节点本地缓存的有效节点列表也是动态更新的(即检测到过期时进行更新)以及对于同一个直播文件的直播文件请求到达各个节点的时间大多是不一致的，导致各个节点所筛选的汇聚节点并不是唯一的，能够避免多个节点接收到的对于同一个直播文件的请求被分配到单独一个汇聚节点的情况。
66.根据本技术实施例的集群节点分流方法，当检测已缓存的有效节点列表已经过期时，则确定为更新汇聚节点的时机，向存储服务器请求更新有效节点列表，根据更新后的有效节点列表重新筛选汇聚节点。各个节点所缓存的有效节点列表是动态变化的，且直播文件请求到达各个节点的时间不一致，使得直播文件请求到达各个节点时节点所缓存的有效节点列表也是不一致的，进而使得各个节点所计算出的汇聚节点不是惟一的，能够避免多个对于同一个直播文件的请求被分配到单独一个汇聚节点的情况，能够实现将同一个直播
文件的多个请求分配到不同的汇聚节点，通过集群中的多个汇聚节点分散请求回源，避免造成集群中某个节点所承载的压力过大的情况，保证单个节点的可用性，进而保证集群的可用性。
67.图2示出了本技术另一实施例提供的集群节点分流方法的流程图，该方法应用于集群中的任意一个节点中。如图2所示，该方法包括以下步骤：
68.步骤s210，接收用户端发起的直播文件请求。
69.步骤s220，判断直播文件的直播热度是否满足预设条件。
70.若是，执行步骤s230；若否，执行步骤s250。
71.本实施例的方法中，仅针对热门直播文件采用汇聚模式进行回源，原因在于热门直播文件的请求量会非常大，需要分流进行回源。具体在接收用户端发起的直播文件请求之后，首先判断直播文件的直播热度是否满足预设条件，例如判断直播热度是否超过预设值、是否为热门直播文件等等。
72.在一种可选的方式中，直播文件请求的url中携带热度标识信息，通过该热度标识信息确定直播文件的直播热度是否满足预设条件。例如部署一个特定服务用于分析确定直播文件的热度信息(直播文件的热度分值或者直播文件是否为热门直播文件)，具体根据直播文件对应的播放交互数据确定直播文件的热度信息，播放交互数据如：观看数量、评论数量、点赞数量、分享数量和/或礼物资源等等。
73.步骤s230，检测已缓存的有效节点列表是否已经过期，若已经过期，触发向存储服务器请求更新有效节点列表，对更新后的有效节点列表进行缓存并设定有效期。
74.如果所请求的直播文件的热度满足预设条件，则检测已缓存的有效节点列表是否已经过期，如果检测到已缓存的有效节点列表已经过期，则向存储服务器请求更新有效节点列表，存储服务器把当前的有效节点列表返回给节点，存储服务器所返回的有效节点列表即为更新后的有效节点列表，节点缓存存储服务器所返回的更新后的有效节点列表并设定其有效期。
75.在一种可选的方式中，根据有效期配置信息，设定更新后的有效节点列表的有效期。也即，节点中有效节点列表的有效期是可灵活配置的，使得各个节点中已缓存的有效节点列表之间存在信息差，进一步地，还可以将集群中各个节点缓存有效节点列表的有效期配置为不一致。
76.其中，存储服务器定时刷新有效节点列表。对于集群中的每一个节点而言，定时向存储服务器上报性能信息，以供存储服务器根据集群内各个节点上报的性能信息，识别各个节点中的各个有效节点，将各个有效节点的节点信息更新至有效节点列表中。可选地，在每个节点上部署采集服务，采集服务定时采集节点的性能信息，包括带宽信息、内存信息、cpu信息、磁盘信息和/或负载信息等等，采集服务将采集到的节点性能信息上报给存储服务器，存储服务器分析各个节点的性能信息，确定此时集群中有效可用的多个节点，并将各个有效可用的节点的信息更新到有效节点列表中。
77.步骤s240，根据更新后的有效节点列表包含的多个有效节点的节点信息以及直播文件请求的文件标识信息，进行一致性哈希计算，根据计算结果确定汇聚节点；将直播文件请求转发至汇聚节点，以供汇聚节点发起直播文件的回源请求。
78.节点信息可以是节点的ip或者节点名，直播文件请求的文件标识信息可以是url，
通过一致性哈希算法计算，将直播文件锁定到多个有效节点中的汇聚节点，通过汇聚节点对直播文件进行回源。可选地，每当计算出汇聚节点之后，对汇聚节点的相关信息进行缓存。
79.其中，一致性哈希算法将整个哈希值空间组成一个虚拟的圆环，例如可以于环上形成32位整数域。在本实施例中，针对于有效节点列表中包含的每一个有效节点，根据该有效节点的ip或者节点名生成多个哈希值，作为该有效节点对应的多个虚拟节点的节点哈希值，将各个虚拟节点的节点哈希值映射到这个环上，形成一致性哈希环。对直播文件的文件标识信息进行哈希计算得到文件哈希值，从一致性哈希环中查找节点哈希值与文件哈希值相匹配的目标虚拟节点，将目标虚拟节点对应的有效节点确定为汇聚节点。
80.另外，如果已缓存的有效节点列表未过期，则从该未过期的有效节点列表所包含的多个有效节点中筛选汇聚节点，具体也通过一致性哈希算法计算确定汇聚节点。
81.步骤s250，发起对直播文件的回源请求。
82.在直播文件的直播热度不满足预设条件的情况下，则无需通过汇聚节点进行回源，如果节点内未缓存直播文件，节点直接发起对直播文件的回源请求。
83.由于存储服务器是定时刷新有效节点列表的，并且，缓存到本地的有效节点列表是有有效期的，一旦已缓存的有效节点列表过期，节点会向存储服务器请求更新后的有效节点列表，也就是说，节点本地缓存的有效节点列表是动态变化的。对于接收到针对于同一直播文件的请求的各个节点而言，接收到直播文件请求时的有效节点列表是不一致的，进而使得对于同一直播文件的请求所计算的汇聚节点是并不是唯一的，就形成了各个节点的针对于同一直播文件的请求被分配到不同的汇聚节点的多层汇聚模式。
84.下面结合附图说明本技术实施例的集群节点分流方法，集群中包含节点1-4，集群通过随机分散的方式将外部的直播文件a的请求均衡地分散给集群内的各个节点。节点1、节点2以及节点3在不同的时间接收到直播文件a的请求，并且接收到请求时已缓存的有效节点列表未过期，且均记录了节点1、节点2、节点3以及节点4，计算出汇聚节点为节点4，三个节点接收的直播文件a的请求被分配到节点4，此时形成了如图3a所示的单节点汇聚模式。
85.由于节点4的承载了较大的压力，负载和带宽达到了瓶颈，到达存储服务器的下一个更新时间点时，存储服务器根据各个节点的采集服务上报的性能信息，判定节点4不再是有效节点，则将节点4从有效节点列表中剔除，更新后的有效节点列表记录有节点1、节点2以及节点3。
86.一段时间之后，节点1、节点2中缓存的有效节点列表先后过期，请求存储服务器获得更新后的有效节点列表(记录有节点1、节点2以及节点3)，计算汇聚节点为节点3，则节点1和节点2接收的直播文件a的请求被分配到节点3，而此时，节点3中已缓存的有效节点列表仍未过期，其接收到的直播文件a的请求仍然被分配到节点4，此时形成了如图3b所示的多个汇聚节点对同一直播文件进行回源的多层汇聚模式。这里只是简单举例说明了本实施例方法的实施方式，在实际应用中，由于集群内节点数较多，各个节点对有效节点的有效期也可配置为不一致，则会形成更加复杂的多层汇聚模式。
87.根据本技术实施例的集群节点分流方法，对于热门直播文件采用汇聚节点回源的方式，在存储服务器定时刷新有效节点列表，节点缓存有效节点列表并设置有效期，过期时
再向存储服务器请求更新有效节点列表，使得节点缓存的有效节点列表是动态变化的，再加上针对于同一直播文件的请求到达各个节点的时间不一致，使得各个节点计算汇聚节点时所使用的有效节点列表不一致，进而使得根据有效节点信息所构成一致性哈希环是动态变化的，所计算的汇聚节点也就不唯一，避免了将热门直播文件的所有请求分配到单个汇聚节点上，而是分散到不同的汇聚节点，能够形成多个汇聚节点对同一个热门直播文件进行回源的模式，避免造成集群中某个节点所承载的压力过大的情况；进一步地，对于热门直播文件的请求通过汇聚模式进行回源，对于非热门直播文件的请求在节点本地进行回源，能够通过集群中的汇聚节点分散热门直播文件的回源请求，同时也能够避免不必要的计算，从而保证整个集群的性能。
88.图4示出了本技术实施例提供的集群节点分流装置的结构示意图。如图4所示，该装置包括：
89.接收模块41，适于接收用户端发起的直播文件请求；
90.检测模块42，适于检测已缓存的有效节点列表是否已经过期；
91.请求模块43，适于若已经过期，触发向存储服务器请求更新有效节点列表；
92.处理模块44，适于对更新后的有效节点列表进行缓存并设定有效期；其中，存储服务器定时刷新有效节点列表；
93.筛选模块45，适于从更新后的有效节点列表包含的多个有效节点中筛选汇聚节点；
94.发送模块46，适于将直播文件请求转发至汇聚节点，以供汇聚节点发起直播文件的回源请求。
95.在一种可选的方式中，筛选模块45进一步适于：根据更新后的有效节点列表包含的多个有效节点的节点信息以及直播文件请求的文件标识信息，进行一致性哈希计算，根据计算结果确定汇聚节点。
96.在一种可选的方式中，装置还包括上报模块，适于定时向存储服务器上报性能信息，以供存储服务器根据集群内各个节点上报的性能信息，识别各个节点中的各个有效节点，将各个有效节点的节点信息更新至有效节点列表中。
97.在一种可选的方式中，装置还包括热度判断模块，适于判断直播文件的直播热度是否满足预设条件；
98.检测模块42进一步适于：在直播文件的直播热度满足预设条件的情况下，检测已缓存的有效节点列表是否已经过期。
99.在一种可选的方式中，装置还包括回源模块，适于在直播文件的直播热度不满足预设条件的情况下，发起对直播文件的回源请求。
100.在一种可选的方式中，性能信息包括以下信息中的一项或多项：带宽信息、内存信息、cpu信息、磁盘信息、负载信息。
101.在一种可选的方式中，处理模块进一步适于：根据有效期配置信息，设定更新后的有效节点列表的有效期。
102.通过上述方式，当检测已缓存的有效节点列表已经过期时，则确定为更新汇聚节点的时机，向存储服务器请求更新有效节点列表，根据更新后的有效节点列表重新筛选汇聚节点。各个节点所缓存的有效节点列表是动态变化的，且直播文件请求到达各个节点的
时间不一致，使得直播文件请求到达各个节点时节点所缓存的有效节点列表也是不一致的，进而使得各个节点所计算出的汇聚节点不是惟一的，能够避免多个对于同一个直播文件的请求被分配到单独一个汇聚节点的情况，能够实现将同一个直播文件的多个请求分配到不同的汇聚节点，通过集群中的多个汇聚节点分散请求回源，避免造成集群中某个节点所承载的压力过大的情况，保证单个节点的可用性，进而保证集群的可用性。
103.本技术实施例提供了一种非易失性计算机存储介质，所述计算机存储介质存储有至少一可执行指令，该计算机可执行指令可执行上述任意方法实施例中的集群节点分流方法。
104.图5示出了本技术计算设备实施例的结构示意图，本技术具体实施例并不对计算设备的具体实现做限定。
105.如图5所示，该计算设备可以包括：处理器(processor)502、通信接口(communications interface)504、存储器(memory)506、以及通信总线508。
106.其中：处理器502、通信接口504、以及存储器506通过通信总线508完成相互间的通信。通信接口504，用于与其它设备比如客户端或其它服务器等的网元通信。处理器502，用于执行程序510，具体可以执行上述用于计算设备的集群节点分流方法实施例中的相关步骤。
107.具体地，程序510可以包括程序代码，该程序代码包括计算机操作指令。
108.处理器502可能是中央处理器cpu，或者是特定集成电路asic(application specific integrated circuit)，或者是被配置成实施本技术实施例的一个或多个集成电路。计算设备包括的一个或多个处理器，可以是同一类型的处理器，如一个或多个cpu；也可以是不同类型的处理器，如一个或多个cpu以及一个或多个asic。
109.存储器506，用于存放程序510。存储器506可能包含高速ram存储器，也可能还包括非易失性存储器(non-volatile memory)，例如至少一个磁盘存储器。
110.在此提供的算法或显示不与任何特定计算机、虚拟系统或者其它设备固有相关。各种通用系统也可以与基于在此的示教一起使用。根据上面的描述，构造这类系统所要求的结构是显而易见的。此外，本技术实施例也不针对任何特定编程语言。应当明白，可以利用各种编程语言实现在此描述的本技术的内容，并且上面对特定语言所做的描述是为了披露本技术的最佳实施方式。
111.在此处所提供的说明书中，说明了大量具体细节。然而，能够理解，本技术的实施例可以在没有这些具体细节的情况下实践。在一些实例中，并未详细示出公知的方法、结构和技术，以便不模糊对本说明书的理解。
112.类似地，应当理解，为了精简本技术并帮助理解各个申请方面中的一个或多个，在上面对本技术的示例性实施例的描述中，本技术实施例的各个特征有时被一起分组到单个实施例、图、或者对其的描述中。然而，并不应将该公开的方法解释成反映如下意图：即所要求保护的本技术要求比在每个权利要求中所明确记载的特征更多的特征。更确切地说，如权利要求书所反映的那样，申请方面在于少于前面公开的单个实施例的所有特征。因此，遵循具体实施方式的权利要求书由此明确地并入该具体实施方式，其中每个权利要求本身都作为本技术的单独实施例。
113.本领域那些技术人员可以理解，可以对实施例中的设备中的模块进行自适应性地
改变并且把它们设置在与该实施例不同的一个或多个设备中。可以把实施例中的模块或单元或组件组合成一个模块或单元或组件，以及此外可以把它们分成多个子模块或子单元或子组件。除了这样的特征和/或过程或者单元中的至少一些是相互排斥之外，可以采用任何组合对本说明书(包括伴随的权利要求、摘要和附图)中公开的所有特征以及如此公开的任何方法或者设备的所有过程或单元进行组合。除非另外明确陈述，本说明书(包括伴随的权利要求、摘要和附图)中公开的每个特征可以由提供相同、等同或相似目的的替代特征来代替。
114.此外，本领域的技术人员能够理解，尽管在此的一些实施例包括其它实施例中所包括的某些特征而不是其它特征，但是不同实施例的特征的组合意味着处于本技术的范围之内并且形成不同的实施例。例如，在权利要求书中，所要求保护的实施例的任意之一都可以以任意的组合方式来使用。
115.本技术的各个部件实施例可以以硬件实现，或者以在一个或者多个处理器上运行的软件模块实现，或者以它们的组合实现。本领域的技术人员应当理解，可以在实践中使用微处理器或者数字信号处理器(dsp)来实现根据本技术实施例的一些或者全部部件的一些或者全部功能。本技术还可以实现为用于执行这里所描述的方法的一部分或者全部的设备或者装置程序(例如，计算机程序和计算机程序产品)。这样的实现本技术的程序可以存储在计算机可读介质上，或者可以具有一个或者多个信号的形式。这样的信号可以从因特网网站上下载得到，或者在载体信号上提供，或者以任何其他形式提供。
116.应该注意的是上述实施例对本技术进行说明而不是对本技术进行限制，并且本领域技术人员在不脱离所附权利要求的范围的情况下可设计出替换实施例。在权利要求中，不应将位于括号之间的任何参考符号构造成对权利要求的限制。单词“包含”不排除存在未列在权利要求中的元件或步骤。位于元件之前的单词“一”或“一个”不排除存在多个这样的元件。本技术可以借助于包括有若干不同元件的硬件以及借助于适当编程的计算机来实现。在列举了若干装置的单元权利要求中，这些装置中的若干个可以是通过同一个硬件项来具体体现。单词第一、第二、以及第三等的使用不表示任何顺序。可将这些单词解释为名称。上述实施例中的步骤，除有特殊说明外，不应理解为对执行顺序的限定。

技术特征：
1.一种集群节点分流方法，包括：接收用户端发起的直播文件请求；检测已缓存的有效节点列表是否已经过期，若已经过期，触发向存储服务器请求更新有效节点列表，对更新后的有效节点列表进行缓存并设定有效期；其中，所述存储服务器定时刷新有效节点列表；从所述更新后的有效节点列表包含的多个有效节点中筛选汇聚节点；将所述直播文件请求转发至所述汇聚节点，以供所述汇聚节点发起所述直播文件的回源请求。2.根据权利要求1所述的方法，其中，所述从所述更新后的有效节点列表包含的多个有效节点中筛选汇聚节点进一步包括：根据更新后的有效节点列表包含的多个有效节点的节点信息以及所述直播文件请求的文件标识信息，进行一致性哈希计算，根据计算结果确定汇聚节点。3.根据权利要求1或2所述的方法，其中，所述方法进一步包括：定时向所述存储服务器上报性能信息，以供所述存储服务器根据集群内各个节点上报的性能信息，识别所述各个节点中的各个有效节点，将所述各个有效节点的节点信息更新至所述有效节点列表中。4.根据权利要求1所述的方法，其中，所述接收用户端发起的直播文件请求之后，所述方法还包括：判断所述直播文件的直播热度是否满足预设条件；所述检测已缓存的有效节点列表是否已经过期进一步包括：在所述直播文件的直播热度满足预设条件的情况下，检测已缓存的有效节点列表是否已经过期。5.根据权利要求4所述的方法，其中，所述方法进一步包括：在所述直播文件的直播热度不满足预设条件的情况下，发起对所述直播文件的回源请求。6.根据权利要求3所述的方法，其中，所述性能信息包括以下信息中的一项或多项：带宽信息、内存信息、cpu信息、磁盘信息、负载信息。7.根据权利要求1所述的方法，其中，对更新后的有效节点列表设定有效期进一步包括：根据有效期配置信息，设定所述更新后的有效节点列表的有效期。8.一种集群节点分流装置，包括：接收模块，适于接收用户端发起的直播文件请求；检测模块，适于检测已缓存的有效节点列表是否已经过期；请求模块，适于若已经过期，触发向存储服务器请求更新有效节点列表；处理模块，适于对更新后的有效节点列表进行缓存并设定有效期；其中，所述存储服务器定时刷新有效节点列表；筛选模块，适于从所述更新后的有效节点列表包含的多个有效节点中筛选汇聚节点；发送模块，适于将所述直播文件请求转发至所述汇聚节点，以供所述汇聚节点发起所述直播文件的回源请求。
9.一种计算设备，包括：处理器、存储器、通信接口和通信总线，所述处理器、所述存储器和所述通信接口通过所述通信总线完成相互间的通信；所述存储器用于存放至少一可执行指令，所述可执行指令使所述处理器执行如权利要求1-7中任一项所述的集群节点分流方法对应的操作。10.一种计算机存储介质，所述存储介质中存储有至少一可执行指令，所述可执行指令使处理器执行如权利要求1-7中任一项所述的集群节点分流方法对应的操作。

技术总结
本申请公开了一种集群节点分流方法、装置、计算设备及存储介质，涉及计算机技术领域，方法包括：接收用户端发起的直播文件请求；检测已缓存的有效节点列表是否已经过期，若已经过期，触发向存储服务器请求更新有效节点列表，对更新后的有效节点列表进行缓存并设定有效期；存储服务器定时刷新有效节点列表；从更新后的有效节点列表包含的多个有效节点中筛选汇聚节点；将直播文件请求转发至汇聚节点，以供汇聚节点发起直播文件的回源请求。通过上述方式，能够实现将同一个直播文件的多个请求分配到不同的汇聚节点，通过集群中的多个汇聚节点分散请求回源，避免造成集群中单独某个节点所承载的压力过大的情况，保证单个节点的可用性。用性。用性。


技术研发人员：张建锋 刘勇江 杨成进
受保护的技术使用者：上海哔哩哔哩科技有限公司
技术研发日：2023.06.12
技术公布日：2023/8/31