欢迎来到知嘟嘟! 联系电话:13336804447 卖家免费入驻,海量在线求购! 卖家免费入驻,海量在线求购!
知嘟嘟
我要发布
联系电话:13336804447
知嘟嘟经纪人
收藏
专利号: 201911047652X
申请人: 平安科技(深圳)有限公司
专利类型:发明专利
专利状态:已下证
专利领域: 计算;推算;计数
更新日期:2025-12-10
缴费截止日期: 暂无
价格&联系人
年费信息
委托购买

摘要:

权利要求书:

1.一种存储分区动态选择方法,其特征在于,应用于存储分区动态选择系统,所述系统包括Kafka集群服务器及用户终端,所述方法包括:若所述用户终端接收到待传输消息,根据所述待传输消息生成消息传输请求并发送至Kafka集群服务器;

所述Kafka集群服务器接收所述消息传输请求,根据所述Kafka集群服务器所包含的队列,获取与所述消息传输请求相匹配的服务器的服务器地址信息及存储分区,基于所述服务器地址信息及所述存储分区生成存储分区信息反馈至所述用户终端;

所述用户终端接收所述存储分区信息,其中,所述存储分区信息包括多个存储分区以及每一所述存储分区所对应的存储地址;

所述用户终端根据预置的存储分区选择规则从所述存储分区信息中动态选择一个存储分区作为目标存储分区;

所述存储分区选择规则包含哈希值生成规则、第一计算公式及第二计算公式,所述根据预置的存储分区选择规则从所述存储分区信息中动态选择一个存储分区作为目标存储分区,包括:

根据所述哈希值生成规则生成与所述待传输消息的键值对应的哈希值;

判断所述待传输消息是否为首次发送;

若所述待传输消息为首次发送,选择对应的第一计算公式,将所述存储分区信息及所述哈希值输入所述第一计算公式计算,以将计算结果对应的存储分区作为目标存储分区;

若所述待传输消息非首次发送,选择对应的第二计算公式,将所述存储分区信息、所述哈希值及所述待传输消息的发送次数输入所述第二计算公式计算,以将计算结果对应的存储分区作为目标存储分区;

所述用户终端根据所述存储分区信息中与所述目标存储分区对应的存储地址信息将所述待传输消息传输至所述目标存储分区进行存储。

2.根据权利要求1所述的存储分区动态选择方法,其特征在于,所述根据预置的存储分区选择规则从所述存储分区信息中动态选择一个存储分区作为目标存储分区之前,所述方法还包括:

判断所述待传输消息是否传输成功;

若所述待传输消息未传输成功,获取所述待传输消息的发送次数并自加一以得到更新后的发送次数;

返回执行所述根据预置的存储分区选择规则从所述存储分区信息中选择一个存储分区作为目标存储分区的步骤,以再次获取所述待传输消息的目标存储分区。

3.根据权利要求2所述的存储分区动态选择方法,其特征在于,所述判断所述待传输消息是否传输成功,包括:

判断在反馈时限内是否接收到所述Kafka集群服务器所反馈的传输反馈信息,所述反馈时限为与所述待传输消息的传输时间间隔预置时限的时间;

若在反馈时限内未接收到所述Kafka集群服务器所反馈的传输反馈信息,判定所述待传输消息未传输成功。

4.根据权利要求1所述的存储分区动态选择方法,其特征在于,所述第一计算公式计算为N1=f(K)%n,其中,N1为所述第一计算公式的计算结果,n为所述存储分区信息中所包含存储分区的数量,f(K)为所述哈希值,K为所述待传输消息的键值;

所述第二计算公式计算为N1=(f(K)+S)%n,其中,N2为所述第二计算公式的计算结果,S为所述待传输消息的发送次数。

5.一种存储分区动态选择系统,其特征在于,包括Kafka集群服务器及用户终端,所述Kafka集群服务器包括存储分区信息反馈单元,所述用户终端包括消息传输请求发送单元、存储分区信息接收单元、目标存储分区获取单元及待传输消息发送单元,其中,所述消息传输请求发送单元,用于若接收到待传输消息,根据所述待传输消息生成消息传输请求并发送至Kafka集群服务器;

所述存储分区信息反馈单元,用于接收所述消息传输请求,根据所述Kafka集群服务器所包含的队列,获取与所述消息传输请求相匹配的服务器的服务器地址信息及存储分区,基于所述服务器地址信息及所述存储分区生成存储分区信息反馈至所述用户终端;

所述存储分区信息接收单元,用于接收所述存储分区信息,其中,所述存储分区信息包括多个存储分区以及每一所述存储分区所对应的存储地址;

所述目标存储分区获取单元,用于根据预置的存储分区选择规则从所述存储分区信息中动态选择一个存储分区作为目标存储分区;

哈希值获取单元,用于根据所述哈希值生成规则生成与所述待传输消息的键值对应的哈希值;

发送判断单元,用于判断所述待传输消息是否为首次发送;

第一计算单元,用于若所述待传输消息为首次发送,选择对应的第一计算公式,将所述存储分区信息及所述哈希值输入所述第一计算公式计算,以将计算结果对应的存储分区作为目标存储分区;

第二计算单元,用于若所述待传输消息非首次发送,选择对应的第二计算公式,将所述存储分区信息、所述哈希值及所述待传输消息的发送次数输入所述第二计算公式计算,以将计算结果对应的存储分区作为目标存储分区;

所述待传输消息发送单元,用于根据所述存储分区信息中与所述目标存储分区对应的存储地址信息将所述待传输消息传输至所述目标存储分区进行存储。

6.根据权利要求5所述的存储分区动态选择系统,其特征在于,还包括:传输判断单元,用于判断所述待传输消息是否传输成功;

发送次数更新单元,用于若所述待传输消息未传输成功,获取所述待传输消息的发送次数并自加一以得到更新后的发送次数;

存储分区再次获取单元,用于返回执行所述根据预置的存储分区选择规则从所述存储分区信息中选择一个存储分区作为目标存储分区的步骤,以再次获取所述待传输消息的目标存储分区。

7.一种计算机设备,包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序,其特征在于,所述处理器执行所述计算机程序时实现如权利要求1至4中任一项所述的存储分区动态选择方法。

8.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质存储有计算机程序,所述计算机程序当被处理器执行时使所述处理器执行如权利要求1至4任一项所述的存储分区动态选择方法。