【心得】TP6使用Redis进行处理商城秒杀

书接上回，上次分享了TP6对于Redis的基础使用，那么今天就为大家带来一个简单的，使用场景很高的心得代码风险，Redis在商城秒杀的使用，该代码为简单分享能解决一些基础后续可以根据自己所需进行业务重构。

读这篇文章的我就默认大家已经环境都安装好了，如果不知道怎么安装的可以传送到这里

https://blog.51cto.com/u_16240159/7486573

整体业务流程

1.在准备秒杀时，先将当前参与秒杀的的产品进行入队处理 2.进入秒杀页面处理当前的用户是否进入到队列

业务代码逻辑

首先在extend文件夹下新建Redis.php

<?php
/**
 * Created by PhpStorm.
 * User: lhl
 * Date: 2018/8/20
 * Time: 下午1:52
 */

namespace module;


class Redis extends \Redis
{
    public static function redis() {
        $con = new \Redis();
        $con->connect(config('redis.host'), config('redis.port'), 5);
        return $con;
    }
}

在thinkphp文件下的helper.php加入


if (!function_exists('redis')) {
    /**
     * 获取容器对象实例
     * @return Container
     */
    function redis()
    {
        return \module\Redis::redis();
    }
}

然后就可以在控制器写redis缓存方法了  
//创建redis缓存
\Cache::store('redis')->set(key, value);
//读取缓存
\Cache::store('redis')->get(key);

然后，我们就要注意，秒杀最大的问题就是高并发情况下会出现超卖的情况所以我们可以模仿一下，新建三张表，商品表、日志表、订单表

让我们开始吧：

public function insva(){
        $id = input('id');//获取商品id
        if(!$id){
            return $this->insertlog(0);//记录失败日志
        }
        $redis = $this->redis();//接入redis
        $count = $redis->reduceStock('goods_stock');//减少库存，返回剩余库存
        if($count ==0){
            $this->insertlog(0);//记录秒杀失败日志
            return false;
        }else{
            $order = $this->build_order_no();//随机生成订单号
            $status = 1;
            $data = db('goods')->where('id',$id)->find();
            if (!$data){
                return $this->insertlog(0);//商品不存在
            }
            $res = db('order')->insert(['order_sn'=>$order,'uid'=>$this->user_id,'goods_id'=>$id]);//插入订单
            $stock = db('goods')->where('id',$id)->setDec('count');//减少库存
            if($stock){
                $this->insertlog();//记录成功日志
            }else{
                $this->insertlog(0);//记录秒杀失败日志
            }
        }
    }

    // 将商品库存存入队列
    public function redisinit(){
        $store=50; // 库存50
        $redis=$this->redis(); //接入redis
        $redis->del('goods_store'); // 删除库存列表
        $res=$redis->llen('goods_store'); //返回库存长度，这里已经是0
        $count=$store-$res;
        for($i=0;$i<$count;$i++){
            $redis->lpush('goods_store',1); //列表推进50个，模拟50个商品库存
        }
    }

    //生成唯一订单
    function build_order_no(){
        return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
    }
    
    
    
// 记录日志 状态1成功 0失败
    function insertlog($status=1){
        return Db::name("ab_log")->insertGetId(["count"=>1,"status"=>$status,"addtime"=>date('Y-m-d H:i:s')]);
    }

以上就是简单的一个实现高并发，秒杀的代码了，有啥问题可以互相交流指正