129 lines
3.2 KiB
PHP
129 lines
3.2 KiB
PHP
<?php
|
|
|
|
namespace traits;
|
|
use addons\shopro\exception\Exception;
|
|
use addons\shopro\library\Redis;
|
|
use addons\shopro\model\Activity;
|
|
use addons\shopro\model\ActivityGoodsSkuPrice;
|
|
use addons\shopro\model\Goods;
|
|
use addons\shopro\model\GoodsSkuPrice;
|
|
use addons\shopro\model\OrderItem;
|
|
use addons\shopro\model\ScoreGoodsSkuPrice;
|
|
|
|
/**
|
|
* 缓存
|
|
*/
|
|
trait CacheTrait
|
|
{
|
|
|
|
|
|
private $cache_lock_error_msg = "获取锁失败！";
|
|
|
|
private $cache_lock_thorws_excption = true;
|
|
|
|
public function setCacheLockThorwsExcption($cache_lock_thorws_excption){
|
|
$this->cache_lock_thorws_excption = $cache_lock_thorws_excption;
|
|
return $this;
|
|
}
|
|
|
|
|
|
public function getCacheLockThorwsExcption(){
|
|
return $this->cache_lock_thorws_excption;
|
|
}
|
|
|
|
|
|
|
|
|
|
public function hasRedis($is_interrupt = false) {
|
|
$error_msg = '';
|
|
try {
|
|
$redis = $this->getRedis();
|
|
|
|
// 检测连接是否正常
|
|
$redis->ping();
|
|
} catch (\BadFunctionCallException $e) {
|
|
// 缺少扩展
|
|
$error_msg = $e->getMessage() ? $e->getMessage() : "缺少 redis 扩展";
|
|
} catch (\RedisException $e) {
|
|
// 连接拒绝
|
|
\think\Log::write('redis connection redisException fail: ' . $e->getMessage());
|
|
$error_msg = $e->getMessage() ? $e->getMessage() : "redis 连接失败";
|
|
} catch (\Exception $e) {
|
|
// 异常
|
|
\think\Log::write('redis connection fail: ' . $e->getMessage());
|
|
$error_msg = $e->getMessage() ? $e->getMessage() : "redis 连接异常";
|
|
}
|
|
|
|
if ($error_msg) {
|
|
if ($is_interrupt || $this->cache_lock_thorws_excption) {
|
|
throw new \Exception($error_msg);
|
|
} else {
|
|
$this->setCacheLockErrorMsg($error_msg);
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
|
|
public function getRedis() {
|
|
if (!isset($GLOBALS['SPREDIS'])) {
|
|
$GLOBALS['SPREDIS'] = (new Redis())->getRedis();
|
|
}
|
|
|
|
return $GLOBALS['SPREDIS'];
|
|
}
|
|
|
|
|
|
|
|
public function getLock($key,$suffix = "-lock-suffix", $timeout = 120){
|
|
$this->hasRedis(true);
|
|
$redis = $this->getRedis();
|
|
$hashKey = $key.$suffix;
|
|
// $redis->del($hashKey);
|
|
//判断锁是否存在，如果存在，返回错误
|
|
if ($redis->EXISTS($hashKey)){
|
|
if($this->cache_lock_thorws_excption){
|
|
throw new \Exception($this->cache_lock_error_msg);
|
|
}else{
|
|
return false;
|
|
}
|
|
|
|
}
|
|
//如果不存在创建锁并返回
|
|
$redis->set($hashKey, 1,$timeout);
|
|
return true;
|
|
}
|
|
|
|
|
|
public function setCacheLockErrorMsg($cache_lock_error_msg){
|
|
$this->cache_lock_error_msg = $cache_lock_error_msg;
|
|
return $this;
|
|
}
|
|
|
|
|
|
public function getCacheLockErrorMsg(){
|
|
return $this->cache_lock_error_msg;
|
|
}
|
|
|
|
|
|
public function freeLock($key,$suffix = "-lock-suffix"){
|
|
$this->hasRedis(true);
|
|
$redis = $this->getRedis();
|
|
if(!$key || !$suffix) return true;
|
|
$hashKey = $key.$suffix;
|
|
if (!$redis->EXISTS($hashKey)) return true;
|
|
$redis->del($hashKey);
|
|
return true;
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|