Cet article présente principalement l'explication détaillée de PHP combinée aux produits de vente flash Redis. Il a une certaine valeur de référence. si vous en avez besoin. Les amis peuvent se référer à
1.1 Créer table de produits, table de commande et initialiser les données
table de commande.
1.2 Écrire les données du produit dans la file d'attente Redis.
Par exemple, il y a 100 pièces du produit n°1. Écrivez simplement 100 1 dans la file d'attente marchandises_1. Par exemple, en utilisant l'atomicité de l'opération pop (transport de concurrence), lors d'un achat ultérieur, il suffit d'en afficher un après en avoir acheté un.
//代码使用yii 框架,重点在思路,其它框架做少量调整即可。 $redis = self::createRedisObj(); //创建redis 对象,后面提供详细代码 $sql = "select * from sec_goods"; $rows = Yii::app()->db->createCommand($sql)->queryAll(); foreach( $rows as $key => $row ): $goods_id = $row["id"]; $stock_avail = $row["stock_avail"]; $redis_key = "goods_".$goods_id; for($i =0 ; $i< $stock_avail; $i++){ $redis->lpush($redis_key , 1); } echo $goods_id."llen is ".$redis->lLen($redis_key)."<br/>"; endforeach;
Comme indiqué ci-dessous une fois terminé. (Dans des situations réelles, des ajustements de bibliothèque peuvent se produire en arrière-plan et les données dans Redis doivent être synchronisées en conséquence. Veuillez faire attention à cela dans les projets réels, qui ne sont pas présentés ici pour le moment)
//用随机值模拟客户,商品,单次购买份数 $uid = rand(1,10); $amount = rand(1,5); $goods_id = rand(1,6); $time = time(); $this->buy($uid , $goods_id , $amount); public function buy($uid , $goods_id , $amount){ //使用行锁. try { $trans = Yii::app()->db->beginTransaction(); $sql = "select stock_avail from sec_goods where id = $goods_id for update"; // $stock_avail = Yii::app()->db->createCommand($sql)->queryScalar(); if( $stock_avail >= $amount ){ //份额足够。 $sn = date("YmdHis")."-".$uid."-".$goods_id.rand(1000,9999); $sql = "insert into sec_order set sn = '$sn',user_id = $uid, goods_id = $goods_id, create_at = $time,num = $amount"; $bool = Yii::app()->db->createCommand($sql)->execute(); if( !$bool ){ throw new Exception("执行失败".$sql); } $sql = "update sec_goods set stock_avail = stock_avail - $amount where id= $goods_id"; $bool = Yii::app()->db->createCommand($sql)->execute(); if( !$bool ){ throw new Exception("执行失败".$sql); } } $trans->commit(); return true; } catch (Exception $e) { //日志记录 $trans->rollback(); return false; } }
Ensuite, utilisez le gadget ab d'Apache pour tester.
-n représente le nombre de requêtes -c représente le nombre de requêtes simultanées à la fois.
(Supprimez la transaction dans le code ci-dessus, et il y aura une explosion lorsque AB s'exécutera. )
En raison de l'utilisation du verrouillage de ligne pour la mise à jour. Sur la base de l'isolement des transactions, elles doivent être exécutées séquentiellement, de sorte que le code ci-dessus ne provoquera pas de survente ou d'explosion des commandes. (11 articles vendus sur 10 articles en stock), mais il y a un problème de performances avec ce code, c'est-à-dire combien de fois
il y a demandes simultanées, combien de fois sera demandé au base de données . Le fragile MySQL s’est effondré rapidement.
3 Terminez le code de vente flash de redis.
//code 3.1 //用随机值模拟客户,商品,单次购买份数 $uid = rand(1,10); $amount = rand(1,5); $goods_id = rand(1,6); $time = time(); //用redis 校验,此次用户是否可以买。(库存是否充足) $redis = self::createRedisObj(); $redis_key = "goods_".$goods_id; $len = $redis->lLen($redis_key); //求队列的长度,也就是商品的库存。 if( $len == 0 ){ exit("抢光了!"); } else if( $len < $amount){ exit("库存不足!"); } //验证通过,开始pop 出队列。 pop 一个,相当于买一个。 for( $i =0 ; $i< $amount;$i++){ $redis->rPop( $redis_key ); } $bool = $this->buy($uid , $goods_id , $amount); if( !$bool ) { //如果购买失败,则把取出的redis 队列的数据,再压回去。(回充库存) for( $i =0 ; $i< $amount;$i++){ $redis->lPush( $redis_key , 1); } } //创建redis 对象的。 private static $_redis = null; /** * 创建一个redis 对象. * @return Redis */ public static function createRedisObj(){ //2017-11-29 改为单例创建模式. if( ! self::$_redis){ $redis = new Redis(); $host = “192.168.1.xx”; $port = "6379"; $redis->connect($host,$port); self::$_redis = $redis; } return self::$_redis; }
-------------------------------------------------------------- --- ----------------------------------------------- ---
Cependant, le phénomène va continuer à évoluer avec les besoins opérationnels.
Donnez-moi juste un exemple.
1 Le produit ne devrait être acheté par un seul utilisateur qu'une seule fois dans un délai de 3 secondes. Aucun produit
//用随机值模拟客户,商品,单次购买份数 $uid = rand(1,10); $amount = rand(1,5); $goods_id = rand(1,6); $time = time(); $redis = self::createRedisObj(); ////////////单用户限3秒内仅允许请求一次/////////////////////////////// $lock_key = "uTimeLimit_".$uid; //按用户名编即可。 如果限用户针对指定商品,则lock_key 按uid+ goods_id 进行唯一编码 if( $redis->get($lock_key)){ $left_time = $redis->ttl($lock_key); exit($expire ."秒内只允许 $tag 一次!请".$left_time."之后再尝试"); }else { $redis->setEx($lock_key , $expire , "1" ); } ////////////////////////////////////////////////////////////////// //用redis 校验,此次用户是否可以买。(库存是否充足) $len = $redis->lLen($redis_key); //求队列的长度,也就是商品的库存。 if( $len == 0 ){ exit("抢光了!"); }else if( $len < $amount){ exit("库存不足!"); }
//用随机值模拟客户,商品,单次购买份数 $uid = rand(1,10); $amount = rand(1,5); $goods_id = rand(1,6); $time = time(); $redis = self::createRedisObj(); ////////////单用户限5个处理/////////////////////////////// //设一个hash 表, "user_buy" 然后 $uid . "_" . $goods_id 来记录购买的份数。 $already_num = $redis->hGet("user_buy",$uid."_".$goods_id)? $redis->hGet("user_buy",$uid."_".$goods_id) :0; //求出已购买份额 if( $already_num +$amount > 5){ exit("单用户单个商品限购买5个");} else{ $new_num = $already_num +$amount ; $redis->hSet("user_buy",$uid."_".$goods_id , $new_num); } ////////////////////////////////////////////////////////////////////用redis 校验,此次用户是否可以买。(库存是否充足) $len = $redis->lLen($redis_key); //求队列的长度,也就是商品的库存。 if( $len == 0 ){ exit("抢光了!"); } else if( $len < $amount){ exit("库存不足!"); }// 后序购买流程。。。。。 //如果购买失败 $redis->hSet( "user_buy",$uid."_".$goods_id , $redis->hGet("user_buy",$uid."_".$goods_id ) - $amount //失败时,则回复hash 表的数值 );
PHP se combine avec Redis pour limiter le nombre de visites par utilisateurs ou IP dans une certaine période de temps
PHP combiné avec la commande Linux cron pour implémenter des exemples de tâches planifiées
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!