欢迎来到知嘟嘟! 联系电话:13095918853 卖家免费入驻,海量在线求购! 卖家免费入驻,海量在线求购!
知嘟嘟
我要发布
联系电话:13095918853
知嘟嘟经纪人
收藏
专利号: 2022100298388
申请人: 深圳市天一泓科技有限公司
专利类型:发明专利
专利状态:已下证
专利领域: 电通信技术
更新日期:2024-02-23
缴费截止日期: 暂无
价格&联系人
年费信息
委托购买

摘要:

权利要求书:

1.一种消息延迟消费方法,其特征在于,应用于延迟消费系统的第一服务器,其中,所述延迟消费系统还包括第二服务器和第三服务器,其中,所述第一服务器位于延迟服务端、所述第二服务器位于生产端以及所述第三服务器位于消费端;所述方法包括:所述第一服务器从消息队列的预设主题中消费待消费延迟消息,并将所述待消费延迟消息存储到预设数据库,包括:获取所述预设数据库中每个已存储的延迟消息的剩余延迟时间,其中,所述剩余延迟时间为第一时长和每个已存储的延迟消息的延迟时间之间的差值,其中,所述第一时长为当前时刻和消费所述每个已存储的延迟消息的时刻之间的时长;

对所述待消费延迟消息的延迟时间和每个已存储的延迟消息的剩余延迟时间从大到小进行排序,得到所述待消费延迟消息在所述预设数据库中的存储顺序;根据所述待消费延迟消息的存储顺序,将所述待消费延迟消息存储到所述预设数据库,其中,所述待消费延迟消息是由所述第二服务器发布到所述消息队列的所述预设主题中的,所述待消费延迟消息包括原始消息、所述原始消息的原始主题以及所述原始消息的延迟时间;

所述第一服务器周期性的扫描所述预设数据库,从所述预设数据库中获取目标延迟消息,包括:按照所述预设数据库中已存储的延迟消息的存储顺序,对所述已存储的延迟消息进行周期性扫描;若首次扫描到第i个已存储的延迟消息的延迟时间到达,且第i+n个已存储的延迟消息未到达,则不再对位于所述第i个已存储的延迟消息之后的延迟消息进行扫描,并且将第i个已存储的延迟消息到第i+n‑1个已存储的延迟消息,均作为所述目标延迟消息,其中,n为大于或者等于1的整数,其中,目标延迟消息为所述预设数据库中当前存储的所有延迟消息中延迟时间小于或等于第一时长的延迟消息,其中,所述第一时长为当前时刻和所述第一服务器消费所述目标延迟消息的时刻之间的差值;

所述第一服务器获取所述目标延迟消息的目标主题,并将所述目标延迟消息中的原始消息发回到所述消息队列中的所述目标主题,以便所述第三服务器从所述目标主题中消费所述目标延迟消息中的原始消息。

2.根据权利要求1所述的方法,其特征在于,所述消费待消费延迟消息是所述第二服务器通过执行以下步骤得到的:

所述第二服务器对生产者生产的所述原始消息进行类型识别,确定所述原始消息为需要进行延迟消费的消息;

所述第二服务器对所述原始消息进行主题识别,得到所述原始消息的原始主题;

所述第二服务器根据所述生产者在多个特征维度下的多个用户特征数据,确定所述原始消息的延迟时间;

所述第二服务器将所述原始消息、所述原始消息的原始主题以及所述原始消息的延迟时间封装为所述待消费延迟消息。

3.根据权利要求2所述的方法,其特征在于,所述第二服务器根据所述生产者在多个特征维度下的多个用户特征数据,确定所述原始消息的延迟时间,包括:所述第二服务器根据所述生产者在所述多个特征维度下的多个用户特征数据以及每个候选用户在所述多个特征维度下的多个用户特征数据,从多个候选用户中获取多个目标用户,其中,所述多个目标用户中的任意一个所述目标用户与所述生产者至少在一个所述特征维度下具有相同的用户特征数据;

所述第二服务器根据所述生产者在所述多个特征维度下的多个用户特征数据,以及每个所述目标用户在所述多个特征维度下的多个用户特征数据,确定所述原始消息的延迟时间。

