一个下单的小示例(上代码,没加事务的时候):
<code>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 "已经没剩余了"; } } }</code>
库存默认有100个:
日志表:
Apache ab工具并发一下:
ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html
结果出并发问题(很自然的):
然后加了事务控制之后:
<code>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 "已经没剩余了"; } } }</code>
再测试并发一下:
ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html
结果呢,输出的结果没问题(但是真的解决了并发问题吗?):
很多人说了用Redis队列来做,具体实施我还是有点不太清楚,请大家帮忙
回复内容:
一个下单的小示例(上代码,没加事务的时候):
<code>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 "已经没剩余了"; } } }</code>
库存默认有100个:
日志表:
Apache ab工具并发一下:
ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html
结果出并发问题(很自然的):
然后加了事务控制之后:
<code>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 "已经没剩余了"; } } }</code>
再测试并发一下:
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
引擎就用表锁)
最核心还是在数据库,你需要做一个悲观锁或者乐观锁。
表面看你是解决了问题,其实特殊情况下还是会出现超卖的。
事务可以解决,统一提交即可,但是一般解决这个问题还得靠锁。
如果不用锁,就得用队列,就是排队插入,把异步改成同步,这样是最保险的。
可以参考我这个答案。
https://segmentfault.com/q/1010000005105041/a-1020000005106490
队列的方法可以是,一个商品库存(也可以所有商品一起,跑一个下单队列)在后台有一个脚本在跑,然后把请求变成串行。这个方案会被推崇是因为可控性,我们可以根据系统需要控制处理的频率。
缓存的做法是,定时将商品库存更新到缓存里面去,利用缓存的原子读写,对缓存里的库存进行自减操作,如果自减后大于零,就可以走后面的下单流程(下单流程仍然需要完整的事务加锁来保证一致性),缓存的目的在于,避免流量冲击,只有有效流量进入db。
把第一个例子中的$condition['id'] = 1;换成"id=1 and stock_left > 0"的等效条件就解决问题了,不需要事务,事务在这个时候起不到什么作用。后面的逻辑当然也要相应调整,因为setDec肯定成功,但是不一定真有记录被修改了,所以伪码示例:
<code>$sql = "update table set num = num - 1 where num > 0"; $updatedRows = get_updated_rows($db->exec($sql)); if ($updatedRows > 0) { //成功 } else { //失败 }</code>

使用数据库存储会话的主要优势包括持久性、可扩展性和安全性。1.持久性:即使服务器重启,会话数据也能保持不变。2.可扩展性:适用于分布式系统,确保会话数据在多服务器间同步。3.安全性:数据库提供加密存储,保护敏感信息。

在PHP中实现自定义会话处理可以通过实现SessionHandlerInterface接口来完成。具体步骤包括:1)创建实现SessionHandlerInterface的类,如CustomSessionHandler;2)重写接口中的方法(如open,close,read,write,destroy,gc)来定义会话数据的生命周期和存储方式;3)在PHP脚本中注册自定义会话处理器并启动会话。这样可以将数据存储在MySQL、Redis等介质中,提升性能、安全性和可扩展性。

SessionID是网络应用程序中用来跟踪用户会话状态的机制。1.它是一个随机生成的字符串,用于在用户与服务器之间的多次交互中保持用户的身份信息。2.服务器生成并通过cookie或URL参数发送给客户端,帮助在用户的多次请求中识别和关联这些请求。3.生成通常使用随机算法保证唯一性和不可预测性。4.在实际开发中,可以使用内存数据库如Redis来存储session数据,提升性能和安全性。

在无状态环境如API中管理会话可以通过使用JWT或cookies来实现。1.JWT适合无状态和可扩展性,但大数据时体积大。2.Cookies更传统且易实现,但需谨慎配置以确保安全性。

要保护应用免受与会话相关的XSS攻击,需采取以下措施:1.设置HttpOnly和Secure标志保护会话cookie。2.对所有用户输入进行输出编码。3.实施内容安全策略(CSP)限制脚本来源。通过这些策略,可以有效防护会话相关的XSS攻击,确保用户数据安全。

优化PHP会话性能的方法包括:1.延迟会话启动,2.使用数据库存储会话,3.压缩会话数据,4.管理会话生命周期,5.实现会话共享。这些策略能显着提升应用在高并发环境下的效率。

thesession.gc_maxlifetimesettinginphpdeterminesthelifespanofsessiondata,setInSeconds.1)它'sconfiguredinphp.iniorviaini_set().2)abalanceIsiseededeedeedeedeedeedeedto to to avoidperformance andununununununexpectedLogOgouts.3)

在PHP中,可以使用session_name()函数配置会话名称。具体步骤如下:1.使用session_name()函数设置会话名称,例如session_name("my_session")。2.在设置会话名称后,调用session_start()启动会话。配置会话名称可以避免多应用间的会话数据冲突,并增强安全性,但需注意会话名称的唯一性、安全性、长度和设置时机。


热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

Video Face Swap
使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热门文章

热工具

螳螂BT
Mantis是一个易于部署的基于Web的缺陷跟踪工具,用于帮助产品缺陷跟踪。它需要PHP、MySQL和一个Web服务器。请查看我们的演示和托管服务。

EditPlus 中文破解版
体积小,语法高亮,不支持代码提示功能

ZendStudio 13.5.1 Mac
功能强大的PHP集成开发环境

安全考试浏览器
Safe Exam Browser是一个安全的浏览器环境,用于安全地进行在线考试。该软件将任何计算机变成一个安全的工作站。它控制对任何实用工具的访问,并防止学生使用未经授权的资源。

SublimeText3 Mac版
神级代码编辑软件(SublimeText3)