当前位置: 首页 > news >正文

关于在分布式环境中RVN和使用场景的介绍4

简介

在前面的文档中,我们介绍了RVN的概念,通过RVN可以解决的某类问题和使用技巧,以及处理RVN的逻辑的具体实现。在本文中,我们将要介绍关于如何使用RVN解决另一种在分布式系统中常出现的问题。

问题

假设我们创建了一个service来维护某种record。我们的service允许client获取record,并且基于现有record的内容对record进行修改。举例说,假设我们的record记录了client一方的某种操作的数量。Client每完成一次操作就将service一侧的count加1。当然我们有其它的方法,但是我们现在要求count的计算部分在client一侧完成。具体来说,我们的record可以定义为:

Record {int ID;int count;
}

Service提供的API 为:

void updateRecord(Record record);

但是在分布式系统中,可能有多个client同时试图更新同一个record,这样这两个client的update就会互相覆盖,从而使最终的结果错误。例如在下图,我们数据库中保存的ID “1”的数量是10。现在有两个client同时获取了这个记录,然后同时试图将数量改为11。最终两个带有11的结果将互相覆盖,从而我们错误的保存了11,而不是12。我们将如何避免这个问题?

解决方法

这个问题同样可以使用RVN来解决。具体来说,我们在record里加入RVN,代表某条记录的版本号。对于每次更新,client都要先获取当前记录以及它的版本号,然后将版本号加1写入到update record的request里。而service端需要检查request的RVN,确保该RVN大于当前保存的保本好,最后再将该记录和RVN写入到数据库。我们详细描述该过程如下:

现在client1和client2都获取了RVN为1的记录,然后都将RVN更新为2,发送request去试图更新service一侧的数据。Service一侧的逻辑如下:

在这里我们需要特别说明几点。为了保证处理的正确性,service必须保证在处理record的过程中RVN一直是合理的,否则就可能出现两个thread都认为自己的RVN是正确的,从而仍然互相覆盖。这样我们可以使用lock住record的ID,并且在处理完record之后再unlock,来保证处理的正确性。我们也可以使用DynamoDB的condition update来达到相同的目的,具体可以参见《关于在分布式环境中RVN和使用场景的介绍3》。

在这种逻辑下,后获得锁的thread将会发现它所持有的RVN已经不是合理的RVN了,所以它会拒绝处理它持有的request,并且向client汇报这一情况(比如可以throw exception)。而client可以重新从service获得最新的RVN的record,再次尝试根据最新的记录进行更新。

问题扩展

在我们讨论的解决方案里,我们期望service和client可以遵守共同的规则在一起工作,比如期望所有的client都可以基于获取的RVN每次增加1。只有在这种情况下,我们的数据才能被维护正确。假如,我们的API是公开的API,也就是说client并不总是可信的。Client可能会破坏规则给RVN增加2或者更多来试图非法获取修改数据的规则。在这种情况下,我们可以给每一个record version生成一个UUID来代替RVN。Client必须提供当前version的UUID以获取修改当前record的资格。在每次record被改变时都生成新的UUID。

参考文档

《关于在分布式环境中RVN和使用场景的介绍1》

《关于在分布式环境中RVN和使用场景的介绍2》

《关于在分布式环境中RVN和使用场景的介绍3》

相关文章:

  • 【Git】:远程仓库操作
  • 祝贺!湖南天府生态农业有限公司喜获“湖南省生猪核心育种场”授牌
  • 使用傅里叶实现100倍的压缩效果(附Python源码)
  • 【TCP/IP】组播
  • WPF 控件禁用时,显示悬浮提示
  • http协议工具:apache详解
  • 数学建模:BP神经网络(含python实现)
  • geoserver 热力图样式
  • 从kafka如何保证数据一致性看通常数据一致性设计
  • 利用LaTex批量将eps转pdf、png转eps、eps转png、eps转svg
  • 这才开工没几天收到Offer了,简历改的好,找工作没烦恼。
  • 基于ant的图片上传组件封装(复制即可使用)
  • 2个wordpress优化SEO主题模板
  • TypeScript基础知识点
  • 捕捉消费新趋势,脉纷纷让生活更便捷
  • 【108天】Java——《Head First Java》笔记(第1-4章)
  • 11111111
  • Fundebug计费标准解释:事件数是如何定义的?
  • gcc介绍及安装
  • input的行数自动增减
  • javascript面向对象之创建对象
  • react 代码优化(一) ——事件处理
  • ucore操作系统实验笔记 - 重新理解中断
  • 从零开始的无人驾驶 1
  • 规范化安全开发 KOA 手脚架
  • 计算机常识 - 收藏集 - 掘金
  • 简析gRPC client 连接管理
  • 一个完整Java Web项目背后的密码
  • 用Node EJS写一个爬虫脚本每天定时给心爱的她发一封暖心邮件
  • “十年磨一剑”--有赞的HBase平台实践和应用之路 ...
  • 微龛半导体获数千万Pre-A轮融资,投资方为国中创投 ...
  • ​创新驱动,边缘计算领袖:亚马逊云科技海外服务器服务再进化
  • ​如何使用ArcGIS Pro制作渐变河流效果
  • #鸿蒙生态创新中心#揭幕仪式在深圳湾科技生态园举行
  • #经典论文 异质山坡的物理模型 2 有效导水率
  • #我与Java虚拟机的故事#连载01:人在JVM,身不由己
  • $ is not function   和JQUERY 命名 冲突的解说 Jquer问题 (
  • $con= MySQL有关填空题_2015年计算机二级考试《MySQL》提高练习题(10)
  • $forceUpdate()函数
  • %3cli%3e连接html页面,html+canvas实现屏幕截取
  • (M)unity2D敌人的创建、人物属性设置,遇敌掉血
  • (第一天)包装对象、作用域、创建对象
  • (附源码)spring boot火车票售卖系统 毕业设计 211004
  • (附源码)springboot“微印象”在线打印预约系统 毕业设计 061642
  • (官网安装) 基于CentOS 7安装MangoDB和MangoDB Shell
  • (十三)Flask之特殊装饰器详解
  • (四)鸿鹄云架构一服务注册中心
  • (新)网络工程师考点串讲与真题详解
  • (一)RocketMQ初步认识
  • (原創) 如何安裝Linux版本的Quartus II? (SOC) (Quartus II) (Linux) (RedHat) (VirtualBox)
  • (转) Face-Resources
  • (转)一些感悟
  • ... fatal error LINK1120:1个无法解析的外部命令 的解决办法
  • .form文件_SSM框架文件上传篇
  • .NET C#版本和.NET版本以及VS版本的对应关系