4.根据权利要求3所述的方法,其特征在于,所述第二服务器根据所述生产者在所述多个特征维度下的多个用户特征数据,以及每个所述目标用户在所述多个特征维度下的多个用户特征数据,确定所述原始消息的延迟时间,包括:所述第二服务器通过语义提取模型对所述生产者在所述多个特征维度下的多个用户特征数据进行向量化,得到所述生产者的第一特征向量;

所述第二服务器通过所述语义提取模型分别对每个所述目标用户在所述多个特征维度下的多个用户特征数据进行向量化,得到每个所述目标用户的第二特征向量;

所述第二服务器基于所述生产者的权重以及每个所述目标用户的权重,对所述生产者的第一特征向量以及每个所述目标用户的第二特征向量进行加权,得到目标特征向量;

所述第二服务器将所述目标特征向量输入到多层感知器中进行时间预测,得到所述原始消息的延迟时间。

5.根据权利要求3或4所述的方法,其特征在于,所述第二服务器基于所述生产者的权重以及每个所述目标用户的权重,对所述生产者的第一特征向量以及每个所述目标用户的第二特征向量进行加权之前,所述方法还包括:所述第二服务器获取所述生产者在所述多个特征维度下的多个用户特征数据和每个所述目标用户在所述多个特征维度下的多个用户特征数据相同的数量;

所述第二服务器根据每个所述目标用户对应的相同的数量进行归一化处理,得到每个所述目标用户的初始权重;

所述第二服务器对每个所述目标用户的初始权重以及所述生产者的初始权重进行归一化,得到每个所述目标用户的权重,以及所述生产者的权重,其中,所述生产者的初始权重为1。

6.一种服务器,其特征在于,所述服务器应用于延迟消费系统,所述延迟消费系统还包括第二服务器和第三服务器,其中,所述服务器位于延迟服务端、所述第二服务器位于生产端以及所述第三服务器位于消费端;所述服务器包括收发单元和处理单元;

所述收发单元,用于从消息队列的预设主题中消费待消费延迟消息,并将所述待消费延迟消息存储到预设数据库,包括:获取所述预设数据库中每个已存储的延迟消息的剩余延迟时间,其中,所述剩余延迟时间为第一时长和每个已存储的延迟消息的延迟时间之间的差值,其中,所述第一时长为当前时刻和消费所述每个已存储的延迟消息的时刻之间的时长;对所述待消费延迟消息的延迟时间和每个已存储的延迟消息的剩余延迟时间从大到小进行排序,得到所述待消费延迟消息在所述预设数据库中的存储顺序;根据所述待消费延迟消息的存储顺序,将所述待消费延迟消息存储到所述预设数据库,其中,所述待消费延迟消息是由所述第二服务器发布到所述消息队列的所述预设主题中的,所述待消费延迟消息包括原始消息、所述原始消息的原始主题以及所述原始消息的延迟时间;

所述处理单元,用于周期性的扫描所述预设数据库,从所述预设数据库中获取目标延迟消息,包括:按照所述预设数据库中已存储的延迟消息的存储顺序,对所述已存储的延迟消息进行周期性扫描;若首次扫描到第i个已存储的延迟消息的延迟时间到达,且第i+n个已存储的延迟消息未到达,则不再对位于所述第i个已存储的延迟消息之后的延迟消息进行扫描,并且将第i个已存储的延迟消息到第i+n‑1个已存储的延迟消息,均作为所述目标延迟消息,其中,n为大于或者等于1的整数,其中,目标延迟消息为所述预设数据库中当前存储的所有延迟消息中延迟时间小于或等于第一时长的延迟消息,其中,所述第一时长为当前时刻和所述服务器消费所述目标延迟消息的时刻之间的差值;获取所述目标延迟消息的目标主题;

所述收发单元,还用于将所述目标延迟消息中的原始消息发回到所述消息队列中的所述目标主题,以便所述第三服务器从所述目标主题中消费所述目标延迟消息中的原始消息。

7.一种电子设备,其特征在于,包括:处理器和存储器,所述处理器与所述存储器相连,所述存储器用于存储计算机程序,所述处理器用于执行所述存储器中存储的计算机程序,以使得所述电子设备执行如权利要求1‑5中任一项所述的方法。

8.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质存储有计算机程序,所述计算机程序被处理器执行以实现如权利要求1‑5中任一项所述的方法。