悲观锁乐观锁在django中使用

1 悲观锁乐观锁
1.1 并发控制
1.1 悲观锁
1.2 乐观锁
1.3 悲观锁乐观锁使用场景

2 django中开启事务
2.1 全局开启事务
2.2 视图开启事务
2.3 局部使用事务
2.4 savepoint回滚
2.5 事务提交后回调函数

3 django中使用悲观锁
3.1 前置条件，表模型
3.1 模拟秒杀生成订单场景

4 django使用乐观锁
4.1 普通版
4.2 升级版

1 悲观锁乐观锁

无论是悲观锁还是乐观锁，都是人们定义出来的概念，仅仅是一种思想，与语言无关

1.1 并发控制

1 并发控制:当程序中出现并发问题时，就需要保证在并发情况下数据的准确性，以此确保当前用户和其他用户一起操作时，所得到的结果和他单独操作时的结果是一样的,这种手段就叫做并发控制
2 没有做好并发控制，就可能导致脏读、幻读和不可重复读等问题

1.1 悲观锁

# 悲观锁是什么？
1 悲观锁：当要对数据库中的一条数据进行修改的时候，为了避免同时被其他人修改，最好的办法就是直接对该数据进行加锁以防止并发。
2 这种借助数据库锁机制，在修改数据之前先锁定，再修改的方式被称之为悲观并发控制【Pessimistic Concurrency Control，缩写"PCC"，又名"悲观锁"】
3 之所以叫做悲观锁，是因为这是一种对数据的修改持有悲观态度的并发控制方式。总是假设最坏的情况，每次读取数据的时候都默认其他线程会更改数据，因此需要进行加锁操作，当其他线程想要访问数据时，都需要阻塞挂起。# 悲观锁的实现方式：
1 传统的关系型数据库(如mysql)使用这种锁机制，比如行锁，表锁等，读锁，写锁等，都是在做操作之前先上锁
2 编程语言中的线程锁，比如python的互斥锁
3 分布式锁：redis实现的分布式锁等
​

1.2 乐观锁

# 乐观锁是什么？
1 通过程序实现，不会产生死锁
2 总是假设最好的情况，每次去拿数据的时候都认为别人不会修改，所以不会上锁，只在更新的时候会判断一下在此期间别人有没有去更新这个数据
​
# 乐观锁实现方式
1 CAS(Compare And Swap) 即比较并交换。是解决多线程并行情况下使用锁造成性能损耗的一种机制，CAS 操作包含三个操作数——内存位置(V)、预期原值(A)和新值(B),执行CAS操作的时候，将内存位置的值与预期原值比较，如果相匹配，那么处理器会自动将该位置值更新为新值，否则，处理器不做任何操作CAS会出现ABA问题，比如，你看到桌子上有100块钱，然后你去干其他事了，回来之后看到桌子上依然是100块钱，你就认为这100块没人动过，其实在你走的那段时间，别人已经拿走了100块，后来又还回来了。这就是ABA问题解决ABA问题：既然有人动了，那我们对数据加一个版本控制字段，只要有人动过这个数据，就把版本进行增加，我们看到桌子上有100块钱版本是1，回来后发现桌子上100没变，但是版本却是2，就立马明白100块有人动过
​
2 版本号控制：在数据表中增加一个版本号字段，每次更新数据时将版本号加1，同时将当前版本号作为更新条件，如果当前版本号与更新时的版本号一致，则更新成功，否则更新失败
3 时间戳方式:在数据表中增加一个时间戳字段，每次更新数据时将时间戳更新为当前时间戳，同时将当前时间戳作为更新条件，如果当前时间戳与更新时的时间戳一致，则更新成功，否则更新失败

1.3 悲观锁乐观锁使用场景

并发量：如果并发量不大，可以使用悲观锁解决并发问题；但如果系统的并发非常大的话,悲观锁定会带来非常大的性能问题, 建议乐观锁响应速度：如果需要非常高的响应速度，建议采用乐观锁方案，成功就执行，不成功就失败，不需要等待其他并发去释放锁。乐观锁并未真正加锁，效率高冲突频率：如果冲突频率非常高，建议采用悲观锁，保证成功率。冲突频率大，选择乐观锁会需要多次重试才能成功，代价比较大重试代价：如果重试代价大，建议采用悲观锁。悲观锁依赖数据库锁，效率低。更新失败的概率比较低读多写少: 乐观锁适用于读多写少的应用场景，这样可以提高并发粒度

