事务管理 vs. 锁控制:你真的分得清吗?何时使用何种并发控制策略?

news2025/1/9 1:57:43

分布式锁和事务是分布式系统中两个重要的概念,它们都用于解决分布式环境下的数据一致性问题。

一、概念

分布式锁

分布式锁是一种用于在分布式环境中控制对共享资源访问的锁。分布式锁可以防止多个进程或线程同时访问共享资源,从而避免数据冲突和资源竞争。

事务

事务是指一组操作要么全部执行,要么全部不执行,以保证数据的一致性。事务通常用于处理多个数据源之间的操作,例如对于跨多个数据库的事务操作,需要保证在执行过程中的原子性、一致性和持久性。

区别

区别

分布式锁

事务

作用

控制对共享资源的访问

保证数据的一致性

范围

单个资源

多个资源

粒度

细粒度

粗粒度

实现

基于数据库、基于消息队列、基于共享内存等

基于 ACID 原理

优缺点

优点:简单易用、性能高;缺点:无法保证数据一致性

优点:保证数据一致性;缺点:实现复杂、性能低

使用场景

抢购、秒杀、数据同步等

银行转账、订单支付等

本质区别

分布式锁是针对资源访问的

事务是针对数据一致性的

二、使用场景

分布式锁

分布式锁通常用于以下场景:

  • 抢购、秒杀:在抢购、秒杀等场景中,需要防止多个用户同时下单,从而保证公平性。
  • 数据同步:在数据同步场景中,需要防止多个服务器同时更新数据,从而保证数据的一致性。
  • 资源访问控制:在资源访问控制场景中,需要防止多个用户同时访问共享资源,从而保证资源的安全性。

事务

事务通常用于以下场景:

  • 银行转账:在银行转账场景中,需要保证转账金额的正确性,从而避免资金损失。
  • 订单支付:在订单支付场景中,需要保证订单的状态正确,从而避免订单丢失。
  • 数据库操作:在数据库操作场景中,需要保证数据的完整性和一致性。

三、本质区别

分布式锁可以防止多个进程或线程同时访问共享资源,从而避免数据冲突和资源竞争。事务可以保证数据在操作过程中的一致性,即使在发生异常的情况下,也不会导致数据不一致。

在实际应用中,可以根据具体的需求选择合适的方案。如果需要保证数据的一致性,可以使用事务。如果只需要防止资源竞争,可以使用分布式锁。

四、锁与事务实现

1、锁方案

分布式锁的实现方法有很多,常见的有以下几种:

  • 数据库锁:使用数据库中的行锁或表锁来实现分布式锁。
  • 文件锁:使用文件来实现分布式锁。
  • Zookeeper锁:使用Zookeeper来实现分布式锁。
  • Redis锁:使用Redis来实现分布式锁。
  • 消息队列锁:使用消息队列来实现分布式锁。

Redisson 是一个基于 Redis 的 Java 分布式框架。Redisson 提供了丰富的功能,包括分布式锁、分布式集合、分布式队列等。

以下是使用 Redisson 实现分布式锁的示例:

    @Autowired
    private RedissonClient redissonClient;

    public String lock() {
        // 获取锁
        RLock lock = redissonClient.getLock("lock");
        boolean acquired = lock.tryLock(10,-1,TimeUnit.SECONDS);
        if (acquired) {
            // 获取锁成功,执行业务逻辑
            return "获取锁成功,执行业务逻辑...";
        } else {
            // 获取锁失败,重试
            return "获取锁失败,重试...";
        }
    }

    public String unlock() {
        // 释放锁
        RLock lock = redissonClient.getLock("lock");
        lock.unlock();
        return "释放锁成功...";
    }

另外,redisson支持锁续期。即在锁键值过期后任务还没执行完成,此时需要把锁键值的时间自动延长。

Redisson提供了的续期机制,只要客户端加锁成功,就会启动一个Watch Dog。可以看到源代码的实现leaseTime不设置为-1时开启监听。如果任务没完成就调用scheduleExpirationRenewal续期方法。

tryLock() 方法用于尝试获取分布式锁,该方法有三个参数:

  • key:锁的键值
  • waitTime:等待获取锁的时间,单位为毫秒
  • leaseTime:锁的过期时间,单位为毫秒

waitTime 参数表示客户端最多等待多长时间来获取锁。如果在 waitTime 时间内没有获取到锁,则会返回 false。

leaseTime 参数表示锁的过期时间。如果锁在 leaseTime 时间内没有被释放,则会自动释放。如果 leaseTime 设置为 -1,则表示锁的过期时间由 renew() 方法来控制。这样,在业务逻辑执行过程中,可以定期调用 lock.renew() 方法来续期锁的过期时间。

tryLock() 方法的返回值是一个 Boolean 值,表示是否成功获取到锁。如果成功获取到锁,则返回 true。否则,返回 false。

2、事务方案

以下是一些常见的分布式事务解决方案:

  1. 两阶段提交(2PC)

