PHP高并发高负载下的3种实战场景解决方法示例

命令：
subscribe __keyevent@0__:expired

命令：
setex test_key_name 30 ceshi

<?php
//设置php脚本执行时间
set_time_limit(0);
//设置socket连接超时时间
ini_set('default_socket_timeout', -1);
class redisSubscribe 
{
    protected $config = [
        "host" => "127.0.0.1",
        "password" => "6379"
    ];
    protected $redis;
    public function __construct() 
    {
        try {
            $this->redis = new \Redis();
            $this->redis->pconnect($this->config['host'],$this->config['password']);
        } catch(\Exception $e) {
            echo "redis错误：".$e->getMessage().PHP_EOL;
        }
    }
    // 普通消息订阅
    public function normal()
    {
        //声明频道名称
        $channelName = "test";
        try {
            $this->redis->subscribe([$channelName], function ($redis, $channel, $msg)
            {
                echo 'channel:' . $channel . ',message:' . $msg . PHP_EOL;
                file_put_contents('subscribe.log',"\n-".$msg."-\n",FILE_APPEND);
            });
        } catch (\Exception $e) {
            echo $e->getMessage();
        }
    }
    // 订阅Key失效事件的频道
    public function keyNotify()
    {
        echo "wathc keyNotify start~~".PHP_EOL;
        // Key事件回调
        //$channel = "__keyevent@0__:expired";        // 0号库的Key过期事件频道名
        $channel = "__keyevent@*__:expired";        // 所有库的Key过期事件频道名
        try {
            $this->redis->subscribe([$channel], function ($redis, $channel, $msg)
            {
                echo 'channel:' . $channel . '===========' . ',message:' . $msg . PHP_EOL;
                file_put_contents('subscribe.log',"\n-".$msg."-\n",FILE_APPEND);
            });
        } catch (\Exception $e) {
            echo $e->getMessage();
        }
    }
}
(new redisSubscribe())->keyNotify();
?>

/**
     * @Notes: 高并发防止重复提交（插入数据） 【保证接口的幂等性】
     * @Interface preventRepeatSubmit
     * @return mixed
     * @author: bqs
     * @Time: 2020/6/19 14:56
     */
    public function preventRepeatSubmit()
    {
        /* 比如查询某条(什么条件)记录是否存在，分布式锁机制[redis的原子性setnx]
         * 1. 通过条件拼接为唯一的键名，将键名setnx设置一个30s有效期的值
         * 2. setnx设置键名不成功(返回0)表示已经存在，接口则直接返回记录已经存在
         * 3. 根据该条件查询数据库记录，如果存在，接口再返回记录已经存在
         * 【只要添加记录前需要查询什么是否存在则都需要考虑高并发情况，则通过此方案】
        */
        $redis = Redis::db(0);
        $no = date('YmdHis',time()).mt_rand(1000,9999);
        //$no = 202006191537447811;
        // 是否添加锁表
        $addLock = false;
        if ($redis->setnx($no,1)) {
            $redis->expire($no,30);     //设置30s过期时间
        } else {
            $addLock = true;        // 订单已经存在则锁住
        }
        // 数据库查询是否存在
        $isExist = Db::name('ztest')->where(['no'=>$no])->find();
        if ($isExist) {
            $addLock = true;
        }
        if (!$addLock) {
            $data = [
                "no" => $no,
                "tab_num" => 2,
                "stock" => 20,
                "create_time" => time()
            ];
            $res = Db::name('ztest')->insertGetId($data);
        }
        return "添加数据成功";
    }

/**
     * @Notes: 高并发乐观锁 - （更新数据）
     * @Interface testConcurrence
     * @return mixed
     * @author: bqs
     * @Time: 2020/6/19 14:25
     */
    public function testConcurrence()
    {
        // 开启事务
        Db::startTrans();
        // 查询ID25当前的库存和版本号
        $curr = Db::name('ztest')->field('stock,version')->where(['id'=>25])->find();
        // 判断库存是否小于0
        if ($curr && $curr['stock'] <= 0) {
            throw new \Exception('物品已售罄',302);
        }
        try {
            // 修改库存 - 获取ID25的行琐
            $updateRes = Db::name('ztest')->where(['id'=>25,'version'=>$curr['version']])->update(['stock'=>$curr['stock']-1,'version'=>$curr['version']+1]);
            // 标识并发过来修改的，拿到的version太旧，事务回滚重新回到查询再走一遍
            if (!$updateRes) {
                Db::rollback();
            }
        } catch(\Exception $e) {
            Db::rollback();
            // 记录日志，或者返回
        }
        // 事务提交
        Db::commit();
        return '购买成功了';
    }