ci mysql高并发_高并发访问mysql时的问题(一):库存超减

标签:

如果在对某行记录的更新时不采取任何防范措施,在多线程访问时,就容易出现库存为负数的错误.

以下用php、mysql,apache ab工具举例说明:

mysql表结构

CREATE TABLE`yxt_test_concurrence` (

`id`int(11) NOT NULLAUTO_INCREMENT,

`value`int(11) NOT NULL COMMENT ‘库存‘,PRIMARY KEY(`id`)

) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT=‘库存表‘;

CREATE TABLE`yxt_test_pv` (

`id`int(10) unsigned NOT NULLAUTO_INCREMENT,

`val`int(255) DEFAULT NULL COMMENT ‘该线程读取到的库存数量‘,PRIMARY KEY(`id`)

) ENGINE=MyISAM AUTO_INCREMENT=351 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT=‘访问记录表,每次访问都增加一条记录,并记录此次访问时的库存数‘;

在库存表中存入模拟库存500个.

在此,为方便,php采用TP框架:

public functiontc(){$this->tc = M("test_concurrence");//模拟商品的剩余数量

$this->pv = M("test_pv");//模拟访问次数

$res=$this->tc->field(‘value‘)->find(1);//查到的剩余数量

$value=$res[‘value‘];if($value>0){//如果大于0,则进行下面的逻辑

$this->pv->data(array(‘val‘=>$value))->add();//这个是用来记录访问的次数,并记录此次访问时的库存数

M()->execute("UPDATE `yxt_test_concurrence` SET `value`=`value` - 1 WHERE `id` = 1");//商品数量减1}

}

使用ab工具模拟并发访问:

C:\Users\chenhui>ab -c 50 -n 500 http://study.com/course/Course/tc/

This is ApacheBench, Version 2.3Copyright 1996 Adam Twiss, Zeus Technology Ltd, http://www.zeustech.net/

Licensed to The Apache Software Foundation, http://www.apache.org/

Benchmarking studyyxtcmf.com (be patient)

Completed 100 requests

Completed 200 requests

Completed 300 requests

Completed 400 requests

Completed 500 requests

Finished 500 requests

Server Software: Apache/2.4.9

Server Hostname: studyyxtcmf.com

Server Port: 80

Document Path: /course/Course/tc/

Document Length: 25786 bytes

Concurrency Level: 50

Time taken for tests: 60.035 seconds

Complete requests: 500

Failed requests: 450

(Connect: 0, Receive: 0, Length: 450, Exceptions: 0)

Total transferred: 12973630 bytes

HTML transferred: 12785130 bytes

Requests per second: 8.33 [#/sec] (mean)

Time per request: 6003.543 [ms] (mean)

Time per request: 120.071 [ms] (mean, across all concurrent requests)

Transfer rate: 211.03 [Kbytes/sec] received

Connection Times (ms)

min mean[+/-sd] median max

Connect: 0 1 2.1 1 34

Processing: 781 5915 1578.6 5996 12272

Waiting: 765 5901 1581.8 5983 12261

Total: 783 5916 1578.4 5997 12272

Percentage of the requests served within a certain time (ms)

50% 5997

66% 6385

75% 6707

80% 6850

90% 7387

95% 8402

98% 9734

99% 10300

100% 12272 (longest request)

查看数据库记录:

SELECT * fromyxt_test_pv;--截取一段记录(左边是第几次访问,右侧是当次访问看到的库存)

| 338 | 164 |

| 339 | 164 |

| 340 | 163 |

| 341 | 162 |

| 342 | 162 |

| 343 | 162 |

| 344 | 162 |

| 345 | 157 |

| 346 | 156 |

| 347 | 156 |

| 348 | 153 |

| 349 | 155 |

| 350 | 151 |

可以发现在341-343次读取的库存数量是一样的,在库存还很多的情况时,并不会出现问题:因为程序中减库存的逻辑,是当前库存量减去1.但是库存不多的时候,就很可能出现问题,比如库存只有一个了,而此时有多个线程查询到此时还有一个库存,因为1>0满足条件,所以库存减1,多个线程都对当前库存减1,最后就多减了库存,出现负数,这是不允许的.

所以一定要采取措施.

我认为,总的原则是:对于某一个时刻的库存,只允许一个会话去修改.要满足此条件.有两种选择:

1.对于某一个时刻的库存,只允许一个会话去读取(锁机制).待锁被释放后,其他会话才可以读取库存.

2.对于某一个时刻的库存,设定版本(即增加一个版本字段,用于比较.我对版本的理解是刻个记号),更新库存时要判断版本是否发生变化,若没发生变化,则更新库存的同时,更新版本号.若更新库存时发现版本发生变化了,那一定是有别的线程早已对库存修改,此情况下就放弃修改.

选择1.使用mysql的锁机制.(悲观锁)

public functiontc(){$this->tc = M("test_concurrence");//模拟商品的剩余数量

$this->pv = M("test_pv");//模拟访问次数

//对表加锁,注意,如果加锁过程中要操作多个表,要对这几个表都加锁,否则会报错

//mysql> lock table yxt_test_concurrence read;--只锁了一张表

//Query OK, 0 rows affected (0.00 sec)

//mysql> SELECT * from yxt_test_pv;--读取没有被锁的表

//ERROR 1100 (HY000): Table ‘yxt_test_pv‘ was not locked with LOCK TABLES--报错,提示查询的表没有被锁住

M()->execute("lock tables yxt_test_concurrence write,yxt_test_pv write;");$res=$this->tc->field(‘value‘)->find(1);//查到的剩余数量

$value=$res[‘value‘];if($value>0){//如果大于0,则进行下面的逻辑

$this->pv->data(array(‘val‘=>$value))->add();//这个是用来记录访问的次数

M()->execute("UPDATE `yxt_test_concurrence` SET `value`=`value` - 1 WHERE `id` = 1");//商品数量减1

}//解锁

M()->execute("unlock tables");

}

采用锁机制,可以严格控制库存数量的变化,但是采用锁会增加数据库的开销.

选择2.版本控制(乐观锁)

乐观锁,是假定事务之间是互不干扰的,事务在访问数据的时候,并不会获取锁,但是,在提交前,每个事务都要确保其他事务并没有修改他读取到的数据.如果在更新数据时发现其他事务已经修改了数据,则回滚提交.乐观锁经常用于"低争用数据结构"的场景中.当冲突特别少的时候,事务可以在完成时,不需要管理锁的开销及等待其他事务释放锁,这可以带来更高的吞吐率.但是,如果对于数据的争用特别频繁,重新开启一个新事务的开销会明显影响性能.

通常认为,其他并发控制方法,在此情况下会有更好的表现,然而,基于悲观锁的方法,会导致较差的性能.因为即使死锁可以避免,"锁"仍会极大的影响并发性能.(我想应该是因为会话被阻塞,从而导致只能串行访问数据库)

以上定义摘自wiki:https://en.wikipedia.org/wiki/Optimistic_concurrency_control

这种情况下,如果并发访问,则修改失败的几率会较高,

举例:在热销产品场景下则容易出现购买失败的情况.这对用户的体验是不好的.因为这意味着又要重新尝试一次.

小结:应该采取哪一种锁,应根据实际场景来权衡利弊,如果更新的很频繁,那应该使用悲观锁.此刻需要考虑的问题是:如何解决并发问题.如果很少更新,则使用乐观锁更为方便省事.

标签:

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

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

相关文章

ASP.NET Core 6 Minimal API

ASP.NET Core 6 Minimal APIIntro微软在 ASP.NET 6 Preview 4 的介绍文章中介绍了即将到来的 ASP.NET Core 6 中的最小 API 的雏形,我们现在已经基本可以达到最小化 API 了雏形了,在 Preview 4 的时候就写了这个小示例,但是不够简洁&#xff…

Form身份验证

网站安全模式 使用Windows身份验证 使用Forms身份验证 使用最多,也是最常见的方式 使用PassPort身份验证(收费) 需要MS给接口 Forms身份验证 Web.config <system.web> <authentication mode"Forms"> <forms loginUrl"登陆地址.aspx&…

支付宝今日起还卡收费;大城市女性买房猛增;小米发布100W快充技术;严查非法办学行为;交大通报博导辱骂学生;这就是今天的大新闻...

今天是3月26日农历二月二十今天星期二不是个让人可以昏昏欲睡的日子下面是今天的大新闻支付宝还信用卡开始收费&#xff08;澎湃新闻&#xff09;根据支付宝此前发布的消息&#xff0c;自3月26日起&#xff0c;通过支付宝给信用卡还款超过免费额度后将收取0.1%的服务费&#xf…

mysql connector c编程_MySQL数据库之MySQL Connector 编程

本文主要向大家介绍了MySQL数据库之MySQL Connector 编程 &#xff0c;通过具体的内容向大家展现&#xff0c;希望对大家学习MySQL数据库有所帮助。MySQL Connector 是MySQL数据库客户端编程的接口, 它提供了通过网络访问数据库的接口, 这些功能在动态链接库(.dll, .so)或者静态…

WPF任务栏同步进度

一、概要本篇文章主要分享使用TaskbarItemInfo对象&#xff08;WPF&#xff09;在window操作系统的任务栏中同步任务进度的功能。什么是TaskbarItemInfo对象&#xff1f;TaskbarItemInfo类为 Windows 7 任务栏功能提供托管包装。有关 Windows shell 和本机任务栏 Api 的详细信息…

每日一笑 | 各大互联网公司离职员工群名

全世界只有3.14 % 的人关注了数据与算法之美&#xff08;图源网络&#xff0c;侵权删&#xff09;

优秀的培训机构该如何培养学生?

作为一个优秀的培训机构来讲&#xff0c;培训的关键是提升学生的学习思想、养成良好学习习惯&#xff0c;培养学生较强的自学能力&#xff0c;否则讲再多的知识都还是少&#xff01; 老男孩培训多年来正是在履行着这样的教学理念和思路。 动物园的动物&#xff0c;如果不…

mysql快照过久_Oracle 快照(snapshot) 管理

----手工创建Oracle 快照 BEGIN DBMS_WORKLOAD_REPOSITORY.CREATE_SNAPSHOT (); END; / ---删除快照 具体快照信息可以查看视图 D----手工创建Oracle 快照BEGINDBMS_WORKLOAD_REPOSITORY.CREATE_SNAPSHOT ();END;/---删除快照具体快照信息可以查看视图 DBA_HIST_SNAPSHOTBEGIND…

WPF 左侧菜单样式

之前做了一个菜单样式&#xff0c;这样的&#xff1a;链接&#xff1a;WPF 修改(优化)Menu菜单的样式如今又来一个左侧菜单样式&#xff0c;其实只是修改了一下模板&#xff0c;如下图&#xff1a;还是老样子&#xff0c;代码全部都在MainWindow.xaml中&#xff1a;<Window …

STEAM教育风口正劲,如何培养STEAM思维?

近年来&#xff0c;STEAM教育越来越深入我们的生活&#xff0c;但STEAM教育到底是什么呢&#xff1f;来源于美国的“STEAM教育”是将五大学科——科学&#xff08;Science&#xff09;、技术&#xff08;Technology&#xff09;、工程&#xff08;Engineering&#xff09;、艺术…

【Android开发】Android应用程序目录结构

原文&#xff1a;http://android.eoe.cn/topic/summary Android开发之旅&#xff1a;组件生命周期吴秦 Android开发之旅&#xff1a;HelloWorld项目的目录结构 * HelloWorld项目的目录结构* &#xff08;这个HelloWorld项目是基于Android 2.1的&#xff09;在Eclipse的左侧展开…

vue从url中获取token并加入到 请求头里_BATJ都会用到的接口鉴权cookie、session 和token...

鉴权鉴权是指验证用户是否拥有访问系统的权利—鉴定权限。cookie、session和token为什么会有cookie、session和token&#xff1f;1、 http是无状态协议什么是无状态呢&#xff1f;答&#xff1a;当前请求和上一次或者下一次请求是没有任何关系的&#xff0c;好处是速度快&#…

程序有并发错误?NO WAY!

什么是并发错误并发是指程序能够交替执行不同的任务,以达到"同时执行效果"&#xff0c;加快程序的运行效率。但是并发也会导致一系列问题&#xff0c;以变量1赋值为例&#xff0c;由于操作实际由多条指令组成&#xff0c;不同任务执行指令的顺序可能是交错的&#xf…

好好珍惜今生,不要期待来世……

亲情经不起冷漠&#xff0c;爱情经不起谎言&#xff0c;友情经不起虚伪。再好的缘份也经不起敷衍&#xff0c;再深的感情也需要珍惜。没有绝对的傻瓜&#xff0c;只有愿为你装傻的人&#xff0c;原谅你的人&#xff0c;是不愿失去你的世界。一辈子真的好短好短…… 有多少人说好…

NET问答: C# 中是否有 format json 的类库?

咨询区 mpen&#xff1a;我在寻找一个 function&#xff0c;它能够接收 string 格式的json&#xff0c;并且能够以 换行缩进 的形式输出&#xff0c;比如&#xff1a;{"status":"OK", "results":[ {"types":[ "locality", &…

图像柔光效果(SoftGlow)的原理及其实现。

图像柔光效果在很多商业软件中都有实现&#xff0c;比如美图秀秀&#xff0c;光影魔术手等。其能针对原始图像产生一副新的比较平滑感觉光线比较柔和的效果&#xff0c;给人一种朦胧美&#xff0c;如下面几幅图所示&#xff1a; 目前&#xff0c;关于该算法的可控参数&#xff…

中小学招生强化就近入学;首次全女性太空行走取消;苹果付费新闻APP奔溃;NASA火星上发现鹅卵石;这就是今天的大新闻...

今天是3月27日农历二月廿一今天星期三有点闷已经开始用空调了下面是今天的大新闻中小学招生强化就近入学&#xff08;北京商报&#xff09;中小学秋季入学新生招生已经陆续开始&#xff0c;近日&#xff0c;教育部办公厅也紧随其后&#xff0c;印发了《关于做好2019年普通中小学…

python如何安装扩展库openpyxl和numpy_Python第三方库之openpyxl(2)

Python第三方库之openpyxl(2)简单的使用写一个工作簿>>> from openpyxl importWorkbook>>> from openpyxl.compat importrange>>> from openpyxl.utils importget_column_letter>>>>>> wb Workbook()>>>>>> de…

[翻译]在GC上加入DPAD

本文90%通过机器翻译&#xff0c;另外10%译者按照自己的理解进行翻译&#xff0c;和原文相比有所删减&#xff0c;可能与原文并不是一一对应&#xff0c;但是意思基本一致。译者水平有限&#xff0c;如果错漏欢迎批评指正译者Bing Translator、InCerry&#xff0c;另外感谢Hex、…

SQL 结合CASE WHEN 实现二维统计

在开发中往往要用到类似下面的二维统计&#xff1a; abtype15465type25454在SQL中使用CASE WHEN 语句可以很轻松的实现&#xff1a; SELECT SUM(CASE WHEN typetype1 THEN 1 ELSE 0 END) AS a ,SUM(CASE WHEN typetype2 THEN 1 ELSE 0 END) AS b FROM Table1 转载于:https://ww…