欢迎来到知嘟嘟! 联系电话:13095918853 卖家免费入驻,海量在线求购! 卖家免费入驻,海量在线求购!
知嘟嘟
我要发布
联系电话:13095918853
知嘟嘟经纪人
收藏
专利号: 2020116091171
申请人: 平安普惠企业管理有限公司
专利类型:发明专利
专利状态:授权未缴费
专利领域: 计算;推算;计数
更新日期:2023-08-11
缴费截止日期: 暂无
价格&联系人
年费信息
委托购买

摘要:

权利要求书:

1.一种应用于蓝绿发布的消息队列修复方法,其特征在于,消息队列网络的站点名携带有配置环境信息,包括下述步骤:接收用户终端发送的消息发布请求,所述消息发布请求至少携带有广播内容;

基于所述消息队列网络向消息处理中心发送消息广播请求,所述消息广播请求至少携带有所述广播内容以及所述配置环境信息;

判断所述消息处理中心是否返回与所述配置环境信息相对应的请求异常信号;

若所述消息处理中心没有返回所述请求异常信号,则确定所述广播内容已广播至消息队列中;

若所述消息处理中心返回所述请求异常信号,则基于负载均衡算法对所述消息广播请求进行消息队列修复操作,得到修复消息队列;

基于所述修复消息队列向所述消息处理中心发送所述消息广播请求;所述消息广播请求还携带有权效向量,在所述若所述消息处理中心没有返回所述请求异常信号,则确定该广播内容已广播至消息队列中的步骤之后,还包括下述步骤:判断与所述广播内容的消息主题相对应消息量是否满载;

若所述消息量未满载,则将所述消息广播请求的所述权效向量加入至权效向量空间,并将所述广播内容放入所述消息主题中,以进行消息广播;

若所述消息量满载,则基于所述权效向量计算所述消息广播请求的当前权效值;

获取当前所述权效向量空间中所有已存放消息的已存权效值,并计算所述权效向量空间的权效阈值;

判断所述当前权效值是否大于所述权效阈值;

若所述当前权效值大于所述权效阈值,则在所述已存放消息中删除一条所述已存权效值小于所述权效阈值的所述已存放消息,并将所述广播内容放入所述消息主题中,以进行消息广播;

若所述当前权效值小于所述权效阈值,则取消消息广播操作。

2.根据权利要求1所述的应用于蓝绿发布的消息队列修复方法,其特征在于,所述消息广播请求还包括广播主题信息,所述若所述消息处理中心返回所述请求异常信号,则基于负载均衡算法对所述消息广播请求进行消息队列修复操作的步骤,具体包括下述步骤:采集与所述广播主题信息相对应的关联消费者数据以及关联队列标识数据;

在所述关联消费者数据中获取与所述配置环境信息相一致的目标消费者;

在所述关联队列标识数据中获取与所述配置环境信息相一致的目标队列标识;

分别对所述目标消费者以及所述目标队列标识进行排序操作,得到两列排序结果;

基于所述排序结果,分别为每个所述目标消费者分配一个所述目标队列标识。

3.根据权利要求1所述的应用于蓝绿发布的消息队列修复方法,其特征在于,所述权效向量空间为四维向量组成的向量空间,所述四维向量包括消息ID、重要度、时效度和置换标识;

所述重要度表示为: ;

其中,x表示任意一条消息, 表示消息x的优先级, 表示消息x的发送源权重, 表示消息x的重要度;

所述时效度表示为: ;

其中, 表示消息x的发送时间, 表示消息x的时效度。

4.根据权利要求3所述的应用于蓝绿发布的消息队列修复方法,其特征在于,所述基于所述权效向量计算所述消息广播请求的当前权效值的步骤,具体包括:根据所述消息广播请求的重要度和时效度计算所述当前权效值,所述当前权效值表示为: ;

其中, 表示所述消息广播请求, 表示所述消息广播请求的权效值,α为重权参数,β为时权参数, 为当前消息的重要度, 为所述当前消息的时效度。

5.根据权利要求3所述的应用于蓝绿发布的消息队列修复方法,其特征在于,所述权效阈值表示为: ;

其中,n为当前权效向量空间中的权效向量总数, 为第i个消息的权效值,为第i个消息的加权参数,且有: 。

6.根据权利要求5所述的应用于蓝绿发布的消息队列修复方法,其特征在于,所述加权参数表示为: ;

其中,W为当前消息主题中所有消息的权效值之和,即: ;

为第i个消息的权效值,n为当前权效向量空间中的权效向量总数,即当前消息主题中的消息数量。

7.一种应用于蓝绿发布的消息队列修复装置,其特征在于,消息队列网络的站点名携带有配置环境信息,包括:发布请求接收模块,用于接收用户终端发送的消息发布请求,所述消息发布请求至少携带有广播内容;

第一请求发送模块,用于基于所述消息队列网络向消息处理中心发送消息广播请求,所述消息广播请求至少携带有广播内容以及所述配置环境信息;

异常判断模块,用于判断所述消息处理中心是否返回与所述配置环境信息相对应的请求异常信号;

广播正常模块,用于若所述消息处理中心没有返回所述请求异常信号,则确定所述广播内容已广播至消息队列中;

异常修复模块,用于若所述消息处理中心返回所述请求异常信号,则基于负载均衡算法对所述消息广播请求进行消息队列修复操作,得到修复消息队列;

第二请求发送模块,用于基于所述修复消息队列向所述消息处理中心发送所述消息广播请求;所述装置还包括:满载判断模块、未满载模块、满载确定模块、权效阈值计算模块、权效阈值判断模块、已存放消息处理模块以及广播取消模块,其中:所述满载判断模块,用于判断与所述广播内容的消息主题相对应消息量是否满载;

所述未满载模块,用于若所述消息量未满载,则将所述消息广播请求的权效向量加入至权效向量空间,并将所述广播内容放入所述消息主题中,以进行消息广播;

所述满载确定模块,用于若所述消息量满载,则基于所述权效向量计算所述消息广播请求的当前权效值;

所述权效阈值计算模块,用于获取当前所述权效向量空间中所有已存放消息的已存权效值,并计算所述权效向量空间的权效阈值;

所述权效阈值判断模块,用于判断所述当前权效值是否大于所述权效阈值;

所述已存放消息处理模块,用于若所述当前权效值大于所述权效阈值,则在所述已存放消息中删除一条所述已存权效值小于所述权效阈值的所述已存放消息,并将所述广播内容放入所述消息主题中,以进行消息广播;

所述广播取消模块,用于若所述当前权效值小于所述权效阈值,则取消消息广播操作。

8.一种计算机设备,包括存储器和处理器,所述存储器中存储有计算机可读指令,所述处理器执行所述计算机可读指令时实现如权利要求1至6中任一项所述的应用于蓝绿发布的消息队列修复方法的步骤。

9.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质上存储有计算机可读指令,所述计算机可读指令被处理器执行时实现如权利要求1至6中任一项所述的应用于蓝绿发布的消息队列修复方法的步骤。