search
HomeBackend DevelopmentPHP TutorialPHP+redis realizes snap-up function

PHP+redis realizes snap-up function

Feb 09, 2018 am 09:21 AM
phpFunction

Earlier we shared with you the code sharing of php and redis to implement the mall flash sale function. This article mainly introduces the php+redis message queue rush purchase implementation code in detail. It has certain reference value. Interested friends can refer to it. , hope it can help everyone.

Implementation functions:

1. Based on redis queue to prevent high concurrency overselling
2. Based on mysql transaction adding exclusive lock to prevent high concurrency overselling

Based on the redis queue workflow:

1. The administrator creates a redis product inventory queue based on the inventory in the goods table
2. Client accesses the flash sale API
3. The web server first queries the remaining inventory key content from the redis product inventory queue
4. If there is remaining inventory in the redis queue, create an order in mysql, remove the inventory, and the purchase is successful
5. There is no remaining inventory in the redis queue , it prompts that the inventory is insufficient and the rush purchase fails. Key contents

Based on mysql transaction and exclusive lock workflow:

1. Open the transaction
2. Query the inventory and display the Set write lock (exclusive lock): SELECT * FROM goods WHERE id = 1 FOR UPDATE
3. Generate order
4. Remove inventory, implicitly set write lock (exclusive lock): UPDATE goods SET counts = counts – 1 WHERE id = 1
5. commit, release the lock

Note: You can set the shared lock in the second step, otherwise it may cause a deadlock.

Code:


<?php
/**********************************************
* 抢购模块
*
* @author liubin
* @date 2016-02-10
*
* ab -n 1000 -c 100 http://192.168.16.73/Seckill/buy.php
*
*/
class seckill extends common
{