2PC是一种经典的分布式事务解决方案,它将分布式事务分为两个阶段:准备阶段和提交阶段。在准备阶段,协调者向所有参与者发送预提交请求;如果所有参与者都同意预提交,则进入提交阶段;否则,所有参与者都将回滚事务。2PC的优点是可以保证原子性、一致性和隔离性,但是实现复杂度较高。

  1. 三阶段提交(3PC)

3PC是在2PC的基础上发展而来的一种改进方案,它引入了超时机制和预提交响应等新特性。在3PC中,协调者会向所有参与者发送预提交请求,并等待参与者的响应。如果所有参与者都同意预提交,则进入预提交阶段;否则,进入回滚阶段。在正式提交阶段,如果所有参与者都同意提交事务,则进入正式提交阶段;否则,所有参与者都将回滚事务。3PC的优点是可以更好地处理节点故障等问题,但是实现复杂度仍然较高。

  1. TCC(Try-Confirm-Cancel)

TCC是一种基于补偿机制的分布式事务解决方案。它将分布式事务分为三个阶段:尝试阶段、确认阶段和取消阶段。在尝试阶段,参与者尝试预留所需的资源,并执行一些检查和准备工作,以确保执行事务操作的前提条件满足;在确认阶段,如果所有参与者都满足,则所有参与者执行之前在Try阶段所预留的操作,并提交实际的数据持久化。在取消阶段,如果有任何一个参与者执行失败,则执行回滚操作,将系统状态恢复到事务开始之前的状态。TCC的优点是可以避免阻塞情况的发生,但是实现复杂度较高。

  1. Saga模式

Saga模式是一种基于事件驱动的分布式事务解决方案。它将分布式事务看作一系列的事件序列,每个事件都有一个唯一的ID和一个时间戳。在每个事件发生时,参与者会根据事件的内容执行相应的本地事务。如果某个参与者执行失败,则会记录该事件的状态为“已失败”,并等待其他参与者的响应。当所有的事件都被处理完毕后,再执行最终的本地事务。Saga模式的优点是可以支持复杂的业务逻辑和异常情况处理,但是实现复杂度较高。

  1. 消息队列

消息队列可以用于异步地处理多个任务,并且可以保证任务的顺序执行。在分布式系统中使用消息队列来处理事务时,可以将事务拆分成多个小任务,并将这些任务发布到消息队列中进行异步处理。当所有任务都完成后,再执行最终的本地事务。这种方式可以避免阻塞情况的发生,并且可以提高系统的可扩展性和容错能力。能保证事务的最终一致性。

  1. 最大努力通知(Best Effort Delivery)

这种解决方案通过异步通信和消息重试来实现事务的最终一致性。事务操作被封装为消息发送到目标系统,如果消息传递失败,系统会进行重试。

  1. 分布式事务中间件

Seata是一款阿里巴巴开源的分布式事务中间件,它提供了AT、TCC、SAGA和XA事务模式,为用户打造一站式的分布式解决方案。Seata的设计思路是将一个分布式事务理解成全局事务,下面挂了若干个分支事务,而一个分支事务就是一个满足ACID的本地事务,因此我们可以操作分布式事务像操作本地事务一样简单。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Mini小主机All-in-one搭建教程4-安装Windows11系统

Mini小主机All-in-one搭建教程4-安装Windows11系统 硬件介绍 在狗东买的 极摩客M2 到手价是2799元 具体配置如下: 酷睿英特尔11代标压i7 11390H 64G1TB固态。 以下是 安装Windows11系统的教程。 安装Windows11系统 下载镜像包 首先下Windows系统的懒人镜像包&…

【特纳斯电子】基于物联网的智能油烟机-仿真设计

视频及资料链接:基于物联网的智能油烟机-仿真设计 - 电子校园网 (mcude.com) 编号: T0332203M-FZ 设计简介: 本设计是基于物联网的智能油烟机系统,主要实现以下功能: 1.通过OLED显示燃气浓度; 2.可通过…

多媒体应用设计师 第4章 移动多媒体技术基础

1.移动多媒体技术基础 1.1.移动互联网的定义 移动互联网是指利用互联网提供的技术、平台、应用以及商业模式,与移动通信技术相结合并用于实践活动的总称。 1.2.移动互联网的特征 移动互联网三个层面:终端、软件、应用 移动互联网特征:2版…

在搜狗浏览器中设置代理

要在搜狗浏览器中设置代理,请按照以下步骤操作: 打开搜狗浏览器。在浏览器顶部菜单栏中点击“设置”(一般位于右上角)。在设置菜单中点击“代理设置”。在代理设置页面中,将“使用代理”选项设置为“自动检测”或“al…

通讯网关软件026——利用CommGate X2ORACLE-U实现OPC UA数据转入ORACLE