2 django中开启事务

Django是支持事务操作的，它的默认事务行为是自动提交，具体表现形式为：每次数据库操作(比如调用save()方法)会立即被提交到数据库中。但是如果你希望把连续的SQL操作包裹在一个事务里，就需要手动开启事务。

2.1 全局开启事务

DATABASES = {'default': {'ENGINE': 'django.db.backends.mysql','NAME': 'lqz','HOST': '127.0.0.1','PORT': '3306','USER': 'lqz','PASSWORD': 'lqz123',#全局开启事务，绑定的是http请求响应整个过程'ATOMIC_REQUESTS': True, }
}
​1 每当有请求过来时，Django会在调用视图方法前开启一个事务。如果完成了请求处理并正确返回了结果，Django就会提交该事务。否则，Django会回滚该事务。
​
2 虽然全局开启事务很简单，但Django并不推荐开启全局事务。因为一旦将事务跟 HTTP 请求绑定到一起时，每一个请求都会开启事务，当访问量增长到一定的时候会造成很大的性能损耗。在实际开发过程中，很多GET请求根本不涉及到事务操作，一个更好的方式是局部开启事务按需使用
​

局部禁用全局事务

from django.db import transaction
# 局部禁用事务
@transaction.non_atomic_requests
def seckill(request):return HttpResponse('秒杀成功')# 多数据库，用default的视图不受事务控制
@transaction.non_atomic_requests(using='default')
def seckill(request):return HttpResponse('秒杀成功')

2.2 视图开启事务

Django局部开启事务，借助于transaction.atomic使用它我们就可以创建一个具备原子性的代码块，一旦代码块正常运行完毕，
所有的修改会被提交到数据库。反之，如果有异常，更改会被回滚

# fbv开启
from django.db import transaction
@transaction.atomic
def seckill(request):return HttpResponse('秒杀成功')
# cbv开启
from django.db import transaction
from rest_framework.views import APIView
class SeckillAPIView(APIView):@transaction.atomicdef post(self, request):pass

2.3 局部使用事务

from django.db import transaction
def seckill(request):with transaction.atomic():passreturn HttpResponse('秒杀成功')

2.4 savepoint回滚

'''
在事务操作中，我们还会经常显式地设置保存点(savepoint)
一旦发生异常或错误，我们使用savepoint_rollback方法让程序回滚到指定的保存点
如果没有问题，就使用savepoint_commit方法提交事务
'''from .models import Book
from django.db import transaction
def seckill(request):with transaction.atomic():# 设置回滚点，一定要开启事务sid = transaction.savepoint()print(sid)try:book = Book.objects.get(pk=1)book.name = '红楼梦'book.save()except Exception as e:# 如发生异常，回滚到指定地方transaction.savepoint_rollback(sid)print('出异常了，回滚')# 如果没有异常，显式地提交一次事务transaction.savepoint_commit(sid)return HttpResponse('秒杀成功')

2.5 事务提交后回调函数

# 有的时候我们希望当前事务提交后立即执行额外的任务，比如客户下订单后立即邮件通知卖家###### 案例一##################
def send_email():print('发送邮件给卖家了')
def seckill(request):with transaction.atomic():# 设置回滚点，一定要开启事务sid = transaction.savepoint()print(sid)try:book = Book.objects.get(pk=1)book.count = book.count-1book.save()except Exception as e:# 如发生异常，回滚到指定地方transaction.savepoint_rollback(sid)else:transaction.savepoint_commit(sid)transaction.on_commit(send_email)return HttpResponse('秒杀成功')##### 案例二：celery中使用###
transaction.on_commit(lambda: send_sms.delay('电话号码'))

3 django中使用悲观锁

3.1 前置条件，表模型

from django.db import models
class Book(models.Model):name = models.CharField(max_length=32)count = models.IntegerField()class Order(models.Model):order_id=models.CharField(max_length=64)order_name=models.CharField(max_length=32)

# Django中使用悲观锁锁定一个对象，需要使用select_for_update()方法。它本质是一个行级锁，能锁定所有匹配的行,如果查询所有，可以锁住整张表，直到事务结束@transaction.atomic
def seckill(request):# 锁住查询到的book对象，直到事务结束book = Book.objects.select_for_update().filter(pk=1).first()book.count= book.count-1book.save()time.sleep(4)return HttpResponse('秒杀成功')

3.1 模拟秒杀生成订单场景

@transaction.atomic
def seckill(request):# 锁住查询到的book对象，直到事务结束sid = transaction.savepoint()book = Book.objects.select_for_update().filter(pk=1).first()  # 加悲观锁if book.count > 0:print('库存可以，下单')Order.objects.create(order_id=str(datetime.datetime.now()), order_name='测试订单')# 库存-1，扣减的时候，判断库存是不是上面查出来的库存，如果不是，就回滚time.sleep(random.randint(1, 4))  # 模拟延迟book.count=book.count-1book.save()transaction.savepoint_commit(sid)return HttpResponse('秒杀成功')else:transaction.savepoint_rollback(sid)return HttpResponse('库存不足，秒杀失败')

客户端测试

import requests
from threading import Thread
def task():res = requests.get('http://127.0.0.1:8000/sckill/')print(res.text)if __name__ == '__main__':for i in range(10):t=Thread(target=task)t.start()

4 django使用乐观锁

4.1 普通版

@transaction.atomic
def seckill(request):# 锁住查询到的book对象，直到事务结束sid = transaction.savepoint()book = Book.objects.filter(pk=1).first()  # 没加锁count = book.countprint('现在的库存为：%s' % count)if book.count > 0:print('库存可以，下单')Order.objects.create(order_id=str(datetime.datetime.now()), order_name='测试订单')# 库存-1，扣减的时候，判断库存是不是上面查出来的库存，如果不是，就回滚time.sleep(random.randint(1, 4))  # 模拟延迟res = Book.objects.filter(pk=1, count=count).update(count=count - 1)if res >= 1:  # 表示修改成功transaction.savepoint_commit(sid)return HttpResponse('秒杀成功')else:  # 修改不成功，回滚transaction.savepoint_rollback(sid)return HttpResponse('被别人改了，回滚，秒杀失败')else:transaction.savepoint_rollback(sid)return HttpResponse('库存不足，秒杀失败')

客户端测试

import requests
from threading import Thread
def task():res = requests.get('http://127.0.0.1:8000/sckill/')print(res.text)if __name__ == '__main__':for i in range(10):t=Thread(target=task)t.start()

4.2 升级版

@transaction.atomic
def seckill(request):# 锁住查询到的book对象，直到事务结束### 乐观锁可能会失败，我们一直尝试秒杀，直到秒成功或库存不足while True:sid = transaction.savepoint()book = Book.objects.filter(pk=1).first()  # 没加锁count = book.countprint('现在的库存为：%s' % count)if book.count > 0:print('库存可以，下单')Order.objects.create(order_id=str(datetime.datetime.now()), order_name='测试订单')# 库存-1，扣减的时候，判断库存是不是上面查出来的库存，如果不是，就回滚# time.sleep(random.randint(1, 4))  # 模拟延迟res = Book.objects.filter(pk=1, count=count).update(count=count - 1)if res >= 1:  # 表示修改成功transaction.savepoint_commit(sid)return HttpResponse('秒杀成功')else:  # 修改不成功，回滚transaction.savepoint_rollback(sid)print('被别人扣减了，继续秒杀')continueelse:transaction.savepoint_rollback(sid)return HttpResponse('库存不足，秒杀失败')

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

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

相关文章

配电网重构单时段+多时段（附带matlab代码）

配电网重构单时段+多时段（附带matlab代码）

配电网重构单时段多时段 对于《主动配电网最优潮流研究及其应用实例》的基本复现 简介：最优潮流研究在配电网规划运行中不可或缺，且在大量分布式能源接入的主动配电网环境下尤为重要。传统的启发式算法在全局最优解和求解速度上均无法满足主动配电网运行…
阅读更多...
八股文-如何理解Java中的多态

八股文-如何理解Java中的多态

什么是多态？ 多态是面向对象编程的一个重要概念，它允许一个对象以不同的形式表现。也就是说，在父类中定义的属性和方法，在子类继承后，可以有不同的数据类型或表现出不同的行为。这可以使得同一个属性或方法&#xff0…
阅读更多...
读书笔记：彼得·德鲁克《认识管理》第34章 结构与战略

读书笔记：彼得·德鲁克《认识管理》第34章 结构与战略

一、章节内容概述 在现代管理的短暂历史上，我们曾经两次相信找到了正确答案。一 次是第一次世界大战时期亨利法约尔构建的“职能制组织”，另一次是 一代人时间后阿尔弗雷德斯隆构建的“联邦分权制组织”。在适当的领 域和条件下，这两种组织结…
阅读更多...
操作系统 day14（进程同步、进程互斥）

操作系统 day14（进程同步、进程互斥）

进程同步 概念 进程的异步性体现在，例如：当有I/O操作时，进程需要等待I/O操作，而每个I/O操作又是不同的，所以进程没有一个固定的顺序，固定的时间来执行，而这体现了进程的异步性。 进程互斥 …
阅读更多...
freeRTOS异常处理函数分析（以RISC-V架构进行分析）

freeRTOS异常处理函数分析（以RISC-V架构进行分析）

1、异常处理函数的注册 对RISC-V架构中断不熟悉，可参考博客：《RISC-V架构——中断处理和中断控制器介绍》； 2、异常处理函数分析 2.1、数调用关系 freertos_risc_v_trap_handler //异常处理函数入口portcontextSAVE_CONTEXT_INTERNAL //保存…
阅读更多...
Python-pip配置国内镜像源，快速下载包

Python-pip配置国内镜像源，快速下载包

文章目录 国内镜像源临时使用永久配置添加环境变量Path测试关于Python技术储备一、Python所有方向的学习路线二、Python基础学习视频三、精品Python学习书籍四、Python工具包项目源码合集①Python工具包②Python实战案例③Python小游戏源码五、面试资料六、Python兼职渠道 国内…
阅读更多...
零代码连接钉钉宜搭与用友U8，让业财数据管理简单高效

零代码连接钉钉宜搭与用友U8，让业财数据管理简单高效

零代码连接钉钉宜搭与用友U8，让业财数据管理简单高效 如果把企业内部的业务系统比作一条条河流，那么它们的交汇点就像江河湖海。在这些交汇点上，数据的汇集、分析和共享离不开系统之间的集成。 钉钉宜搭和用友U8是两个在企业中非常重要的系统…
阅读更多...
实现电商平台与营销系统无缝集成：雅座的无代码开发与API连接

实现电商平台与营销系统无缝集成：雅座的无代码开发与API连接

无代码开发：营销的新引擎 在数字化转型的浪潮中，无代码开发已成为企业提升效率、减少成本的新引擎。这种开发方式允许非技术人员通过图形界面构建应用程序，无需编写代码即可实现复杂功能。这对于营销、广告推广以及用户运营等业务尤为重要&a…
阅读更多...
wvp 视频监控平台抓包分析

wvp 视频监控平台抓包分析

抓包时机 下面的抓包时机是抓包文件最新，但是最有用的包 选择网卡开始抓包 如果之前已经选择网卡，直接开始抓包 停止抓包 重新抓包 sip播放过程分析 过滤条件 tcp.port 5060 and sip 可以看到有这些包 选择任何一个 ，戍边右键--追踪流--…
阅读更多...
JDK21下载+安装+环境配置教程(Windows系统)

JDK21下载+安装+环境配置教程(Windows系统)

前言：甲骨文公司与2023.9发布JDK21,JDK21将是一个长期支持（LTS）版本，JDK20目前可以从官网下载使用。 1，搜索Oracle官网找到JDK21 Java Downloads | Oracle 2，切换Windows系统，然后点击下载&am…
阅读更多...
记录vue2组件传值props的两种写法

记录vue2组件传值props的两种写法

在写传值时候发现了props的对象和数组类型写法&#xff0c;不知道有什么差距就查了一下 props: ["testMsg",] 这种方式是使用数组的形式来定义props&#xff0c;其中数组的元素是要传递的属性名称。在子组件中&#xff0c;可以通过this.$props来访问这些属性 <…
阅读更多...
Mysql 不执行索引问题与优化

Mysql 不执行索引问题与优化

难以查找的隐藏问题 及 解决办法&#xff1a; 问题总结&#xff1a;
阅读更多...
项目demo —— GPT 聊天机器人

项目demo —— GPT 聊天机器人

本文介绍我的开源项目 TelegramChatBot&#xff0c;这是一个基于 OpenAI GPT API 开发的 telegram 机器人&#xff0c;具有多模态交互能力&#xff0c;求 star&#xff01;感谢大家&#xff01;在 telegram jokerController_bot 立即体验&#xff01;欢迎对 GPT 应用开发或对 t…
阅读更多...
Day09

Day09

1.异常 1.1 介绍 在使用计算机语言进行项目开发的过程中&#xff0c;即使程序员把代码写得尽善尽美&#xff0c;在系统的运行过程中仍然会遇到一些问题&#xff0c;因为很多问题不是靠代码能够避免的&#xff0c;比如&#xff1a;客户输入数据的格式问题&#xff0c;读取文件…
阅读更多...
【分布式系统学习】CAP原理详解

【分布式系统学习】CAP原理详解

CAP原理详解 前言CAP一张图 一、概念1.1 关键词解读1.2 关于CAP&#xff08;拆分解读&#xff09;1.3 CAP原理精髓 二、CAP模拟场景举例理解三、CAP原理证明为什么不能同时满足&#xff08;下面举例说明&#xff09;3.1 必须满足分区容错性P下的处理方式3.2 不是必须满足分区容…
阅读更多...
​LeetCode解法汇总2336. 无限集中的最小数字

​LeetCode解法汇总2336. 无限集中的最小数字

目录链接&#xff1a; 力扣编程题-解法汇总_分享记录-CSDN博客 GitHub同步刷题项目&#xff1a; https://github.com/September26/java-algorithms 原题链接&#xff1a;力扣&#xff08;LeetCode&#xff09;官网 - 全球极客挚爱的技术成长平台 描述&#xff1a; 现有一个包…
阅读更多...
PlantUML语法（全）及使用教程-类图

PlantUML语法（全）及使用教程-类图

目录 1. 类图1.1、什么是类图1.2、元素声明1.3、类之间的关系1.4、关系上的标签1.5、在元素名称和关系标签中使用非字母1.6、添加方法 1. 类图 类图的设计语法与编程语言的传统语法相似。这种相似性为开发人员提供了一个熟悉的环境&#xff0c;从而使创建图表的过程更简单、更直…
阅读更多...
Golang中rune和Byte，字符和字符串有什么不一样

Golang中rune和Byte，字符和字符串有什么不一样

Rune和Byte&#xff0c;字符和字符串有什么不一样 String Go语言中&#xff0c; string 就是只读的采用 utf8 编码的字节切片(slice) 因此用 len 函数获取到的长度并不是字符个数&#xff0c;而是字节个数。 for循环遍历输出的也是各个字节。 Rune rune 是 int32 …
阅读更多...
[数据结构]-map和set

[数据结构]-map和set

前言 作者&#xff1a;小蜗牛向前冲 名言&#xff1a;我可以接受失败&#xff0c;但我不能接受放弃 如果觉的博主的文章还不错的话&#xff0c;还请点赞&#xff0c;收藏&#xff0c;关注&#x1f440;支持博主。如果发现有问题的地方欢迎❀大家在评论区指正 目录 一、键值对…
阅读更多...
centos系列：【 全网最详细的安装配置Nginx，亲测可用，解决各种报错】

centos系列：【 全网最详细的安装配置Nginx，亲测可用，解决各种报错】

全网最详细的安装配置Nginx&#xff0c;亲测可用&#xff0c;解决各种报错 全网最详细的安装配置Nginx1、 安装环境依赖2、 下载Nginx包3、编译Nginx4、安装Nginx5、启动Nginx6、配置Nginx7、了解Nginx服务的主配置文件 nginx.conf8、基于授权的访问控制9、基于IP和端口的访问控…
阅读更多...
最新文章

Copyright @ 2022~2023