redis秒杀抢购并发核心代码及测试

核心代码

如下:

<?php

try {

    $redis = new Redis();
    $redis->connect(127.0.0.1, 6379);
    //   $uid=$this->uid;//获取用户的id
    $uid = $_GET[id];//因为我没有模拟登陆,所以用户id使用get传递以下,实际场景下可已使用上面的类似代码获取
    $count = $redis->LLEN(data %};
    if ($count >= 100) {//查看秒杀请求是否满了,满了提示
        echo (100个了 %};
        die;
    }
    $redis->LPUSH(data, $uid);//进来一个秒杀请求
 

  
    //TODO  成功进来的请求走后续逻辑挨个出列,如创建订单
    echo ($uid.  开始创建订单了 %};

} catch (Exception $e) {
    echo $e->getMessage();
}

讲解

1. redis的原子性

redis之所以能够用做并发处理的中间件,很大程度上是得益于它的IO操作是原子性的,那么redis的原子性到底是什么??

原子性是数据库的事务中的特性。在数据库事务的情景下，原子性指的是：一个事务（transaction）中的所有操作，要么全部完成，要么全部不完成，不会结束在中间某个环节。

对于Redis而言，命令的原子性指的是：一个操作的不可以再分，操作要么执行，要么不执行。

Redis操作原子性的原因

Redis的操作之所以是原子性的，是因为Redis是单线程的。

由于对操作系统相关的知识不是很熟悉，从上面这句话并不能真正理解Redis操作是原子性的原因，进一步查阅进程与线程的概念及其区别。

2. 进程与线程

2.1 进程

计算机中已执行程序的实体。比如，一个启动了的php-fpm，就是一个进程。

2.2 线程

操作系统能够进行运算调度的最小单元。它被包含在进程之中，是进程的实际运作单位。一条线程指的是进程中一个单一顺序的控制流，一个进程中可以并发多个线程，每条线程并行执行不同的任务。比如，mysql运行时，mysql启动后，该mysql服务就是一个进程，而mysql的连接、查询的操作，就是线程。

3. 进程与线程的区别

资源（如打开文件）：进程间的资源相互独立，同一进程的各线程间共享资源。某进程的线程在其他进程不可见。

通信：进程间通信：消息传递、同步、共享内存、远程过程调用、管道。线程间通信：直接读写进程数据段（需要进程同步和互斥手段的辅助，以保证数据的一致性）。

调度和切换：线程上下文切换比进程上下文切换要快得多。

线程，是操作系统最小的执行单元，在单线程程序中，任务一个一个地做，必须做完一个任务后，才会去做另一个任务。

4. 代码含义

从上面的代码中可以看出,当请求过来以后我们判断队列的请求数是否溢出,溢出的话,会提示:

秒杀商品不足,已结束

等等用户友好提示;如过人数没有溢出,就将其放入redis的队列,继续执行创建订单及付款的操作

测试脚本

下面我就用图文的方式简单的测试下我们刚刚的业务脚本,这里为了方便测试,我将总的秒杀数量改为 5 个(如下),模拟100用户同时在1s内同时发起请求的场景,因为实际场景会比我们测试的要复杂的多,所以结果仅供参考

<?php

try {

    $redis = new Redis();
    $redis->connect(127.0.0.1, 6379);
    //   $uid=$this->uid;//获取用户的id
    $uid = $_GET[id];//因为我没有模拟登陆,所以用户id使用get传递以下,实际场景下可已使用上面的类似代码获取
    $count = $redis->LLEN(data %};
    if ($count >= 5) {//查看秒杀请求是否满了,满了提示
        echo (5个,够了 %};
        die;
    }
    $redis->LPUSH(data, $uid);//进来一个秒杀请求
 
    //TODO  成功进来的请求走后续逻辑挨个出列,如创建订单
    echo ($uid.  开始创建订单了 %};

} catch (Exception $e) {
    echo $e->getMessage();
}