本文介绍利用CommGate X2ORACLE-U实将OPC UA数据源中的数据转入到ORACLE数据库。CommGate X2ORACLE-U是宁波科安网信开发的网关软件,软件可以登录到网信智汇(http://wangxinzhihui.com)下载。 【案例】如下图所示,将OPC UA数据源的数据写入到ORACLE数据…

ssh 报错:Permission denied, please try again.

报错问题:执行一条远程scp远程拷贝,在此之前已配置好ssh无密登录, sudo scp -r hadoop-3.2.0 slave2:/usr/local/src/ 确保 /etc/ssh/sshd_config文件下 PasswordAuthentication no 改为 PasswordAuthentication yes 和 PermitRootLogin no …

云爬虫系统设计:云平台资源管理优化爬虫性能

目录 1、云爬虫系统概述 2、云平台资源管理优化爬虫性能的关键措施 2.1 资源池化 2.2 负载均衡 2.3 任务调度 2.4 异常处理和恢复 2.5 数据存储与处理 2.6 数据清洗和去重 2.7 分布式爬虫 2.8 任务优先级与质量 2.9节能与环保 2.10监控与日志 总结 随着互联网的快…

成都瀚网科技:如何有效运营抖店来客呢?

随着电子商务的快速发展和移动互联网的普及,越来越多的企业开始将目光转向线上销售渠道。其中,抖音成为备受关注的平台。作为中国最大的短视频社交平台之一,抖音每天吸引数亿用户,这也为企业提供了巨大的商机。那么,如…

解决github打开慢的问题

1,修改hosts(可以从这个链接 https://raw.hellogithub.com/hosts 获取对应的host配置)。 140.82.112.3 github.com 151.101.1.194 github.global.ssl.fastly.net 2,刷新dns缓存。 # 打开CMD运行如下命令 ipconfig /flushdns 之…

MATLAB-自动批量读取文件,并按文件名称或时间顺序进行数据处理

我在处理文件数据时,发现一个一个文件处理效率太低,因此学习了下MATLAB中自动读取特定路径下文件信息的程序,并根据读取信息使用循环进行数据处理,提高效率,在此分享给大家这段代码并给予一些说明,希望能为…

小程序新增功能页面

需求背景: 小程序主页面有个报名板块,我打算替换主页面报名板块菜单,迁移到我的页面里面, 替换成资讯栏目,我喜欢分享最新技术,开源课题,IT资讯,本想做成论坛的效果,由于时间问题,先替换添加板块 替换后效果: 模块功能: 添加、修改、删除、查看 文件目录:// 添…

git本地仓库及远端仓库推送【linux】

git本地仓库及远端仓库推送【linux】 一.git上创建仓库二.linux中git三板斧i.检查是否安装gitii.克隆仓库到本地iii.提交到本地仓库iiii.上传到远端仓库 三.其他内容补充git loggit status.gitignore 一.git上创建仓库 已经创建好的可以直接跳到第二步进入到创建仓库界面&…

Qt应用开发(基础篇)——头部视图 QHeaderView

一、前言 QHeaderView类继承于QAbstractItemView,为项目视图(QTableView、QTreeView等)提供标题行或标题列。 树结构视图 QTreeView 表格视图 QTableView 视图基类 QAbstractItemView QHeaderView有section的概念,表示整条标题栏的一个个小部分&#xff…

为小公司申请企业邮箱的步骤和方法

对于小公司来说,拥有自己的企业邮箱不仅可以提高公司的专业形象,还可以更好地管理内部和外部的通信。小公司应该如何申请企业邮箱呢?以下是一份详尽的指南。 小公司应该如何申请企业邮箱呢?基本上由三步组成:确定自己的…

class的get和set

class的get和set 一、使用场景二、代码实现 一、使用场景 当我们需要在用户获取或设置实例某个属性的时候做一些附加的操作的时候,就能利用这个特性。 二、代码实现 class Person {#name #age 0 // 设置私有属性存储值,避免被外部修改constructor(na…

智能微秘书+FastGPT,打造你的超级微信助手!

自 ChatGPT 面世以来,它开创了一种交互方式的新革命,引领着技术与人类交互方式的全新演变。特别是在 GPT-3.5 全面开放 API 接口后,基于语言模型(LLM)的各种应用如雨后春笋般涌现,显示了无限的可能性和创新…

RabbitMQ的LazyQueue

在默认情况下,RabbitMQ会将接收到的信息保存在内存中以降低消息收发的延迟。但在某些特殊情况下,这会导致消息积压,比如: 消费者宕机或出现网络故障消息发送量激增,超过了消费者处理速度消费者处理业务发生阻塞 一旦…

C51--基本认知

单片机基本认知: 1、什么是单片机 单片机是一种集成电路芯片。 把具有数据处理能力的中央处理器 CPU、随机存储器RAM、只读存储器ROM。 多种 I / O 口和中断系统、定时器/计数器等功能(可能还包括显示驱动电路、脉宽调制电路、模拟多路转换器、A/D转换器…

JAVAEE初阶相关内容第十四弹--网络初识

写在前: 这一部分开启网络部分的相关知识,这一弹内容初始网络将主要进行网络相关知识的简单介绍,以及着重介绍协议、协议分层、OSI七层模型、TCP/IP五层模型、封装和分用。 需要认识协议,并知道协议的效果是什么;知道…

利用N点复数序列求2个N点实数序列的快速傅里叶变换

一、方法简介 通过一个点复数序列求出两个点实数序列的离散傅里叶变换,进一步提升快速傅里叶变换的效率。 二、方法详解 和是实数序列,且长度都为,定义复数序列: , 则序列和可表示为: 的离散傅…