Heim  >  Artikel  >  Backend-Entwicklung  >  mysql - PHP高并发下单用事务可以解决吗?

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

WBOY
WBOYOriginal
2016-07-06 13:53:231444Durchsuche

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

<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个:
mysql - PHP高并发下单用事务可以解决吗?

日志表:
mysql - PHP高并发下单用事务可以解决吗?

Apache ab工具并发一下:
ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html

结果出并发问题(很自然的):
mysql - PHP高并发下单用事务可以解决吗?

然后加了事务控制之后:

<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
结果呢,输出的结果没问题(但是真的解决了并发问题吗?):
mysql - PHP高并发下单用事务可以解决吗?

很多人说了用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个:
mysql - PHP高并发下单用事务可以解决吗?

日志表:
mysql - PHP高并发下单用事务可以解决吗?

Apache ab工具并发一下:
ab -n 1200 -c 1200 -w http://localhost/queue/index.php >> D:/1.html

结果出并发问题(很自然的):
mysql - PHP高并发下单用事务可以解决吗?

然后加了事务控制之后:

<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
结果呢,输出的结果没问题(但是真的解决了并发问题吗?):
mysql - PHP高并发下单用事务可以解决吗?

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

事务跟并发没有任何关系。你使用事务只能保证这一段逻辑成功或者失败,而不能保证并发时能控制住你的程序逻辑。
对并发进行控制还是需要锁 来解决,比如楼上有提到的mysql 实现乐观锁。
如 upadte table set a = a - 1 where a = 5; 只有在a=5的情况下这个update才会真正修改数据,使用这种方法是可以保证如果要修改的数据版本跟你预想中的不同,就不进行操作,通过影响行数来判断是否有修改,然后继续下面的操作或者退出。

还有就是使用排他锁,如果单机可以直接使用flock 来达到阻塞锁的目的。
或者redis和memcache来实现锁。
请求比较多的的情况下推荐使用redis,memcache来进行锁操作,或者考虑用消息队列来处理并发的情况。

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

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

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

用事务吧,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>
Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Vorheriger Artikel:负载均衡 - nginx php解析Nächster Artikel:关于ob_start的疑问。