redis案例 -- 商品拍卖
Posted FcLwYf
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了redis案例 -- 商品拍卖相关的知识,希望对你有一定的参考价值。
代码说明:在小程序上进行商品拍卖,多人抢拍,零秒抢拍,用redis(事物)来确认抢拍价格的准确性,什么不说了,附上代码!
/** * 加价 */ public function plusPrice(){ $member_id = $this->userInfo[‘member_id‘]>0 ? $this->userInfo[‘member_id‘] : 0; $mobile = $this->userInfo[‘member_name‘]>0 ? $this->userInfo[‘member_name‘] : 0; $lb_id = input(‘lb_id‘,0); $every_hand = input(‘price‘,0); // 每一手 $goods_id = input(‘goods_id‘,0); $nickname = input(‘nickname‘,‘‘); $avatar = input(‘avatar‘,‘‘); $msg_type = input(‘msg_type‘,‘morker‘); $this->redis->set(‘msgType‘,$msg_type); // 判断参数 if($lb_id<=0) { $this->returnmsg(‘2055‘, ‘直播ID不能为空‘); } if($goods_id<=0) { $this->returnmsg(‘2055‘, ‘商品ID不能为空‘); } if($member_id<=0) { $this->returnmsg(‘2055‘, ‘会员ID不能为空‘); } // redis事物控制价格不出问题 $thing_key = ‘wxGoodsPlusPrice‘; $this->redis->setex($thing_key, 60); //监视keyTest $this->redis->watch(array($thing_key)); $plus_max_price_key = ‘plusMaxPrices:‘.$lb_id.‘:‘.$goods_id; $iag_key = ‘setAuctionGoods:‘.$lb_id; $iag_g_info_json = $this->redis->get($iag_key); $iag_g_info = json_decode($iag_g_info_json,true); $plus_max_prices = $this->redis->lRange($plus_max_price_key,0,-1); $max_price = max($plus_max_prices)>0 ? max($plus_max_prices) : $iag_g_info[‘starting_price‘]; // 当没有最大价格时,取起拍价 $price = $max_price + $every_hand; //开启事务 $this->redis->multi(); $this->redis->incr($thing_key); $this->redis->lPush($plus_max_price_key,$price); //执行事务 $result = $this->redis->exec(); // 这里很重要,后续代码一定要在事物完成这个判断里进行 , // 要不然,就会出现数据错乱的问题 if($result){ $auction_goods_id_key = ‘auctionGoodsId:‘.$lb_id; $auction_goods_id = $this->redis->get($auction_goods_id_key); if(empty($auction_goods_id)){ $this->redis->lPop($plus_max_price_key); $this->returnmsg(‘2055‘, ‘拍卖结束‘); } // 把价格重新保存一下 if($price<=$max_price){ $this->redis->lPop($plus_max_price_key); $this->returnmsg(‘2055‘, ‘不是最高价‘); } // 加入数据 $max_price_uinfo_key = ‘maxPriceUinfoKey:‘.$lb_id.‘-‘.$goods_id; $old_max_price_uinfo_json = $this->redis->get($max_price_uinfo_key); $old_max_price_uinfo = json_decode($old_max_price_uinfo_json,true); if($old_max_price_uinfo[‘user_id‘] == $member_id){ $this->redis->lPop($plus_max_price_key); $this->returnmsg(‘2055‘, ‘您已经领先了‘); } // 判断不要重复数据 $unique_price_key = ‘unique_price_key:‘.$lb_id.‘:‘.$goods_id; $price_arr = $this->redis->lRange($unique_price_key,0,-1); if(!in_array($price,$price_arr)){ $this->redis->lPush($unique_price_key,$price); $max_price_uinfo = array( ‘user_id‘=>$member_id, ‘mobile‘=>$mobile, ‘max_price‘=>$price, ‘goods_id‘=>$goods_id, ‘lb_id‘=>$lb_id, ‘nickname‘=>$nickname, ‘new_avatar‘=>$avatar ); $this->redis->set($max_price_uinfo_key,json_encode($max_price_uinfo,true)); $plus_max_price_mtime_key = ‘plusMaxMtimePrices:‘.$lb_id.‘:‘.$goods_id; $this->redis->lPush($plus_max_price_mtime_key,$member_id.‘--‘.$price.‘--‘.$max_price.‘--‘.microtime(1)); $mq_plus_price_consumption_key = ‘mq_plus_price_consumption‘; $this->redis->lPush($mq_plus_price_consumption_key,json_encode($max_price_uinfo,true)); // QueueClient::push(new LiveImSendMsgProcessQueue(), [‘reset_name‘ => [‘live_im_send_msg‘],‘lb_id‘=>$lb_id,‘user_id‘=>$member_id,‘price‘=>$price]); } } $this->returnmsg(‘200‘, ‘success‘); }
以上是关于redis案例 -- 商品拍卖的主要内容,如果未能解决你的问题,请参考以下文章
2022年11月 .NET CORE工具案例-StackExchange.Redis代码变量方式实现商品秒杀
#yyds干货盘点#愚公系列2023年03月 .NET CORE工具案例-StackExchange.Redis代码变量方式实现商品秒杀