Dieser Artikel stellt hauptsächlich den Implementierungscode von thinkphp+redis+queue vor. Ich werde ihn jetzt mit Ihnen teilen und als Referenz verwenden. Lassen Sie uns dem Editor folgen und einen Blick darauf werfen.
1. Installieren Sie Redis und installieren Sie die entsprechende Redis-Erweiterung entsprechend Ihrer PHP-Version (dieser Schritt wird kurz beschrieben). php_redis.dll-Erweiterung Hier müssen Sie auf Ihre PHP-Version achten, wie in der Abbildung gezeigt:
1.2, fügen Sie extension=php_igbinary.dll;extension=php_redis.dll hinzu die php.ini-Datei.
ok Der erste Schritt der Redis-Umgebungskonstruktion ist abgeschlossen.
Redis ist tatsächlich im Projekt verwendet
2.1 Der erste Schritt besteht darin, die Redis-Parameter wie folgt zu konfigurieren. Der Standardport für die Redis-Installation ist 6379:
2.2. Verwenden Sie Redis in der eigentlichen Funktion:
<?php
/* 数据库配置 */
return array(
'DATA_CACHE_PREFIX' => 'Redis_',//缓存前缀
'DATA_CACHE_TYPE'=>'Redis',//默认动态缓存为Redis
'DATA_CACHE_TIMEOUT' => false,
'REDIS_RW_SEPARATE' => true, //Redis读写分离 true 开启
'REDIS_HOST'=>'127.0.0.1', //redis服务器ip，多台用逗号隔开；读写分离开启时，第一台负责写，其它[随机]负责读；
'REDIS_PORT'=>'6379',//端口号
'REDIS_TIMEOUT'=>'300',//超时时间
'REDIS_PERSISTENT'=>false,//是否长连接 false=短连接
'REDIS_AUTH'=>'',//AUTH认证密码
);
?>
Nach dem Login kopieren
2.3, das Kernproblem von Flash-Verkäufen besteht darin, den Bestandskauf nicht zu überschreiten Im Falle einer großen Parallelität ist dies der Schlüssel zur Verarbeitung. Führen Sie in der Flash-Sale-Kategorie zunächst einige grundlegende Datengenerierungen durch:
/**
* redis连接
* @access private
* @return resource
* @author bieanju
*/
private function connectRedis(){
$redis=new \Redis();
$redis->connect(C("REDIS_HOST"),C("REDIS_PORT"));
return $redis;
}Nach dem Login kopieren
2.4. Der zweite Schritt ist der Schlüssel. Der Benutzer betritt zuerst die aktuelle Produktdetailseite und speichert ihn wie folgt in der Warteschlange:
//现在初始化里面定义后边要使用的redis参数
public function _initialize(){
parent::_initialize();
$goods_id = I("goods_id",'0','intval');
if($goods_id){
$this->goods_id = $goods_id;
$this->user_queue_key = "goods_".$goods_id."_user";//当前商品队列的用户情况
$this->goods_number_key = "goods".$goods_id;//当前商品的库存队列
}
$this->user_id = $this->user_id ? $this->user_id : $_SESSION['uid'];
}Nach dem Login kopieren
Als nächstes müssen Sie Ajax verwenden, um den Klick des Benutzers auf die Kaufschaltfläche asynchron zu verarbeiten, um die Bedingungen zu erfüllen. Die Daten gelangen in die Kaufwarteschlange (wenn sich der aktuelle Benutzer nicht in der Warteschlange des aktuellen Produkts befindet). Benutzer, es tritt in die Warteschlange ein und öffnet eine Inventarwarteschlange. Wenn dies der Fall ist, wirft es sie aus:
/**
* 访问产品前先将当前产品库存队列
* @access public
* @author bieanju
*/
public function _before_detail(){
$where['goods_id'] = $this->goods_id;
$where['start_time'] = array("lt",time());
$where['end_time'] = array("gt",time());
$goods = M("goods")->where($where)->field('goods_num,start_time,end_time')->find();
!$goods && $this->error("当前秒杀已结束！");
if($goods['goods_num'] > $goods['order_num']){
$redis = $this->connectRedis();
$getUserRedis = $redis->hGetAll("{$this->user_queue_key}");
$gnRedis = $redis->llen("{$this->goods_number_key}");
/* 如果没有会员进来队列库存 */
if(!count($getUserRedis) && !$gnRedis){
for ($i = 0; $i < $goods['goods_num']; $i ++) {
$redis->lpush("{$this->goods_number_key}", 1);
}
}
$resetRedis = $redis->llen("{$this->goods_number_key}");
if(!$resetRedis){
$this->error("系统繁忙，请稍后抢购！");
}
}else{
$this->error("当前产品已经秒杀完！");
}
}Nach dem Login kopieren
Fügen Sie eine Debug-Funktion hinzu, um die zu löschen angegebener Warteschlangenwert:
/**
* 抢购商品前处理当前会员是否进入队列
* @access public
* @author bieanju
*/
public function goods_number_queue(){
!$this->user_id && $this->ajaxReturn(array("status" => "-1","msg" => "请先登录"));
$model = M("flash_sale");
$where['goods_id'] = $this->goods_id;
$goods_info = $model->where($where)->find();
!$goods_info && $this->error("对不起当前商品不存在或已下架！");
/* redis 队列 */
$redis = $this->connectRedis();
/* 进入队列 */
$goods_number_key = $redis->llen("{$this->goods_number_key}");
if (!$redis->hGet("{$this->user_queue_key}", $this->user_id)) {
$goods_number_key = $redis->lpop("{$this->goods_number_key}");
}
if($goods_number_key){
// 判断用户是否已在队列
if (!$redis->hGet("{$this->user_queue_key}", $this->user_id)) {
// 插入抢购用户信息
$userinfo = array(
"user_id" => $this->user_id,
"create_time" => time()
);
$redis->hSet("{$this->user_queue_key}", $this->user_id, serialize($userinfo));
$this->ajaxReturn(array("status" => "1"));
}else{
$modelCart = M("cart");
$condition['user_id'] = $this->user_id;
$condition['goods_id'] = $this->goods_id;
$condition['prom_type'] = 1;
$cartlist = $modelCart->where($condition)->count();
if($cartlist > 0){
$this->ajaxReturn(array("status" => "2"));
}else{
$this->ajaxReturn(array("status" => "1"));
}
}
}else{
$this->ajaxReturn(array("status" => "-1","msg" => "系统繁忙,请重试！"));
}
}Nach dem Login kopieren
Das obige ist der detaillierte Inhalt vonBeispielcode für die Implementierung von Thinkphp und Redis+Queue (Bild). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
