``` ~~~ <?php namespace app\common\service; use think\Exception; /** * Class RedisLimit * @package app\common\service * redis 簡單限流 */ class RedisLimit { /** * @var int */ static $oneITime = 60; // 單位時間 一分鐘 /** * @var int */ static $oneIMax = 50; // 一個用戶Ip一分鐘最多僅允許訪問訪問10次 /** * @var int */ static $platITime = 60; // 針對所有用戶，單位時間內允許訪問的最大次數 /** * @var int */ static $platIMax = 10; // 針對所有的用戶,該接口最多僅允許訪問N次 /** * Redis配置：IP */ const REDIS_CONFIG_HOST = '127.0.0.1'; /** * Redis配置：端口 */ const REDIS_CONFIG_PORT = 6379; const KEY='RT_DS8dsad845*/-sda'; /** * @return \think\response\Json * @throws Exception * 限制全局請求 */ public static function redis_lock_all_limit() { $redis = self::getRedisConn(); //.... 針對平臺全局鎖，用于限制單位時間內所有用戶訪問的次數 $platKey = md5(request()->url()); $platFlowCount = $redis->get($platKey);// 平臺訪問次數 if($platFlowCount){ if($platFlowCount >= self::$platIMax){ return json(['code'=>0,'msg'=>'超過訪問次數']); } } $redis->incr($platKey);// ++1 次訪問次數 !$platFlowCount && $redis->expire($platKey,self::$platITime); // 設置鎖的有效時間 return json(['code'=>1,'msg'=>'通過']); } /** * @param $mer_no * @param $oneITime * @param $oneIMax * @return bool * @throws Exception */ public static function redis_lock_single_limit($mer_no,$oneITime,$oneIMax) { $redis = self::getRedisConn(); // ... 針對單個商戶戶實現的訪問鎖 $key = md5($mer_no.':'.self::KEY); $userFlowCount = $redis->get($key); // 單個用戶訪問次數 if($userFlowCount){ if($userFlowCount >= $oneIMax){ return false; } } $redis->incr($key);// ++1 次訪問次數 !$userFlowCount && $redis->expire($key,$oneITime);// 設置鎖的有效時間 return true; } /** * @param string $strIp * @param int $intPort * @return \Redis * @throws Exception */ public static function getRedisConn($strIp = self::REDIS_CONFIG_HOST, $intPort = self::REDIS_CONFIG_PORT) { try { if (!extension_loaded('redis')) { throw new \BadFunctionCallException('not support: redis'); } $objRedis = new \Redis(); $objRedis->connect($strIp, $intPort); return $objRedis; }catch (Exception $exception){ throw new Exception($exception->getMessage()); } } } ~~~ ```