05分布式事务之CAP理论和BASE理论

分布式事务

项目优化

在网站上加载课程详情信息时如果很慢(排除网速)会影响用户的体验性，为了提高响应速度需要将课程详情信息进行缓存并且将课程信息加入索引库方便全局搜索

  • Redis中的课程缓存信息是将课程发布表中的数据转为json进行存储
  • Elasticsearch中的课程索引信息是根据搜索需要将课程名称、课程介绍等信息进行索引存储
  • MinIO中存储了包含课程信息的静态化页面文件，再通过Nginx请求查看课程详情页面(Tomcat的并发能力比较弱)

在这里插入图片描述

教学机构用户执行一次课程发布操作后由四个分散的服务与数据库、Redis、elasticsearch、MinIO四个不同的服务进行网络通信

本地事务(数据库事务): 在程序中通过Spring去控制事务是利用数据库本身ACID的事务特性实现,这种是基于微服务自己的关系型数据库中的事务(一次连接)

分布式事务：在分布式系统环境下实现某个事务时需要多个服务通过网络交互共同完成，网络通信时可能会出现问题导致响应未到达

  • 场景: 用户注册送积分，银行转账，创建订单减库存

在这里插入图片描述

# 本地事务
begin transaction； 
//1.本地数据库操作：张三减少金额 
//2.本地数据库操作：李四增加金额 
commit transation; 

# 分布式事务，张三和李四的账户不在一个数据库中甚至不在一个应用系统里，实现转账事务需要通过远程调用
begin transaction； 
//1.本地数据库操作：张三减少金额 
//2.远程调用：让李四增加金额
//3.当远程调用让李四增加金额成功了，由于网络问题远程调用并没有返回，此时本地事务提交失败就会回滚张三减少金额的操作，但远程调用李四增加金额的操作却成功了
commit transation;

CAP理论

CAP表示Consistency(一致性)、Availability(可用性)、Partition tolerance(分区容忍性)三大特点，但在分布式系统中这三点不可能全部满足

  • 一致性: 指用户不管访问哪一个结点拿到的数据都是最新的，如果拿不到最新数据就需要等待同步，不能出现数据没有改变时两次查询结果不一样的情况
  • 可用性: 指任何时候查询用户信息都可以查询到结果，但不能保证查询到最新的数据
  • 分区容忍性(分区容错性)：因为在分布式架构中的服务之间难免出现网络异常，但不能因为局部网络异常导致整个系统不可用， 所以当网络通信异常导致请求中断、消息丢失时系统依然对外提供服务

需求： 添加一个用户小明的信息，该信息先添加到结点1中，再同步到结点2中

  • 满足一致性(CP)：必须等待小明的信息同步完成系统才可用，在信息同步过程中系统是不可用的，即请求到结点2时可能查询不到数据
  • 满足可用性(AP)：要时刻保证系统可用就不能等待信息同步完成才能查询用户信息

在这里插入图片描述

进行分布式事务控制时要在C和A中作出取舍，具体要根据应用场景决定具体方案

  • CP的场景：满足C舍弃A，强调一致性

    • 跨行转账：一次转账请求要等待双方银行系统都完成整个事务才算完成，只要其中一个失败另一方执行回滚操作
    • 开户操作：如在业务系统开户同时要在运营商开户，任何一方开户失败该用户都不可使用

  • AP的场景(使用较多)：满足A舍弃C(最终数据还是会达到一致)，强调可用性

    • 订单退款：今日退款成功，明日账户到账，只要用户可以接受在一定时间内到账即可
    • 注册送积分：注册成功，积分在24小时内到账
    • 支付短信通信：支付成功发短信，短信发送可以有延迟，甚至没有发送成功

BASE理论

在实际应用中符合AP的场景较多，虽然AP舍弃了一致性，但这只是暂时的，因为最终数据还是会达到一致只不过会需要等待数据同步