 private $_orderModel = null;
 private $_goodsModel = null;
 private $_redis = null;
 /*
  * 错误信息
 */
 protected $_error = &#39;&#39;;
 /**
  * 构造器
  *
 */
 public function __construct()
 {
  if($this->_orderModel === null){
   $this->_orderModel = new OrderModel();
  }
  if($this->_goodsModel === null){
   $this->_goodsModel = new GoodsModel();
  }
  if($this->_redis === null){
   $this->_redis = new QRedis(); 
  }
 }
 /*
  * 秒杀API
  * 
  * @author liubin
  * @date 2017-02-10
 */
 public function addQsec(){
  $gid = intval($_GET[&#39;gid&#39;]);
  $type = isset($_GET[&#39;type&#39;]) ? $_GET[&#39;type&#39;] : &#39;mysql&#39;;
  switch ($type) {
   case &#39;mysql&#39;:
    $this->order_check_mysql($gid);
    echo $this->getError();
    break;
   case &#39;redis&#39;:
    $this->order_check_redis($gid);
    echo $this->getError();
    break;
   case &#39;transaction&#39;:
    $this->order_check_transaction($gid);
    echo $this->getError();
    break;
   default:
    echo &#39;类型错误&#39;;
    break;
  }
 }
 /*
  * 获取错误信息
  * 
  * @author liubin
  * @date 2017-02-10
 */
 public function getError(){
  return $this->_error;
 }
 /*
  * 基于mysql验证库存信息
  * @desc 高并发下会导致超卖
  *
  * @author liubin
  * @date 2017-02-10
 */
 protected function order_check_mysql($gid){


  $model = $this->_goodsModel;
  $pdo = $model->getHandler();
  $gid = intval($gid);

  /*
   * 1:$sql_forlock如果不加事务,不加写锁:
   * 超卖非常严重,就不说了
   * 
   * 2:$sql_forlock如果不加事务,只加写锁:
   * 第一个会话读$sql_forlock时加写锁,第一个会话$sql_forlock查询结束会释放该行锁.
   * 第二个会话在第一个会话释放后读$sql_forlock的写锁时,会再次$sql_forlock查库存
   * 导致超卖现象产生
   *
  */
  $sql_forlock = &#39;select * from goods where id = &#39;.$gid .&#39; limit 1 for update&#39;;
  //$sql_forlock = &#39;select * from goods where id = &#39;.$gid .&#39; limit 1&#39;;
  $result = $pdo->query($sql_forlock,PDO::FETCH_ASSOC);
  $goodsInfo = $result->fetch();

  if($goodsInfo[&#39;counts&#39;]>0){

   //去库存
   $gid = $goodsInfo[&#39;id&#39;];
   $sql_inventory = &#39;UPDATE goods SET counts = counts - 1 WHERE id = &#39;.$gid;
   $result = $this->_goodsModel->exect($sql_inventory);
   if($result){
    //创订单
    $data    = [];
    $data[&#39;order_id&#39;] = $this->_orderModel->buildOrderNo();
    $data[&#39;goods_id&#39;] = $goodsInfo[&#39;id&#39;];
    $data[&#39;addtime&#39;] = time();
    $data[&#39;uid&#39;]  = 1;
    $order_rs = $this->_orderModel->create_order($data);
    if($order_rs){
     $this->_error = &#39;购买成功&#39;;
     return true;
    }
   }
  }

  $this->_error = &#39;库存不足&#39;;
  return false;

 }
 /*
  * 基于redis队列验证库存信息
  * @desc Redis是底层是单线程的,命令执行是原子操作,包括lpush,lpop等.高并发下不会导致超卖
  *
  * @author liubin
  * @date 2017-02-10
 */
 protected function order_check_redis($gid){
  $goodsInfo = $this->_goodsModel->getGoods($gid);
  if(!$goodsInfo){
   $this->_error = &#39;商品不存在&#39;;
   return false;
  }
  $key = &#39;goods_list_&#39;.$goodsInfo[&#39;id&#39;];
  $count = $this->_redis->getHandel()->lpop($key);
  if(!$count){
   $this->_error = &#39;库存不足&#39;;
   return false;
  }
  //生成订单
  $data    = [];
  $data[&#39;order_id&#39;] = $this->_orderModel->buildOrderNo();
  $data[&#39;goods_id&#39;] = $goodsInfo[&#39;id&#39;];
  $data[&#39;addtime&#39;] = time();
  $data[&#39;uid&#39;]  = 1;
  $order_rs = $this->_orderModel->create_order($data);

  //库存减少
  $gid = $goodsInfo[&#39;id&#39;];
  $sql = &#39;UPDATE goods SET counts = counts - 1 WHERE id = &#39;.$gid;
  $result = $this->_goodsModel->exect($sql);
  $this->_error = &#39;购买成功&#39;;
  return true;
 }
 /*
  * 基于mysql事务验证库存信息
  * @desc 事务 和 行锁 模式,高并发下不会导致超卖,但效率会慢点
  * @author liubin
  * @date 2017-02-10


  说明:
  如果$sql_forlock不加写锁,并发时,$sql_forlock查询的记录存都大于0,可以减库存操作.
  如果$sql_forlock加了写锁,并发时,$sql_forlock查询是等待第一次链接释放后查询.所以库存最多就是5

 */
 protected function order_check_transaction($gid){

  $model = $this->_goodsModel;
  $pdo = $model->getHandler();
  $gid = intval($gid);

  try{
   $pdo->beginTransaction();//开启事务处理


   /*
    * 1:$sql_forlock如果只加事务,不加写锁:
    * 开启事务
    * 因为没有加锁,读$sql_forlock后,并发时$sql_inventory之前还可以再读。
    * $sql_inventory之后和commit之前才会锁定
    * 出现超卖跟事务的一致性不冲突
    * 
    *
    * 2:$sql_forlock如果加了事务,又加读锁:
    * 开启事务
    * 第一个会话读$sql_forlock时加读锁,并发时,第二个会话也允许获得$sql_forlock的读锁,
    * 但是在第一个会话执行去库存操作时(写锁),写锁便会等待第二个会话的读锁,第二个会话执行写操作时,写锁便会等待第一个会话的读锁,
    * 出现死锁

    * 3:$sql_forlock如果加了事务,又加写锁:
    * 开启事务
    * 第一个会话读$sql_forlock时加写锁,直到commit才会释放写锁,并发查询不会出现超卖现象。
    *
   */

   $sql_forlock = &#39;select * from goods where id = &#39;.$gid .&#39; limit 1 for update&#39;;
   //$sql_forlock = &#39;select * from goods where id = &#39;.$gid .&#39; limit 1 LOCK IN SHARE MODE&#39;;
   //$sql_forlock = &#39;select * from goods where id = &#39;.$gid .&#39; limit 1&#39;;
   $result = $pdo->query($sql_forlock,PDO::FETCH_ASSOC);
   $goodsInfo = $result->fetch();

   if($goodsInfo[&#39;counts&#39;]>0){

    //去库存
    $gid = $goodsInfo[&#39;id&#39;];
    $sql_inventory = &#39;UPDATE goods SET counts = counts - 1 WHERE id = &#39;.$gid;
    $result = $this->_goodsModel->exect($sql_inventory);

    if(!$result){
     $pdo->rollBack();
     $this->_error = &#39;库存减少失败&#39;;
     return false;
    }

    //创订单
    $data    = [];
    $data[&#39;id&#39;]   = &#39;null&#39;;
    $data[&#39;order_id&#39;] = $this->_orderModel->buildOrderNo();
    $data[&#39;goods_id&#39;] = $goodsInfo[&#39;id&#39;];
    $data[&#39;uid&#39;]  = &#39;abc&#39;;
    $data[&#39;addtime&#39;] = time();

    $sql = &#39;insert into orders (id,order_id,goods_id,uid,addtime) values (&#39;.$data[&#39;id&#39;].&#39;,"&#39;.$data[&#39;order_id&#39;].&#39;","&#39;.$data[&#39;goods_id&#39;].&#39;","&#39;.$data[&#39;uid&#39;].&#39;","&#39;.$data[&#39;addtime&#39;].&#39;")&#39;;   
    $result = $pdo->exec($sql);
    if(!$result){
     $pdo->rollBack();
     $this->_error = &#39;订单创建失败&#39;;
     return false;
    }
    $pdo->commit();//提交
    $this->_error = &#39;购买成功&#39;;
    return true;

   }else{
    $this->_error = &#39;库存不足&#39;;
    return false;
   }
  }catch(PDOException $e){
   echo $e->getMessage();
   $pdo->rollBack();
  }


 }
 /*
  * 创建订单
  * mysql 事物处理,也可以用存储过程
  *
 */
 private function create_order($goodsInfo){
  //生成订单
  $data    = [];
  $data[&#39;order_id&#39;] = $this->_orderModel->buildOrderNo();
  $data[&#39;goods_id&#39;] = $goodsInfo[&#39;id&#39;];
  $data[&#39;addtime&#39;] = time();
  $data[&#39;uid&#39;]  = 1;
  $order_rs = $this->_orderModel->create_order($data);

  //库存减少
  $gid = $goodsInfo[&#39;id&#39;];
  $sql = &#39;UPDATE goods SET counts = counts - 1 WHERE id = &#39;.$gid;
  $result = $this->_goodsModel->exect($sql);
  return true;
 }
}

Related recommendations:

PHP implements concurrent snap-up function through locking

How to use JS code to implement the web page snap-up function

How to handle high-concurrency requests for snap-up functions in php

The above is the detailed content of PHP+redis realizes snap-up function. For more information, please follow other related articles on the PHP Chinese website!

Statement
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
PHP's Current Status: A Look at Web Development TrendsPHP's Current Status: A Look at Web Development TrendsApr 13, 2025 am 12:20 AM

PHP remains important in modern web development, especially in content management and e-commerce platforms. 1) PHP has a rich ecosystem and strong framework support, such as Laravel and Symfony. 2) Performance optimization can be achieved through OPcache and Nginx. 3) PHP8.0 introduces JIT compiler to improve performance. 4) Cloud-native applications are deployed through Docker and Kubernetes to improve flexibility and scalability.

PHP vs. Other Languages: A ComparisonPHP vs. Other Languages: A ComparisonApr 13, 2025 am 12:19 AM

PHP is suitable for web development, especially in rapid development and processing dynamic content, but is not good at data science and enterprise-level applications. Compared with Python, PHP has more advantages in web development, but is not as good as Python in the field of data science; compared with Java, PHP performs worse in enterprise-level applications, but is more flexible in web development; compared with JavaScript, PHP is more concise in back-end development, but is not as good as JavaScript in front-end development.

PHP vs. Python: Core Features and FunctionalityPHP vs. Python: Core Features and FunctionalityApr 13, 2025 am 12:16 AM

PHP and Python each have their own advantages and are suitable for different scenarios. 1.PHP is suitable for web development and provides built-in web servers and rich function libraries. 2. Python is suitable for data science and machine learning, with concise syntax and a powerful standard library. When choosing, it should be decided based on project requirements.

PHP: A Key Language for Web DevelopmentPHP: A Key Language for Web DevelopmentApr 13, 2025 am 12:08 AM

PHP is a scripting language widely used on the server side, especially suitable for web development. 1.PHP can embed HTML, process HTTP requests and responses, and supports a variety of databases. 2.PHP is used to generate dynamic web content, process form data, access databases, etc., with strong community support and open source resources. 3. PHP is an interpreted language, and the execution process includes lexical analysis, grammatical analysis, compilation and execution. 4.PHP can be combined with MySQL for advanced applications such as user registration systems. 5. When debugging PHP, you can use functions such as error_reporting() and var_dump(). 6. Optimize PHP code to use caching mechanisms, optimize database queries and use built-in functions. 7

PHP: The Foundation of Many WebsitesPHP: The Foundation of Many WebsitesApr 13, 2025 am 12:07 AM

The reasons why PHP is the preferred technology stack for many websites include its ease of use, strong community support, and widespread use. 1) Easy to learn and use, suitable for beginners. 2) Have a huge developer community and rich resources. 3) Widely used in WordPress, Drupal and other platforms. 4) Integrate tightly with web servers to simplify development deployment.

Beyond the Hype: Assessing PHP's Role TodayBeyond the Hype: Assessing PHP's Role TodayApr 12, 2025 am 12:17 AM

PHP remains a powerful and widely used tool in modern programming, especially in the field of web development. 1) PHP is easy to use and seamlessly integrated with databases, and is the first choice for many developers. 2) It supports dynamic content generation and object-oriented programming, suitable for quickly creating and maintaining websites. 3) PHP's performance can be improved by caching and optimizing database queries, and its extensive community and rich ecosystem make it still important in today's technology stack.

What are Weak References in PHP and when are they useful?What are Weak References in PHP and when are they useful?Apr 12, 2025 am 12:13 AM

In PHP, weak references are implemented through the WeakReference class and will not prevent the garbage collector from reclaiming objects. Weak references are suitable for scenarios such as caching systems and event listeners. It should be noted that it cannot guarantee the survival of objects and that garbage collection may be delayed.

Explain the __invoke magic method in PHP.Explain the __invoke magic method in PHP.Apr 12, 2025 am 12:07 AM

The \_\_invoke method allows objects to be called like functions. 1. Define the \_\_invoke method so that the object can be called. 2. When using the $obj(...) syntax, PHP will execute the \_\_invoke method. 3. Suitable for scenarios such as logging and calculator, improving code flexibility and readability.

See all articles

Hot AI Tools

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress AI Tool

Undress images for free

Clothoff.io

Clothoff.io

AI clothes remover

AI Hentai Generator

AI Hentai Generator

Generate AI Hentai for free.

Hot Article

R.E.P.O. Energy Crystals Explained and What They Do (Yellow Crystal)
3 weeks agoBy尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Best Graphic Settings
3 weeks agoBy尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. How to Fix Audio if You Can't Hear Anyone
3 weeks agoBy尊渡假赌尊渡假赌尊渡假赌
WWE 2K25: How To Unlock Everything In MyRise
4 weeks agoBy尊渡假赌尊渡假赌尊渡假赌

Hot Tools

MinGW - Minimalist GNU for Windows

MinGW - Minimalist GNU for Windows

This project is in the process of being migrated to osdn.net/projects/mingw, you can continue to follow us there. MinGW: A native Windows port of the GNU Compiler Collection (GCC), freely distributable import libraries and header files for building native Windows applications; includes extensions to the MSVC runtime to support C99 functionality. All MinGW software can run on 64-bit Windows platforms.

MantisBT

MantisBT

Mantis is an easy-to-deploy web-based defect tracking tool designed to aid in product defect tracking. It requires PHP, MySQL and a web server. Check out our demo and hosting services.

Safe Exam Browser

Safe Exam Browser

Safe Exam Browser is a secure browser environment for taking online exams securely. This software turns any computer into a secure workstation. It controls access to any utility and prevents students from using unauthorized resources.

SublimeText3 Mac version

SublimeText3 Mac version

God-level code editing software (SublimeText3)

Dreamweaver Mac version

Dreamweaver Mac version

Visual web development tools