回源处理方法、装置、电子设备及存储介质与流程

1.本公开涉及人工智能领域，具体涉及云计算、云存储和内容分发技术，可应用在智能云场景下。尤其涉及一种回源处理方法、装置、电子设备及存储介质。
背景技术：
：：2.随着直播行业的飞速发展，直播受众群体不断地扩大，在各个行业的各个领域涌现出了各种各样的直播。3.现有技术中，直播时，主播通过主播客户端将直播流上传到推流边缘节点，然后由推流边缘节点将直播流转推至流媒体中心平台。观众侧观看直播时，通过采用观众客户端向最近的拉流边缘节点请求该直播流的流媒体资源。若拉流边缘节点上没有该流媒体资源，可以从流媒体中心平台拉取该直播流的流媒体资源。上述观众观看直播时，请求流媒体资源的过程，可以称为回源。技术实现要素：4.本公开提供了一种回源处理方法、装置、电子设备及存储介质。5.根据本公开的一方面，提供了一种回源处理方法，包括：6.基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息；7.基于所述目标上层节点的信息，向所述目标上层节点转发所述第一回源请求，以从所述目标上层节点中获取所述第一直播流标识对应的第一直播流。8.根据本公开的另一方面，提供了一种回源处理装置，包括：9.确定模块，用于基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息；10.发送模块，用于基于所述目标上层节点的信息，向所述目标上层节点转发所述第一回源请求，以从所述目标上层节点中获取所述第一直播流标识对应的第一直播流。11.根据本公开的再一方面，提供了一种电子设备，包括：12.至少一个处理器；以及13.与所述至少一个处理器通信连接的存储器；其中，14.所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器能够执行如上所述的方面和任一可能的实现方式的方法。15.根据本公开的又一方面，提供了一种存储有计算机指令的非瞬时计算机可读存储介质，所述计算机指令用于使所述计算机执行如上所述的方面和任一可能的实现方式的方法。16.根据本公开的再另一方面，提供了一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现如上所述的方面和任一可能的实现方式的方法。17.根据本公开的技术，能够有效地降低流媒体资源平台的带宽成本。18.应当理解，本部分所描述的内容并非旨在标识本公开的实施例的关键或重要特征，也不用于限制本公开的范围。本公开的其它特征将通过以下的说明书而变得容易理解。附图说明19.附图用于更好地理解本方案，不构成对本公开的限定。其中：20.图1是本公开实施例提供的一种直播架构示意图；21.图2是本公开实施例提供的另一种直播架构示意图；22.图3是根据本公开第一实施例的示意图；23.图4是根据本公开第二实施例的示意图；24.图5是根据本公开第三实施例的示意图；25.图6是根据本公开第四实施例的示意图；26.图7是根据本公开第五实施例的示意图；27.图8是根据本公开第六实施例的示意图；28.图9是用来实现本公开实施例的方法的电子设备的框图。具体实施方式29.以下结合附图对本公开的示范性实施例做出说明，其中包括本公开实施例的各种细节以助于理解，应当将它们认为仅仅是示范性的。因此，本领域普通技术人员应当认识到，可以对这里描述的实施例做出各种改变和修改，而不会背离本公开的范围和精神。同样，为了清楚和简明，以下的描述中省略了对公知功能和结构的描述。30.显然，所描述的实施例是本公开一部分实施例，而不是全部的实施例。基于本公开中的实施例，本领域普通技术人员在没有作出创造性劳动前提下所获得的全部其他实施例，都属于本公开保护的范围。31.需要说明的是，本公开实施例中所涉及的终端设备可以包括但不限于手机、个人数字助理(personaldigitalassistant，pda)、无线手持设备、平板电脑(tabletcomputer)等智能设备；显示设备可以包括但不限于个人电脑、电视等具有显示功能的设备。32.另外，本文中术语“和/或”，仅仅是一种描述关联对象的关联关系，表示可以存在三种关系，例如，a和/或b，可以表示：单独存在a，同时存在a和b，单独存在b这三种情况。另外，本文中字符“/”，一般表示前后关联对象是一种“或”的关系。33.图1是本公开实施例提供的一种直播架构示意图，如图1所示，在该直播架构中，在客户端层与流媒体中心平台之间可以设置有至少一层节点层。客户端层包括主播客户端和观众客户端。为了更加清楚地展示直播架构，图1中以在客户端层与流媒体中心平台之间设置至少两层节点层为例，如图中的推流边缘节点和拉流边缘节点所在的边缘节点层、以及上层节点所在的上层节点层。上层节点层为流媒体中心平台下方最近邻的一层节点层。本实施例中的同层的节点，也可以称为同级节点，即在直播架构中为同一级的节点。34.如图1所示，上层节点1、上层节点2、上层节点3所在的上层节点层即为距离流媒体中心平台最近的一层节点层。实际应用场景中，推流边缘节点所在的边缘节点层与上层节点1所在的上层节点层之间可以还包括有至少一个中间节点层，或者也可以不包括有中间节点层。图1所示的架构中，推流边缘节点、拉流边缘节点、中间层的节点以及上层节点都采用内容分发网络(contentdeliverynetwork；cdn)节点来实现。35.而且实际应用中，边缘节点层和上层节点层可以为同一层。此时，可以得到图2所示的直播架构图，如图2所示，此时直播架构可以仅包括三层，如客户端层、边缘节点层以及流媒体中心平台。此时推流边缘节点和拉流边缘节点为距离流媒体中心平台最近的一层节点层，即在该直播架构中，边缘节点层也是上层节点层。36.在图1所示的架构中，直播时，主播通过主播客户端将直播流上传到最近的推流边缘节点，然后推流边缘节点通过中间层的节点，一直将直播流推送到上层节点1，上层节点1将直播流推送到流媒体中心平台。37.在观众侧，以两个观众请求观看同一主播的直播流为例，例如，观众客户端1向最近的拉流边缘节点1发起回源请求，以拉取该直播的直播流。若拉流边缘节点1内无该直播流的资源，继续向上层的节点请求回源，一直到将回源请求发送到上层节点2，上层节点2从流媒体中心平台拉取主播的直播流，再往回传，直至传给拉流边缘节点1。同理，观众客户端2向最近的拉流边缘节点2发起回源请求，以拉取该直播的直播流。若拉流边缘节点2内无该直播流的资源，继续向上层的节点请求回源，一直到将回源请求发送到上层节点3，上层节点3从流媒体中心平台拉取主播的直播流，再往回传，直至传给拉流边缘节点1。38.图1所示架构中，以两个观众请求观看同一主播的直播流为例，实际应用中，可以存在非常多的观众同时观看同一主播的直播流。按照图1所示的架构，对于每个观众的回源请求，最终都由对应的上层节点从流媒体中心平台拉取直播流。即使对于同一直播流，流媒体资源需要向下一层的多个上层节点传输很多次，导致流媒体平台的带宽消耗非常大。39.图3是根据本公开第一实施例的示意图；如图3所示，本实施例提供一种回源处理方法，具体应用在流媒体中心平台下一层的上层节点中，例如可以应用在图1或者图2中流媒体中心平台下一层的上层节点层中的任一上层节点中。本实施例的回源处理方法，具体可以包括如下步骤：40.s301、基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理第一直播流回源的目标上层节点的信息；41.s302、基于目标上层节点的信息，向目标上层节点转发所述第一回源请求，以从目标上层节点中获取第一直播流标识对应的第一直播流。42.本实施例中，可以采用一定的技术手段，在上层节点层中为每个直播流标识配置相应的目标上层节点。例如，基于第一直播流标识，可以确定上层节点层中、负责处理第一直播流回源的目标上层节点的信息；进而基于该目标上层节点层的信息，便可以向目标上层节点转发所述第一回源请求，以从目标上层节点中获取第一直播流标识对应的第一直播流，实现在同层节点中进行回源，避免所有节点都向流媒体中心平台回源，造成流媒体中心平台带宽资源消耗过多。43.本实施例的回源处理方法，通过采用上述方式，可以实现在同层的节点中进行回源，能够有效地避免所有节点都向流媒体中心平台回源，进而可以有效地降低流媒体中心平台带宽资源的成本。44.图4是根据本公开第二实施例的示意图；本实施例提供一种回源处理方法，在上述图3所示实施例的技术方案的基础上，进一步更加详细地描述本公开的技术方案。如图4所示，本实施例的回源处理方法，具体可以包括如下步骤：45.s401、当前上层节点接收到第一回源请求中的第一直播流标识；46.s402、当前上层节点基于第一直播流标识进行一致性哈希计算，确定当前所在的上层节点层中、负责处理第一直播流回源的目标上层节点的标识；47.例如，第一直播流标识采用一串数字来标识。若当前所在的上层节点层中包括有m个上层节点。一致性哈希计算所采用的算法可以为将第一直播流标识除以m，获取对应的余数。基于余数为第一直播流分配负责处理第一直播流回源的目标上层节点的标识。其中余数0到m-1分别对应m个上层节点，每个余数对应一个上层节点。按照此方式，可以非常准确、高效地确定负责处理第一直播流回源的目标上层节点的标识。48.s403、当前上层节点检测目标上层节点是不是当前上层节点本身；若不是，执行步骤s404；若是，执行步骤s405；49.s404、当前上层节点基于目标上层节点的标识，向目标上层节点转发第一回源请求，以从目标上层节点中获取第一直播流标识对应的第一直播流，结束。50.例如，可以根据目标上层节点的标识，获取目标上层节点的地址信息，进而基于目标上层节点的地址信息，向目标上层节点转发第一回源请求。例如，在直播架构中，可以配置有架构中各层各节点的地址信息，需要是直接获取即可。51.s405、当前上层节点向流媒体中心平台转发第一回源请求，以从流媒体中心平台获取第一直播流标识对应的第一直播流，结束。52.本实施例中，以节点为粒度，介绍本实施例的回源处理方法。53.本实施例的回源处理方法，通过采用上述方式，可以实现在同层的节点中进行回源，能够有效地避免所有节点都向流媒体中心平台回源，进而可以有效地降低流媒体中心平台带宽资源的成本。54.图5是根据本公开第三实施例的示意图；本实施例提供一种回源处理方法，在上述图3或者图4所示实施例的技术方案的基础上，进一步更加详细地描述本公开的技术方案。如图5所示，本实施例的回源处理方法，具体可以包括如下步骤：55.s501、控制接收到第一回源请求的当前服务进程基于第一直播流标识，确定当前上层节点内负责处理第一直播流回源的目标服务进程的标识；56.与上述图3所示实施例不同的是，本实施例中，以当前的上层节点内的服务进程为粒度，描述本实施例的回源处理方法。57.具体地，本实施例中，以当前上层节点内的当前服务进程接收到第一回源请求为例。58.具体实现时，可以控制当前服务进程，基于第一直播流标识进行一致性哈希(hash)计算，确定当前上层节点内负责处理第一直播流回源的目标服务进程的标识。59.例如，本实施例的第一直播流标识可以采用一串数字来标识。假如当前上层节点内的服务进程数有n个，一致性哈希计算所采用的算法可以为将第一直播流标识除以n，获取对应的余数。基于余数为第一直播流分配负责处理第一直播流回源的目标服务进程的标识。其中余数0到n-1分别对应n个服务进程，每个余数对应一个服务进程。按照此方式，可以准确、高效地确定负责处理第一直播流回源的目标服务进程的标识。60.s502、控制当前服务进程基于目标服务进程的标识，检测目标服务进程是否为自身；若不是，执行步骤s503；若是，执行步骤s508；61.s503、控制当前服务进程基于目标服务进程的标识，向目标服务进程转发第一回源请求；执行步骤s504；62.s504、控制目标服务进程基于第一直播流标识，确定当前所在的上层节点层中、负责处理第一直播流回源的目标上层节点的标识；执行步骤s505；63.具体地，可以采用上述步骤s402的方式来实现。按照此方式，可以准确、高效地确定负责处理第一直播流回源的目标上层节点的标识。64.s505、控制目标服务进程基于目标上层节点的标识，向目标上层节点转发第一回源请求，以从目标上层节点中获取第一直播流标识对应的第一直播流；65.s506、在目标服务进程与当前服务进程之间建立辅助通道；执行步骤s507；66.s507、控制目标服务进程通过辅助通道向当前服务进程返回第一回源请求的转发信息，该转发信息中携带目标上层节点的信息；执行步骤s510；67.也就是说，通过辅助通道，目标服务进程可以告知当前服务进程，当前服务进程正在请求的第一回源请求，由目标服务进程发送给了同层的目标上层节点，由目标上层节点负责处理该第一回源请求的第一直播流的回源。68.s508、控制当前服务进程基于第一直播流标识，确定当前所在的上层节点层中、负责处理第一直播流回源的目标上层节点的标识；执行步骤s509；69.具体地，可以采用上述步骤s402的方式来实现。按照此方式，可以准确、高效地确定负责处理第一直播流回源的目标上层节点的标识。70.s509、控制当前服务进程基于目标上层节点的标识，向目标上层节点转发第一回源请求，以从目标上层节点中获取第一直播流标识对应的第一直播流；结束。71.本实施例中，以在当前上层节点内描述本公开的技术方案，控制当前服务进程将第一回源请求转发给目标上层节点之后，结束，仅指的是当前上层节点内的处理结束，而并非整个回源流程结束。在目标上层节点内，需要将目标上层节点作为当前上层节点，执行本实施例的技术方案，以保证能够进行准确地回源。72.对于当前上层节点的当前服务进程而言，第一回源请求转发出去之后，后续等待目标上层节点基于第一回源请求，返回第一直播流的流媒体资源即可。73.s510、若当前服务进程接收到携带第二直播流标识和发送端的信息的第二回源请求时，控制当前服务进程检测第二直播流标识是否为正在请求的第一直播流标识；若是，执行步骤s511；若不是，返回步骤s501；按照上述第一回源请求的处理方式处理第二回源请求；即从步骤s501开始，将其中的第一回源请求都替换为第二回源请求，继续处理即可。74.具体地，检测第二直播流标识是否为正在请求的第一直播流标识，相当于检测接收到的第二回源请求中的第二直播流标识与正在请求的第一回源请求中的第一直播流标识是否相同。75.该步骤中是以当前服务进程正在请求第一直播流为例，实际应用中，该当前服务进程需要检测当前接收到的第二回源请求，是否与正在请求的每一个回源请求是否相同。76.s511、控制当前服务进程检测第二回源请求的发送端，是否为正在请求的第一直播流标识对应的第一回源请求转发到的目标上层节点；若是，执行步骤s512；若不是，结束；77.若当前服务进程检测到第二直播流标识是正在请求的第一直播流标识，但是第二回源请求的发送端，不是正在请求的第一直播流标识对应的第一回源请求转发到的目标上层节点，此时可以确定未发生闭环。只能说明其他上层节点将第一回源请求发送给当前上层节点的当前服务进程。由于当前服务进程已经转发了第一回源请求，此时不用重复处理，等待正在请求的第一回源请求获取到相应的第一直播流即可。78.s512、控制当前服务进程向发送端返回回源消息，该回源消息用于指示发送端向流媒体中心平台请求第一直播流的消息；执行步骤s513；79.s513、控制当前服务进程断开与发送端的连接，结束。80.若当前服务进程检测到第二直播流标识是正在请求的第一直播流标识，且第二回源请求的发送端，是正在请求的第一直播流标识对应的第一回源请求转发到的目标上层节点，此时可以确定出现了闭环。所以需要告知发送端去向流媒体中心平台请求第一直播流，并断开当前服务进程与发送端的连接，能够有效地确保回源的准确执行。81.通过采用上述步骤s510-s513，可以防止回源过程中产生闭环而无法获取都直播流的情况，能够有效地确保回源的准确执行，保证直播业务的正常进行。82.需要说明的是，在实际应用中，直播架构中的同一层节点并不是永远固定不变的。例如，对于上层节点层而言，使用过程中，可能会出现部分上层节点故障。例如，对于同一个直播流标识，进行一致性哈希计算时，参与的上层节点的数量不同，导致确定的负责处理该直播流回源的目标上层节点也可能不同，进而可能会导致如上所述的回源闭环。83.本实施例中，以当前进程为例，描述回源处理方法。实际应用中，当前进程可以为上层节点层的任意一个上层节点中的任意一个进程。也就是说，需要在每一个上传节点中的每一个进程都按照图5所示实施例的方案进行检测，能够有效地避免在同层节点中回源时发生闭环，导致无法获取直播流，能够保证直播流的获取，确保直播业务的进行。84.本实施例的回源处理方法，通过采用上述方式，可以以上层节点内的进程为粒度，实现回源处理，不仅可以实现在同层的节点中进行回源，能够有效地避免所有节点都向流媒体中心平台回源；可以有效地降低流媒体中心平台带宽资源的成本。而且，本实施例的技术方案，还能够有效地避免回源成环，导致无法获取直播流的情况，能够保证直播流的获取，确保直播业务的进行。85.图6是根据本公开第四实施例的示意图；如图6所示，以流媒体中心平台下一层的cdn节点a和cdn节点b为例，且流媒体中心平台下一层的节点层中还包括其他cdn节点，图中未示出。86.如图6所示，cdn节点a的服务进程1可以接收客户端的回源请求，该回源请求中携带一个直播流的标识，用于请求一个直播流的回源。如客户端client1通过链路1，将回源请求打到服务进程1。基于直播流的标识，按照上述图5所示实施例的一致性hash计算，可以控制该服务进程检测并确定由该cdn节点a内的服务进程2负责处理该直播流的回源，所以可以控制该服务进程1将回源请求转发给服务进程2。如图6所示，服务进程1采用链路2将回源请求转发给服务进程2。可以控制服务进程2按照图5所示实施例的方案，检测并确定由同层的cdn节点b负责该直播流的回源。所以，可以控制服务进程2将该回源请求转发给cdn节点b，例如可以通过链路5，打到cdn节点b的服务进程3。同理，在cdn节点b内，可以控制服务进程3也检测并确定由该cdn节点b内的服务进程4处理该直播流的回源。所以可以控制服务进程3通过链路6将该回源请求转发给服务进程4。87.也可以控制服务进程4采用一致性哈希计算，但是由于cdn节点a的服务进程2和cdn节点b的服务进程4在不同时刻进行的一致性哈希计算，所以，在服务进程4上进行一致性哈希计算时，可能会出现同层的部分cdn节点故障，导致服务进程4确定的同层cdn节点层中由cdn节点a负责该直播流的回源。所以，可以控制服务进程4将该回源请求又转发给cdn节点a，例如通过链路7打到服务进程1上。另外，在cdn节点b中，服务进程3还通过链路3接收到客户端client2的同一直播流标识的回源请求。同理，该可以控制服务进程5进行一致性哈希计算，确定服务进程4处理该直播流的回源。通过链路4将该回源请求转发给服务进程4。88.此时由于服务进程1通过服务进程1和服务进程2之间的辅助通道，已经得知该回源请求转发给了cdn节点b，此时又收到cdn节点b发来的回源请求，可以确定发生了回源闭环。此时服务进程1可以向cdn节点b的服务进程4，返回回源消息，以指示cdn节点b的服务进程4向流媒体中心平台请求回源，并断开该链路7。89.本实施例的技术方案，不仅可以实现同层cdn节点之间进行回源，以降低流媒体中心的带宽成本，而且还可以防止同层cdn节点之间回源成环，导致无法获取资源的情况，能够有效地确保直播业务的正常进行。90.图7是根据本公开第五实施例的示意图；如图7所示，本实施例提供一种回源处理装置700，应用在直播框架的流媒体中心下一层的任一上层节点中，包括：91.确定模块701，用于基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息；92.发送模块702，用于基于所述目标上层节点的信息，向所述目标上层节点转发所述第一回源请求，以从所述目标上层节点中获取所述第一直播流标识对应的第一直播流。93.本实施例的回源处理装置700可以应用在直播架构中流媒体中心平台下一层的任意一个上层节点中。94.本实施例的回源处理装置700，通过采用上述模块实现回源处理的实现原理以及技术效果，与上述相关方法实施例的实现相同，详细可以参考上述相关方法实施例的记载，在此不再赘述。95.图8是根据本公开第六实施例的示意图；如图8所示，本实施例提供一种回源处理装置800，包括：上述图7所示的同名同功能模块：确定模块801，和发送模块802。96.本实施例中，确定模块801，用于：97.基于所述第一直播流标识进行一致性哈希计算，确定当前所在的所述上层节点层中、负责处理所述第一直播流回源的所述目标上层节点的标识。在本公开的一个实施例中，确定模块801，还用于：98.确定所述目标上层节点不是当前上层节点。在本公开的一个实施例中，发送模块802，还用于：99.若目标上层节点为当前上层节点，向流媒体中心平台转发所述第一回源请求，以从所述流媒体中心平台获取所述第一直播流标识对应的所述第一直播流。在本公开的一个实施例中，确定模块801，还用于100.控制接收到所述第一回源请求的当前服务进程基于所述第一直播流标识，确定当前上层节点内负责处理所述第一直播流回源的目标服务进程的标识；发送模块802，还用于控制所述当前服务进程基于所述目标服务进程的标识，向所述目标服务进程转发所述第一回源请求。101.在本公开的一个实施例中，确定模块801，用于：102.控制所述目标服务进程，基于所述第一直播流标识，确定当前所在的所述上层节点层中、负责处理所述第一直播流回源的所述目标上层节点的标识；103.发送模块802，用于：104.控制所述目标服务进程基于所述目标上层节点的标识，向所述目标上层节点转发所述第一回源请求。105.在本公开的一个实施例中，确定模块801，用于：106.控制所述当前服务进程确定所述目标服务进程不是自身。107.在本公开的一个实施例中，确定模块801，用于：108.控制所述当前服务进程，基于所述第一直播流标识进行一致性哈希计算，确定所述当前上层节点内负责处理所述第一直播流回源的所述目标服务进程的标识。如图8所示，在本公开的一个实施例中，回源处理装置800，还包括：109.建立模块803，用于在所述目标服务进程与所述当前服务进程之间建立辅助通道；发送模块802，用于控制所述目标服务进程通过所述辅助通道向所述当前服务进程返回所述第一回源请求的转发信息，所述转发信息中携带所述目标上层节点的信息。110.如图8所示，在本公开的一个实施例中，回源处理装置800还包括：111.检测模块804，用于若所述当前服务进程接收到携带第二直播流标识和发送端的信息的第二回源请求时，控制所述当前服务进程检测所述第二直播流标识是否为正在请求的所述第一直播流标识；112.检测模块804，还用于若是，控制所述当前服务进程检测所述第二回源请求的所述发送端，是否为正在请求的所述第一直播流标识对应的所述第一回源请求转发到的所述目标上层节点；113.发送模块802，还用于若是，控制所述当前服务进程向所述发送端返回回源消息，所述回源消息用于指示所述发送端向流媒体中心平台请求所述第一直播流；114.断开模块805，用于控制所述当前服务进程断开与所述发送端的连接。115.本实施例的回源处理装置800，通过采用上述模块实现回源处理的实现原理以及技术效果，与上述相关方法实施例的实现相同，详细可以参考上述相关方法实施例的记载，在此不再赘述。116.本公开的技术方案中，所涉及的用户个人信息的获取，存储和应用等，均符合相关法律法规的规定，且不违背公序良俗。117.根据本公开的实施例，本公开还提供了一种电子设备、一种可读存储介质和一种计算机程序产品。118.图9示出了可以用来实施本公开的实施例的示例电子设备900的示意性框图。电子设备旨在表示各种形式的数字计算机，诸如，膝上型计算机、台式计算机、工作台、个人数字助理、服务器、刀片式服务器、大型计算机、和其它适合的计算机。电子设备还可以表示各种形式的移动装置，诸如，个人数字处理、蜂窝电话、智能电话、可穿戴设备和其它类似的计算装置。本文所示的部件、它们的连接和关系、以及它们的功能仅仅作为示例，并且不意在限制本文中描述的和/或者要求的本公开的实现。119.如图9所示，设备900包括计算单元901，其可以根据存储在只读存储器(rom)902中的计算机程序或者从存储单元908加载到随机访问存储器(ram)903中的计算机程序，来执行各种适当的动作和处理。在ram903中，还可存储设备900操作所需的各种程序和数据。计算单元901、rom902以及ram903通过总线904彼此相连。输入/输出(i/o)接口905也连接至总线904。120.设备900中的多个部件连接至i/o接口905，包括：输入单元906，例如键盘、鼠标等；输出单元907，例如各种类型的显示器、扬声器等；存储单元908，例如磁盘、光盘等；以及通信单元909，例如网卡、调制解调器、无线通信收发机等。通信单元909允许设备900通过诸如因特网的计算机网络和/或各种电信网络与其他设备交换信息/数据。121.计算单元901可以是各种具有处理和计算能力的通用和/或专用处理组件。计算单元901的一些示例包括但不限于中央处理单元(cpu)、图形处理单元(gpu)、各种专用的人工智能(ai)计算芯片、各种运行机器学习模型算法的计算单元、数字信号处理器(dsp)、以及任何适当的处理器、控制器、微控制器等。计算单元901执行上文所描述的各个方法和处理，例如本公开的上述方法。例如，在一些实施例中，本公开的上述方法可被实现为计算机软件程序，其被有形地包含于机器可读介质，例如存储单元908。在一些实施例中，计算机程序的部分或者全部可以经由rom902和/或通信单元909而被载入和/或安装到设备900上。当计算机程序加载到ram903并由计算单元901执行时，可以执行上文描述的本公开的上述方法的一个或多个步骤。备选地，在其他实施例中，计算单元901可以通过其他任何适当的方式(例如，借助于固件)而被配置为执行本公开的上述方法。122.本文中以上描述的系统和技术的各种实施方式可以在数字电子电路系统、集成电路系统、场可编程门阵列(fpga)、专用集成电路(asic)、专用标准产品(assp)、芯片上系统的系统(soc)、复杂可编程逻辑设备(cpld)、计算机硬件、固件、软件、和/或它们的组合中实现。这些各种实施方式可以包括：实施在一个或者多个计算机程序中，该一个或者多个计算机程序可在包括至少一个可编程处理器的可编程系统上执行和/或解释，该可编程处理器可以是专用或者通用可编程处理器，可以从存储系统、至少一个输入装置、和至少一个输出装置接收数据和指令，并且将数据和指令传输至该存储系统、该至少一个输入装置、和该至少一个输出装置。123.用于实施本公开的方法的程序代码可以采用一个或多个编程语言的任何组合来编写。这些程序代码可以提供给通用计算机、专用计算机或其他可编程数据处理装置的处理器或控制器，使得程序代码当由处理器或控制器执行时使流程图和/或框图中所规定的功能/操作被实施。程序代码可以完全在机器上执行、部分地在机器上执行，作为独立软件包部分地在机器上执行且部分地在远程机器上执行或完全在远程机器或服务器上执行。124.在本公开的上下文中，机器可读介质可以是有形的介质，其可以包含或存储以供指令执行系统、装置或设备使用或与指令执行系统、装置或设备结合地使用的程序。机器可读介质可以是机器可读信号介质或机器可读储存介质。机器可读介质可以包括但不限于电子的、磁性的、光学的、电磁的、红外的、或半导体系统、装置或设备，或者上述内容的任何合适组合。机器可读存储介质的更具体示例会包括基于一个或多个线的电气连接、便携式计算机盘、硬盘、随机存取存储器(ram)、只读存储器(rom)、可擦除可编程只读存储器(eprom或快闪存储器)、光纤、便捷式紧凑盘只读存储器(cd-rom)、光学储存设备、磁储存设备、或上述内容的任何合适组合。125.为了提供与用户的交互，可以在计算机上实施此处描述的系统和技术，该计算机具有：用于向用户显示信息的显示装置(例如，crt(阴极射线管)或者lcd(液晶显示器)监视器)；以及键盘和指向装置(例如，鼠标或者轨迹球)，用户可以通过该键盘和该指向装置来将输入提供给计算机。其它种类的装置还可以用于提供与用户的交互；例如，提供给用户的反馈可以是任何形式的传感反馈(例如，视觉反馈、听觉反馈、或者触觉反馈)；并且可以用任何形式(包括声输入、语音输入或者、触觉输入)来接收来自用户的输入。126.可以将此处描述的系统和技术实施在包括后台部件的计算系统(例如，作为数据服务器)、或者包括中间件部件的计算系统(例如，应用服务器)、或者包括前端部件的计算系统(例如，具有图形用户界面或者网络浏览器的用户计算机，用户可以通过该图形用户界面或者该网络浏览器来与此处描述的系统和技术的实施方式交互)、或者包括这种后台部件、中间件部件、或者前端部件的任何组合的计算系统中。可以通过任何形式或者介质的数字数据通信(例如，通信网络)来将系统的部件相互连接。通信网络的示例包括：局域网(lan)、广域网(wan)和互联网。127.计算机系统可以包括客户端和服务器。客户端和服务器一般远离彼此并且通常通过通信网络进行交互。通过在相应的计算机上运行并且彼此具有客户端-服务器关系的计算机程序来产生客户端和服务器的关系。服务器可以是云服务器，也可以为分布式系统的服务器，或者是结合了区块链的服务器。128.应该理解，可以使用上面所示的各种形式的流程，重新排序、增加或删除步骤。例如，本发公开中记载的各步骤可以并行地执行也可以顺序地执行也可以不同的次序执行，只要能够实现本公开公开的技术方案所期望的结果，本文在此不进行限制。129.上述具体实施方式，并不构成对本公开保护范围的限制。本领域技术人员应该明白的是，根据设计要求和其他因素，可以进行各种修改、组合、子组合和替代。任何在本公开的精神和原则之内所作的修改、等同替换和改进等，均应包含在本公开保护范围之内。当前第1页12当前第1页12
技术特征：
1.一种回源处理方法，包括：基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息；基于所述目标上层节点的信息，向所述目标上层节点转发所述第一回源请求，以从所述目标上层节点中获取所述第一直播流标识对应的第一直播流。2.根据权利要求1所述的方法，其中，基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息，包括：基于所述第一直播流标识进行一致性哈希计算，确定当前所在的所述上层节点层中、负责处理所述第一直播流回源的所述目标上层节点的标识。3.根据权利要求1所述的方法，其中，基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息之后，基于所述目标上层节点的信息，向所述目标上层节点转发所述第一回源请求之前，所述方法还包括：确定所述目标上层节点不是当前上层节点。4.根据权利要求3所述的方法，其中，所述方法还包括：若目标上层节点为当前上层节点，向流媒体中心平台转发所述第一回源请求，以从所述流媒体中心平台获取所述第一直播流标识对应的所述第一直播流。5.根据权利要求1所述的方法，其中，所述方法还包括：控制接收到所述第一回源请求的当前服务进程基于所述第一直播流标识，确定当前上层节点内负责处理所述第一直播流回源的目标服务进程的标识；控制所述当前服务进程基于所述目标服务进程的标识，向所述目标服务进程转发所述第一回源请求。6.根据权利要求5所述的方法，其中，基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息，包括：控制所述目标服务进程，基于所述第一直播流标识，确定当前所在的所述上层节点层中、负责处理所述第一直播流回源的所述目标上层节点的标识；其中，基于所述目标上层节点的信息，向所述目标上层节点转发所述第一回源请求，包括：控制所述目标服务进程基于所述目标上层节点的标识，向所述目标上层节点转发所述第一回源请求。7.根据权利要求5所述的方法，其中，控制接收到所述第一回源请求的当前服务进程基于所述第一直播流标识，确定当前上层节点内负责处理所述第一直播流回源的目标服务进程的标识之后，控制所述当前服务进程基于所述目标服务进程的标识，向所述目标服务进程转发所述第一回源请求之前，所述方法还包括：控制所述当前服务进程确定所述目标服务进程不是自身。8.根据权利要求5所述的方法，其中，控制接收到所述第一回源请求的当前服务进程基于所述第一直播流标识，确定当前上层节点内负责处理所述第一直播流回源的目标服务进
程的标识，包括：控制所述当前服务进程，基于所述第一直播流标识进行一致性哈希计算，确定所述当前上层节点内负责处理所述第一直播流回源的所述目标服务进程的标识。9.根据权利要求6所述的方法，其中，控制所述目标服务进程基于所述目标上层节点的标识，向所述目标上层节点转发所述第一回源请求之后，所述方法还包括：在所述目标服务进程与所述当前服务进程之间建立辅助通道；控制所述目标服务进程通过所述辅助通道向所述当前服务进程返回所述第一回源请求的转发信息，所述转发信息中携带所述目标上层节点的信息。10.根据权利要求9所述的方法，其中，所述方法还包括：若所述当前服务进程接收到携带第二直播流标识和发送端的信息的第二回源请求时，控制所述当前服务进程检测所述第二直播流标识是否为正在请求的所述第一直播流标识；若是，控制所述当前服务进程检测所述第二回源请求的所述发送端，是否为正在请求的所述第一直播流标识对应的所述第一回源请求转发到的所述目标上层节点；若是，控制所述当前服务进程向所述发送端返回回源消息，所述回源消息用于指示所述发送端向流媒体中心平台请求所述第一直播流；并控制所述当前服务进程断开与所述发送端的连接。11.一种回源处理装置，包括：确定模块，用于基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息；发送模块，用于基于所述目标上层节点的信息，向所述目标上层节点转发所述第一回源请求，以从所述目标上层节点中获取所述第一直播流标识对应的第一直播流。12.根据权利要求11所述的装置，其中，所述确定模块，用于：基于所述第一直播流标识进行一致性哈希计算，确定当前所在的所述上层节点层中、负责处理所述第一直播流回源的所述目标上层节点的标识。13.根据权利要求11所述的装置，其中，所述确定模块，还用于：确定所述目标上层节点不是当前上层节点。14.根据权利要求13所述的装置，其中，所述发送模块，还用于：若目标上层节点为当前上层节点，向流媒体中心平台转发所述第一回源请求，以从所述流媒体中心平台获取所述第一直播流标识对应的所述第一直播流。15.根据权利要求11所述的装置，其中，所述确定模块，还用于：控制接收到所述第一回源请求的当前服务进程基于所述第一直播流标识，确定当前上层节点内负责处理所述第一直播流回源的目标服务进程的标识；所述发送模块，还用于控制所述当前服务进程基于所述目标服务进程的标识，向所述目标服务进程转发所述第一回源请求。16.根据权利要求15所述的装置，其中，所述确定模块，用于：控制所述目标服务进程，基于所述第一直播流标识，确定当前所在的所述上层节点层中、负责处理所述第一直播流回源的所述目标上层节点的标识；所述发送模块，用于：控制所述目标服务进程基于所述目标上层节点的标识，向所述目标上层节点转发所述
第一回源请求。17.根据权利要求15所述的装置，其中，所述确定模块，用于：控制所述当前服务进程确定所述目标服务进程不是自身。18.根据权利要求15所述的装置，其中，所述确定模块，用于：控制所述当前服务进程，基于所述第一直播流标识进行一致性哈希计算，确定所述当前上层节点内负责处理所述第一直播流回源的所述目标服务进程的标识。19.根据权利要求16所述的装置，其中，所述装置还包括：建立模块，用于在所述目标服务进程与所述当前服务进程之间建立辅助通道；所述发送模块，用于控制所述目标服务进程通过所述辅助通道向所述当前服务进程返回所述第一回源请求的转发信息，所述转发信息中携带所述目标上层节点的信息。20.根据权利要求19所述的装置，其中，所述装置还包括：检测模块，用于若所述当前服务进程接收到携带第二直播流标识和发送端的信息的第二回源请求时，控制所述当前服务进程检测所述第二直播流标识是否为正在请求的所述第一直播流标识；所述检测模块，还用于若是，控制所述当前服务进程检测所述第二回源请求的所述发送端，是否为正在请求的所述第一直播流标识对应的所述第一回源请求转发到的所述目标上层节点；所述发送模块，还用于若是，控制所述当前服务进程向所述发送端返回回源消息，所述回源消息用于指示所述发送端向流媒体中心平台请求所述第一直播流；断开模块，用于控制所述当前服务进程断开与所述发送端的连接。21.一种电子设备，包括：至少一个处理器；以及与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器能够执行权利要求1-10中任一项所述的方法。22.一种存储有计算机指令的非瞬时计算机可读存储介质，其中，所述计算机指令用于使所述计算机执行根据权利要求1-10中任一项所述的方法。23.一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现根据权利要求1-10中任一项所述的方法。

技术总结
本公开提供了一种回源处理方法、装置、电子设备及存储介质，涉及人工智能领域，具体涉及云计算、云存储和内容分发技术，可应用在智能云场景下。具体实现方案包括：基于接收到的第一回源请求中的第一直播流标识，确定当前所在的上层节点层中、负责处理所述第一直播流回源的目标上层节点的信息；基于所述目标上层节点的信息，向所述目标上层节点转发所述第一回源请求，以从所述目标上层节点中获取所述第一直播流标识对应的第一直播流。本公开的技术，能够有效地降低流媒体资源平台的带宽成本。能够有效地降低流媒体资源平台的带宽成本。能够有效地降低流媒体资源平台的带宽成本。


技术研发人员：单腾飞
受保护的技术使用者：北京百度网讯科技有限公司
技术研发日：2023.04.10
技术公布日：2023/7/28