BASE 是 Basically Available(基本可用)、Soft state(软状态)和Eventually consistent (最终一致性)三个短语的缩写

  • 基本可用：当系统无法满足全部可用时保证核心服务可用即可，如外卖系统：每到中午12点左右系统并发量很高，此时要保证下单流程涉及的服务可用，其它服务暂时不可用
  • 软状态：如当用户发表一条评论时，这条评论并不会立即同步到所有关注者的页面上，而是会先存储在缓存中，并逐渐传播到其他节点，这样就存在了一个中间状态，即某些用户可以看到这条评论，而某些用户还不能看到
  • 最终一致性：如退款操作后没有及时到账，但最终经过一定的时间后一定会到账，舍弃强一致性满足最终一致性

课程发布

界面原型

教育机构用户在课程管理中对本机构内课程进行检索 ,如果审核状态为通过点击课程的发布链接即可发布课程

在这里插入图片描述

课程发布后学生可在网站搜索到教学机构发布的课程信息，并查看课程的详细信息进行选课和学习，此时如果再从数据库查询课程信息就会大大增加DB压力

在这里插入图片描述

课程发布的事务控制方案

实现CP就是要实现强一致性: 执行课程发布操作后向数据库、redis、elasticsearch、MinIO写四份数据，只要有一份写失败其它的全部回滚

  • 使用Seata框架基于AT模式实现
  • 使用Seata框架基于TCC模式实现

实现AP则要保证最终数据一致性: 执行课程发布操作后，先更新数据库中课程信息表的课程发布状态，更新后向redis、Elasticsearch、MinIO写入课程信息(只要在一定时间内写入数据成功即可)

  • 使用消息队列通知方案，通知失败自动重试，达到最大失败次数需要人工处理
  • 使用任务调度方案，启动任务调度将课程信息由数据库同步到Elasticsearch、MinIO、Redis中

在内容管理服务的数据库中创建消息(任务)表：教学机构用户执行课程发布操作后，我们需要告诉调度中心哪个课程的信息需要同步

  • 通过本地事务控制向课程发布表写入发布课程的信息(存在则更新)，写入成功后可以删除课程预发布表中的记录, 最后在消息表添加一条课程发布的任务消息(保证两个操作同时操作成功)
  • 更新课程信息表course_base和课程发布表的课程发布状态为已发布
  • 启动任务调度系统定时调度内容管理服务去扫描消息表的课程任务发布记录,当扫描到课程发布的消息时即开始完成向redis、elasticsearch、MinIO同步数据的操作
  • 同步数据的任务完成后可以删除消息表中对应的课程发布任务记录

在这里插入图片描述

接口定义

在内容管理模块的content-api接口工程中定义课程发布的接口

@Api(value = "课程预览发布接口",tags = "课程预览发布接口")
@Controller
public class CoursePublishController {@ApiOperation("课程发布")@ResponseBody@PostMapping ("/coursepublish/{courseId}")public void coursepublish(@PathVariable("courseId") Long courseId){Long companyId = 1232141425L;coursePublishService.publish(companyId,courseId);}
}

业务类

课程审核状态通过后用户点击课程的发布链接即可发布课程，即将课程预发布表的课程信息写入课程发布表(两个表的结构基本一样)

  • 课程发布表状态字段描述课程发布和下架时间，课程预发布表状态字段描述课程的提交和审核状态**

在这里插入图片描述

通过本地事务将课程预发布表中包含的课程信息写入课程发布表中并向消息表插入一条课程发布的任务消息

  • 发布约束： 本机构只允许发布本机构的课程，预发布课程审核通过方可发布
/*** @description 课程发布接口* @param companyId 机构id* @param courseId 课程id
*/
public void publish(Long companyId,Long courseId);

