发明名称 一种海量数据管理中动态一致性控制方法
摘要 本发明公开了一种海量数据环境下动态的一致性控制方法,步骤为:①主线程对环境做初始化工作;②服务节点开始监听来自客户端发来的读写请求;③当服务节点接收到一个来自客户端发来的数据读写请求任务后,首先读取该请求任务的操作类型;④读取该请求任务的偏差类型,并读取该请求任务的偏差值,并将读取结果与当前的阈值比较后放到相应的队列尾部;⑤回退到②,继续监听来自客户端发来的请求。本发明可以克服不同的应用由于其业务数据对于一致性要求的差异性而不能使用现成的键值型数据库的困难。使得用户只需要关心所操作的数据对于一致性的指标及其取值,而完全不需要花大量的精力重新开发一套只能满足自己业务需求的键值型数据库。
申请公布号 CN102521265A 申请公布日期 2012.06.27
申请号 CN201110371947.X 申请日期 2011.11.21
申请人 华中科技大学 发明人 金海;谢夏;岑文峰;柯西江
分类号 G06F17/30(2006.01)I 主分类号 G06F17/30(2006.01)I
代理机构 华中科技大学专利中心 42201 代理人 曹葆青
主权项 一种海量数据管理中动态一致性控制方法,其特征在于,该方法包括以下步骤:(1)主线程对环境做初始化工作,包括以下五个步骤:(1.1)创建三个空置队列,按照创建的先后顺序,分别命名为高优先级队列,表示为HQ;中优先级队列,表示为MQ;低优先级队列,表示为LQ;(1.2)创建三个变量NS、VS、PS,分别用来保存所有的任务队列中所有的任务的数据条目偏差总和,数值偏差总和以及新旧程度偏差总和,并将初始值均设为0;(1.3)创建三个计数器NC、VC、PC,分别用来保存当前所有的任务队列中关于数据条目偏差的任务总数,数值偏差的任务总数以及新旧程度偏差的任务总数,并将初始值均设为0;(1.4)创建并启动一个子线程T1,用于逐个处理三个任务队列中的任务;(1.5)创建并启动两个子线程T2和T3,用于定期调度三个任务队列中的任务,避免因较高优先级任务队列中的任务长时间拥堵,导致较低优先级队列中的任务没有机会处理的情况发生;(2)服务节点开始监听来自客户端发来的读写请求;(3)当服务节点接收到一个来自客户端发来的数据读写请求任务后,首先读取该请求任务的操作类型;(4)读取该请求任务的偏差类型,并读取该请求任务的偏差值,并将读取结果与当前的阈值比较后放到相应的队列尾部;(5)回退到步骤(2),继续监听来自客户端发来的请求。
地址 430074 湖北省武汉市洪山区珞喻路1037号