直播物料处理方法及装置与流程

本申请涉及计算机，尤其涉及一种直播物料处理方法及装置。

背景技术：

1、直播推荐物料池在直播场景中扮演着关键的角色，用于储存和管理主播生成的直播物料。直播物料入池后，需要对直播物料的物料状态和物料特征进行及时和准确地更新，以向用户推荐高质量的直播内容，提高用户体验和留存率。

2、然而，相关技术中，直播物料的物料状态更新任务和物料特征更新任务之间相互独立互不通信，存在相互冲突的情况，影响更新准确性，进而影响用户体验和留存率。

技术实现思路

1、本申请实施例的目的提供一种直播物料处理方法及装置，用于解决直播物料更新时物料状态更新任务和物料特征更新任务之间相互独立互不通信，存在相互冲突的情况，影响更新准确性，进而影响用户体验和留存率的问题。

2、为了实现上述目的，本申请实施例采用下述技术方案：

3、第一方面，本申请实施例提供一种直播物料处理方法，包括：

4、通过第一消息队列接收直播数据，并通过第二消息队列接收物料特征更新数据；

5、通过第一进程，对所述第一消息队列进行消费，从所述直播数据中获取物料状态更新数据并写入所属直播物料对应的第一优先级队列中，以及对所述第二消息队列进行消费，将所述物料特征更新数据写入所属直播物料对应的第一优先级队列中，其中，每个直播物料对应唯一的第一优先级队列；

6、通过所述第一进程对所述第一优先级队列进行消费，基于获取到的物料状态更新数据或物料特征更新数据，对物料池记录的所属直播物料的物料数据进行更新。

7、第二方面，本申请实施例提供一种直播物料处理装置，包括：

8、接收单元，用于通过第一消息队列接收直播数据，并通过第二消息队列接收物料特征更新数据；

9、第一消费单元，用于通过第一进程，对所述第一消息队列进行消费，从所述直播数据中获取物料状态更新数据并写入所属直播物料对应的第一优先级队列中，以及对所述第二消息队列进行消费，将所述物料特征更新数据写入所属直播物料对应的第一优先级队列中，其中，每个直播物料对应唯一的第一优先级队列；

10、第二消费单元，用于通过所述第一进程对所述第一优先级队列进行消费，基于获取到的物料状态更新数据或物料特征更新数据，对物料池记录的所属直播物料的物料数据进行更新。

11、第三方面，本申请实施例提供一种电子设备，包括：处理器；用于存储所述处理器可执行指令的存储器；其中，所述处理器被配置为执行所述指令，以实现如第一方面所述的方法。

12、第四方面，本申请实施例提供一种计算机可读存储介质，当所述存储介质中的指令由电子设备的处理器执行时，使得电子设备能够执行如第一方面所述的方法。

13、本申请实施例采用的上述至少一个技术方案能够达到以下有益效果：通过第一进程对第一消息队列和第二消息队列进行消费，将获取到的物料状态更新数据和物料特征更新数据写入所属直播物料对应的第一优先级队列中，再通过第一进程对第一优先级队列进行消费，基于获取到的物料状态更新数据或物料特征更新数据，对物料池记录的所属直播物料的物料数据进行更新，通过将物料状态更新数据和物料特征更新数据汇集到同一个进程中处理，进而对物料池中的直播物料的物料数据进行更新，避免因状态更新和特征更新之间互不通信而产生数据冲突的情况，保证更新的准确性，提升用户体验和留存率，此外，每个直播物料对应唯一的第一优先级队列，通过第一进程将物料状态更新数据和物料特征更新数据写入所属直播物料对应的第一优先级队列中，再通过第一进程对第一优先级队列进行消费，能够保证同一直播物料进行更新的有序性，避免同一直播物料的不同更新任务并发处理，进而避免数据丢失和覆盖的情况，保证更新的准确性，提升有户体验和留存率。

技术特征：

1.一种直播物料处理方法，其特征在于，包括：

2.根据权利要求1所述的方法，其特征在于，所述通过第一进程，对所述第一消息队列进行消费，从所述直播数据中获取物料状态更新数据并写入所属直播物料对应的第一优先级队列中，以及对所述第二消息队列进行消费，将所述物料特征更新数据写入所属直播物料对应的第一优先级队列中，包括：

3.根据权利要求1所述的方法，其特征在于，所述物料状态更新数据和所述物料特征更新数据通过如下方式写入所属直播物料对应的第一优先级队列中：

4.根据权利要求1所述的方法，其特征在于，在所述通过第一进程，对所述第一消息队列进行消费之前，所述方法还包括：

5.根据权利要求4所述的方法，其特征在于，所述第二优先级队列的数量为多个；

6.根据权利要求4所述的方法，其特征在于，在所述物料数据写入所述物料池中之后，所述方法还包括：

7.根据权利要求1所述的方法，其特征在于，在所述通过第二消息队列接收物料特征更新数据之前，所述方法还包括：

8.根据权利要求1所述的方法，其特征在于，在所述对物料池记录的所述直播物料的物料数据进行更新之后，所述方法还包括：

9.根据权利要求1所述的方法，其特征在于，在所述对物料池记录的所述直播物料的物料数据进行更新之后，所述方法还包括：

10.一种直播物料处理装置，其特征在于，包括：

技术总结
本申请公开了一种直播物料处理方法及装置，所述方法包括：通过第一消息队列接收直播数据，并通过第二消息队列接收物料特征更新数据；通过第一进程，对所述第一消息队列进行消费，从所述直播数据中获取物料状态更新数据并写入所属直播物料对应的第一优先级队列中，以及对所述第二消息队列进行消费，将所述物料特征更新数据写入所属直播物料对应的第一优先级队列中，其中，每个直播物料对应唯一的第一优先级队列；通过所述第一进程对所述第一优先级队列进行消费，基于获取到的物料状态更新数据或物料特征更新数据，对物料池记录的所属直播物料的物料数据进行更新。

技术研发人员：朱立军,孙文亮
受保护的技术使用者：微梦创科网络科技（中国）有限公司
技术研发日：
技术公布日：2024/12/5