@Transactional
@Override
public void publish(Long companyId, Long courseId) {// 获取课程预发布表数据CoursePublishPre coursePublishPre = coursePublishPreMapper.selectById(courseId);if(coursePublishPre == null){XueChengPlusException.cast("请先提交课程审核，审核通过才可以发布");}//  预发布课程审核通过方可发布if(!"202004".equals(coursePublishPre.getStatus()){XueChengPlusException.cast("操作失败，课程审核通过方可发布");}// 本机构只允许提交本机构的课程if(!coursePublishPre.getCompanyId().equals(companyId)){XueChengPlusException.cast("不允许提交其它机构的课程");}   // 向课程发布表插入数据，如果存在则更新saveCoursePublish(courseId);// 向消息表插入数据即课程发布的任务saveCoursePublishMessage(courseId);// 课程发布后，可以删除课程预发布表对应记录coursePublishPreMapper.deleteById(courseId);}/*** @description 保存课程发布信息* @param courseId  课程id
*/
private void saveCoursePublish(Long courseId){// 判断课程预发布信息是否存在CoursePublishPre coursePublishPre = coursePublishPreMapper.selectById(courseId);if(coursePublishPre == null){XueChengPlusException.cast("课程预发布数据为空");}// 将课程的预发布信息写入到课程发布表，如果存在则更新CoursePublish coursePublish = new CoursePublish();BeanUtils.copyProperties(coursePublishPre,coursePublish);// 设置课程发布表中课程的发布状态为已发布coursePublish.setStatus("203002");CoursePublish coursePublishUpdate = coursePublishMapper.selectById(courseId);// 有则更新，无则新增if(coursePublishUpdate == null){// 没有指定Id时默认基于雪花算法生成IdcoursePublishMapper.insert(coursePublish);}else{coursePublishMapper.updateById(coursePublish);}// 更新课程基本信息表的发布状态为已发布CourseBase courseBase = courseBaseMapper.selectById(courseId);courseBase.setStatus("203002");courseBaseMapper.updateById(courseBase);
}/*** @description 保存消息表记录，稍后实现* @param courseId  课程id*/
private void saveCoursePublishMessage(Long courseId){}

测试

约束条件测试：在未提交审核时发布课程，在课程审核未通过时进行发布

正常流程测试：提交审核课程，手动修改课程预发布表与课程基本信息的审核状态为审核通过，执行课程发布

  • 最终结果：课程发布表记录是否正常(消息表暂未实现)，课程预发布表记录已经删除，课程基本信息表与课程发布表的发布状态为已发布

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/762882.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Mysql数据库：索引管理

Mysql数据库：索引管理

目录 一、索引的概述 1、索引的概念 2、索引的作用 3、索引的副作用 4、创建索引的原则依据 5、索引优化 6、索引的分类 7、数据文件与索引文件 二、管理数据库索引 1、查询索引 2、创建索引 2.1 创建普通索引 2.2 创建唯一索引 2.3 创建主键索引 2.4 创建组合…
阅读更多...
58、服务攻防——应用协议设备KibanaZabbix远控向日葵VNCTeamViwer

58、服务攻防——应用协议设备KibanaZabbix远控向日葵VNCTeamViwer

文章目录 vnc默认端口：5900 or 5902，hydra支持vnc破解。VNC有三种模式：使用vnc密码、windows密码、无密码。 teamviewer、向日葵都是使用之前爆过漏洞进行测试。 zabbix：监控系统，蓝队部署平台。zabbix页面如下&#…
阅读更多...
（PAT乙级） 1084 外观数列 （C语言实现，不要使用strcat）

（PAT乙级） 1084 外观数列 （C语言实现，不要使用strcat）

外观数列是指具有以下特点的整数序列： d, d1, d111, d113, d11231, d112213111, ...它从不等于 1 的数字 d 开始，序列的第 n1 项是对第 n 项的描述。比如第 2 项表示第 1 项有 1 个 d，所以就是 d1；第 2 项是 1 个 d（对…
阅读更多...
建立一个高效协作的团队从《团队章程》开始

建立一个高效协作的团队从《团队章程》开始

《团队章程》 项目资源分为团队资源（人力）和实物资源。而项目资源管理的目的拿今天最流行的说法就是降本增效，那么建立一个高效协作的团队从《团队章程》开始，以某供应链团队的团队章程（简化）举例&#xf…
阅读更多...
puppeteer使用示例云顶之弈官网

puppeteer使用示例云顶之弈官网

自己从0到1开发的，微信小程序【云顶宝藏】求求点个5星好评吧！ 需求：拿到所有英雄的信息 思路：点击每个英雄，进入英雄详情页，拿信息，并返回，继续下一个英雄** 最终效果 本地环境 win…
阅读更多...
如何搭建DolphinScheduler服务并结合内网穿透公网远程任务调度

如何搭建DolphinScheduler服务并结合内网穿透公网远程任务调度

文章目录 前言1. 安装部署DolphinScheduler1.1 启动服务 2. 登录DolphinScheduler界面3. 安装内网穿透工具4. 配置Dolphin Scheduler公网地址5. 固定DolphinScheduler公网地址 前言 本篇教程和大家分享一下DolphinScheduler的安装部署及如何实现公网远程访问，结合内…
阅读更多...
C语言学习 四、选择与循环

C语言学习 四、选择与循环

4.1关系表达式与逻辑表达式 算术运算符的优先级高于关系运算符关系运算符的优先级高于逻辑与 和 逻辑或运算符相同优先级的运算符从左到右进行结合 【例】 表达式 5 > 3 && 8 < 4 - !0 的最终值为多少 4.2 if-else语句 4.2.1 if-else单分支语句 if判断条件&am…
阅读更多...
力扣日记3.21【贪心算法篇】45. 跳跃游戏 II

力扣日记3.21【贪心算法篇】45. 跳跃游戏 II

力扣日记&#xff1a;【贪心算法篇】45. 跳跃游戏 II 日期&#xff1a;2024.3.21 参考&#xff1a;代码随想录、力扣 45. 跳跃游戏 II 题目描述 难度&#xff1a;中等 给定一个长度为 n 的 0 索引整数数组 nums。初始位置为 nums[0]。 每个元素 nums[i] 表示从索引 i 向前跳转…
阅读更多...
C语言例：设 int x； 则表达式 (x=4*5,x*5),x+25 的值

C语言例：设 int x； 则表达式 (x=4*5,x*5),x+25 的值

代码如下&#xff1a; #include<stdio.h> int main(void) {int x,m;m ((x4*5,x*5),x25);printf("(x4*5,x*5),x25 %d\n",m);//x4*520//x*5100//x2545return 0; } 结果如下&#xff1a;
阅读更多...
网络仿真3-NS2协议修改和移植

网络仿真3-NS2协议修改和移植

Ns2实现原理 OTcl与C关联 执行路径&#xff1a;Tcl->Otcl->C 返回路径&#xff1a;C->Otcl->Tcl NS2协议修改和移植 NS2中的各种网络协议在底层通过C实现&#xff0c;在网络仿真过程中最终通过调用底层C代码实现网络行为、算法、功能等各种仿真 NS2协议修改&…
阅读更多...
牛客NC403 编辑距离为一【中等 模拟法 Java,Go,PHP】

牛客NC403 编辑距离为一【中等 模拟法 Java,Go,PHP】

题目 题目链接&#xff1a; https://www.nowcoder.com/practice/0b4b22ae020247ba8ac086674f1bd2bc 思路 注意&#xff1a;必须要新增一个&#xff0c;或者删除一个&#xff0c;或者替换一个&#xff0c;所以不能相等1.如果s和t相等&#xff0c;返回false,如果s和t长度差大于1…
阅读更多...
【数据库系统】SQL和T-SQL

【数据库系统】SQL和T-SQL

第四章 SQL 基本内容 系统结构、DDL、DML、视图、数据控制、嵌入式SQL SQL介绍 特点 一体化&#xff1b;面向集合操作&#xff1b;非过程化语言&#xff1b;可以单独写&#xff0c;也可以作为嵌入式语言&#xff08;JDBC&#xff09; 体系结构 数据库存储结构 逻辑存储结构 面…
阅读更多...
在vscode中使用git-新手向

在vscode中使用git-新手向

Git 应该是必学的版本同步工具&#xff0c;是代码管理的好帮手。 可是对新手来说上手还是有一丢丢门槛&#xff0c;结合 vscode 同步非常方便。 可实现可视化代码变化&#xff0c;提醒自己记录版本修改内容。非常好用。 在 VSCode 中将项目上传至 GitHub 私有仓库基本步骤 确保…
阅读更多...
基于ssm电子竞技管理平台的设计与实现论文

基于ssm电子竞技管理平台的设计与实现论文

摘 要 现代经济快节奏发展以及不断完善升级的信息化技术&#xff0c;让传统数据信息的管理升级为软件存储&#xff0c;归纳&#xff0c;集中处理数据信息的管理方式。本电子竞技管理平台就是在这样的大环境下诞生&#xff0c;其可以帮助管理者在短时间内处理完毕庞大的数据信息…
阅读更多...
Prometheus（四）：VMware Vsphere监控及数据展示

Prometheus（四）：VMware Vsphere监控及数据展示

目录 1 vmware exporter安装配置1.1 vmware exporter介绍1.2 安装 - 使用kubernetes部署1、下载2、修改配置文件3、执行安装4、查看 1.3 安装-使用docker的方式1.4 Prometheus配置1.5 Grafana配置&#xff08;模板页面还需要修改&#xff09; 总结 1 vmware exporter安装配置 …
阅读更多...
cloudflare 应用例子几则

cloudflare 应用例子几则

Cloudflare&#xff08;以下简称 CF&#xff09; 堪称互联网活菩萨&#xff0c;造就一大批高质量的互联网基础技术服务&#xff0c;更难得的是&#xff0c;几乎所有的服务都有对应的免费的套餐&#xff0c;而且出手大方&#xff0c;基本上有足够的容量或请求次数。 CDN CF 最…
阅读更多...
MySQL的基本操作

MySQL的基本操作

目录 引言 一、SQL语句简介 &#xff08;一&#xff09;SQL通用语法 &#xff08;二&#xff09;SQL分类 &#xff08;三&#xff09;数据类型 1.数值类型 2.字符串类型 3.日期/时间类型 4.修饰符 二、登录mysql服务 三、SQL语句操作 &#xff08;一&#xff09;DD…
阅读更多...
深度学习500问——Chapter04：经典网络解读（1）

深度学习500问——Chapter04：经典网络解读（1）

文章目录 4.1 LeNet-5 4.1.1 模型介绍 4.1.2 模型结构 4.1.3 模型特性 4.2 AlexNet 4.2.1 模型介绍 4.2.2 模型结构 4.2.3 模型特性 4.3 ZFNet 4.3.1 模型介绍 4.3.2 模型结构 4.3.3 模型特性 4.4 Network in Network 4.4.1 模型介绍 4.4.2 模型结构 4.4.3 模型特性 4.1 LeNet-…
阅读更多...
java面试：常见的限流算法有哪些

java面试：常见的限流算法有哪些

1 什么是限流算法 限流算法是一种用于限制流量请求的频率或速率的算法&#xff0c;其目的是在高并发或大流量请求的情况下&#xff0c;保护系统服务的安全性和可用性。限流算法可以应对热点业务带来的突发请求、调用方bug导致的突发请求以及恶意攻击请求等情况。是一种系统保护…
阅读更多...
金融知识分享系列之：出场信号RSI指标

金融知识分享系列之：出场信号RSI指标

金融知识分享系列之&#xff1a;出场信号RSI指标 一、出场信号RSI指标二、RSI指标原理三、 指标用法四、RSI指标总结 一、出场信号RSI指标 名称&#xff1a;相对强弱指标参数&#xff1a;(默认14)组成&#xff1a;RSI线以及30轴、50轴、70轴构成 0-30是极弱&#xff1a;0-30的…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023