1500字范文,内容丰富有趣,写作好帮手!
1500字范文 > mysql – PHP高并发下单用事务可以解决吗?

mysql – PHP高并发下单用事务可以解决吗?

时间:2021-02-06 15:34:16

相关推荐

mysql – PHP高并发下单用事务可以解决吗?

后端开发|php教程

php,thinkphp,mysql

后端开发-php教程

跑腿app源码,电脑vscode的图标没了,ubuntu怎么用输入法,tomcat500错误,mysql,sqlite,网页设计文本超链接,vps怎么创建数据库,服务器与空间区别,织梦 在线租车 插件,layuimini前端框架,爬虫标准库,php 制表符,贵阳seo技术,springboot 动态分库,dede标签 判断语句,什么值得买网站客服,设计网页要打代码吗,手机订单提交页面模板,bootstrap 后台 教程,404页面免费模板,超市会员管理系统c 源代码,免费的微信小程序源码lzw

一个下单的小示例(上代码,没加事务的时候):

300源码,ubuntu脚本改变ip,配置好tomcat怎么用,反爬虫子,如何学习php程序外包,seo保障lzw

class IndexController extends Controller { public function index(){ $stock = M(stock); $log = M(log); $condition[id] = 1; if($stock->where($condition)->getField(stock_left) > 0) { $stock->where($condition)->setDec("stock_left"); $data[op] = 1; $log->add($data); } else { echo "已经没剩余了"; } }}

库存默认有100个:

动漫视频网站手机版源码,ubuntu选择更新源,tomcat自定义出错界面,多脚爬虫名字,php内置的预定义数组有哪些,seo专业教学lzw

日志表:

Apache ab工具并发一下:

ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html

结果出并发问题(很自然的):

然后加了事务控制之后:

class IndexController extends Controller { public function index(){ $stock = M(stock); $log = M(log); $condition[id] = 1; M()->startTrans(); if($stock->where($condition)->getField(stock_left) > 0) { $res1 = $stock->where($condition)->setDec("stock_left"); $data[op] = 1; $res2 = $log->add($data); if($res1 !== false && $res2) {M()->commit(); } else {M()->rollback(); } } else { echo "已经没剩余了"; } }}

再测试并发一下:

ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html

结果呢,输出的结果没问题(但是真的解决了并发问题吗?):

很多人说了用Redis队列来做,具体实施我还是有点不太清楚,请大家帮忙

回复内容:

一个下单的小示例(上代码,没加事务的时候):

class IndexController extends Controller { public function index(){ $stock = M(stock); $log = M(log); $condition[id] = 1; if($stock->where($condition)->getField(stock_left) > 0) { $stock->where($condition)->setDec("stock_left"); $data[op] = 1; $log->add($data); } else { echo "已经没剩余了"; } }}

库存默认有100个:

日志表:

Apache ab工具并发一下:

ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html

结果出并发问题(很自然的):

然后加了事务控制之后:

class IndexController extends Controller { public function index(){ $stock = M(stock); $log = M(log); $condition[id] = 1; M()->startTrans(); if($stock->where($condition)->getField(stock_left) > 0) { $res1 = $stock->where($condition)->setDec("stock_left"); $data[op] = 1; $res2 = $log->add($data); if($res1 !== false && $res2) {M()->commit(); } else {M()->rollback(); } } else { echo "已经没剩余了"; } }}

再测试并发一下:

ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html

结果呢,输出的结果没问题(但是真的解决了并发问题吗?):

很多人说了用Redis队列来做,具体实施我还是有点不太清楚,请大家帮忙

事务跟并发没有任何关系。你使用事务只能保证这一段逻辑成功或者失败,而不能保证并发时能控制住你的程序逻辑。

对并发进行控制还是需要锁 来解决,比如楼上有提到的mysql 实现乐观锁。

如 upadte table set a = a – 1 where a = 5; 只有在a=5的情况下这个update才会真正修改数据,使用这种方法是可以保证如果要修改的数据版本跟你预想中的不同,就不进行操作,通过影响行数来判断是否有修改,然后继续下面的操作或者退出。

还有就是使用排他锁,如果单机可以直接使用flock 来达到阻塞锁的目的。

或者redis和memcache来实现锁。

请求比较多的的情况下推荐使用redis,memcache来进行锁操作,或者考虑用消息队列来处理并发的情况。

用4000并发测试了下,还是会出现问题的:

用事务吧,PS用事务的时候,请务必这样操作

SELECT * FROM TABLE WHERE A=X LIMIT 1 FOR UPDATE;

务必使用FOR UPDATE;

不用 for update 一定会出现负数的情况。

你也可以给数据表加锁也行(InnoDB引擎就用行锁;MyISAM引擎就用表锁)

最核心还是在数据库,你需要做一个悲观锁或者乐观锁。

表面看你是解决了问题,其实特殊情况下还是会出现超卖的。

事务可以解决,统一提交即可,但是一般解决这个问题还得靠锁。

如果不用锁,就得用队列,就是排队插入,把异步改成同步,这样是最保险的。

可以参考我这个答案。

/q/1010000005105041/a-1020000005106490

队列的方法可以是,一个商品库存(也可以所有商品一起,跑一个下单队列)在后台有一个脚本在跑,然后把请求变成串行。这个方案会被推崇是因为可控性,我们可以根据系统需要控制处理的频率。

缓存的做法是,定时将商品库存更新到缓存里面去,利用缓存的原子读写,对缓存里的库存进行自减操作,如果自减后大于零,就可以走后面的下单流程(下单流程仍然需要完整的事务加锁来保证一致性),缓存的目的在于,避免流量冲击,只有有效流量进入db。

把第一个例子中的$condition[‘id’] = 1;换成”id=1 and stock_left > 0″的等效条件就解决问题了,不需要事务,事务在这个时候起不到什么作用。后面的逻辑当然也要相应调整,因为setDec肯定成功,但是不一定真有记录被修改了,所以伪码示例:

$sql = "update table set num = num - 1 where num > 0";$updatedRows = get_updated_rows($db->exec($sql));if ($updatedRows > 0) { //成功} else { //失败}

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。