IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> 分布式事务、分布式锁 -> 正文阅读

[大数据]分布式事务、分布式锁

分布式锁:

????????在分布式环境中,服务都被分布在各个节点中,并且某个节点上的同一个服务还可能存在多个实例,那要保证在分布式系统中同一个资源只能被顺序访问的问题,此时sy锁就起不到作用了,因为此时的服务都是夸jvm的,

解决方案:参照图1

????????使用redis方式

? ? ? ?????????1、在线程要使用公共资源时,在redis中使用set(key,v,过期时间)(注1)

? ? ? ? ? ? ? ? 2、获取到锁后执行业务逻辑,执行完业务逻辑后释放锁(将redis中的数据删除掉)

? ? ? ? ?注:设置过期时间是为了再执行业务逻辑时出错没有执行到删除redis中的key而导致的死锁,

? ? ? ? 存在问题:

? ? ? ? ? ? ? ? 1、如果设置的锁时间已经过期了,但业务还没有执行完,还是会出现并发的问题

? ? ? ? ? ? ? ? 解决方案:参照图2

????????????????????????redisson框架,使用看门狗模式,如果发现锁还没有释放,则自动续期;(当然此方法也会存在问题:哨兵模式/主从模式切换master节点时会出现同时持有锁的问题,解决方案可以使用zookeeper)

? ? ? ? ? ? ? ? ? ? ? ? 即:当第一个线程获取到某个key的锁时,直接对该key执行加锁命令。在执行完业务后再进行解锁操作,当第一个线程还没有执行完时,第二个线程又执行到了该锁,则会进入一个等待状态,直到等到锁并执行(redisson自己已经实现了该功能,类似于一个等待队列)

图1

图2

1添加依赖

?2、配置redissonClient的bean

?3、使用案例

? ? ? ? zookeeper模式

? ? ? ? ? ? ? ? todo

分布式事务

? ? ? ? 多个服务之间的调用使用同一个事务

? ? ? ? 单个服务可以通过@Tran..注解可以保证,但不同服务之间保证同一个事务呢?

? ? ? ? 一致性:强一致性、弱一致性、最终一致性;

? ? ? ? 解决方案:

? ? ? ? ? ? ? ? 1、MQ最终一致性(比较复杂)

? ? ? ? ? ? ? ? 2、seata方案-两阶段提交(百度)

? ? ? ? ? ? ? ? ? ? ? ? 服务A调用服务B,A、B服务执行完之后直接提交事务,A执行完之后如果有异常则根据log日志进行回滚;(异步处理,不占用数据库链接,可以提供性能)

? ? ? ? ? ? ? ? ? ? ? ? 问题:如果都提交了事务,在此期间其他事务也做了提交,如果再回滚的话会对之后提交的数据也进行了回滚,该如何处理?

????????????????

注释:

1、setNx:相同的key只能被赋值一次,如果已经存在再次被赋值则失败,返回0;

2、幂等性:同一个接口相同的入参,调用一次和调用多次返回的结果一样(包括数据库数据一致)

问题:

1、redis设置了过期时间后,服务挂掉后重启,此时的数据是否还存在,是否还会根据过期时间自动过期?

2、‘set k v’ 能重新被赋值吗?‘set k v 过期时间’? 可以被重新赋值吗?

3、MQ的重复消费问题-幂等性问题

? ? ? ? :引发原因:消息发送回调(ACK)时出现了延迟;

? ? ? ? ? ? 1、根据业务唯一编码判断

? ? ? ? ? ? 2、记录日志,判断是否处理过(redis记录日志)

? ? ? ? ? ? 3、数据库的乐观锁

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-04-15 00:05:37  更:2022-04-15 00:08:42 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 3:07:11-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码