HoRain云--PHP+Redis高并发实战指南-洪萨配资

$redis = new Redis(); $redis->connect('127.0.0.1', 6379); // 检查缓存 $key = 'product_' . $productId; $data = $redis->get($key); if ($data) { // 从缓存获取数据 return json_decode($data, true); } else { // 查询数据库 $data = $db->query("SELECT * FROM products WHERE id = $productId"); // 写入缓存，设置过期时间 $redis->setex($key, 300, json_encode($data)); return $data; }

2. 分布式锁防止超卖

function acquireLock($lockKey, $timeout = 5) { $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $lockValue = uniqid() . '_' . microtime(true); $startTime = time(); // 尝试获取锁 while (!$redis->set($lockKey, $lockValue, ['NX', 'EX' => $timeout])) { // 等待锁释放 if (time() - $startTime > $timeout) { return false; // 超时 } usleep(10000); // 等待10ms } return $lockValue; } function releaseLock($lockKey, $lockValue) { $redis = new Redis(); $redis->connect('127.0.0.1', 6379); // Lua脚本确保原子性释放锁 $script = " if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end "; return $redis->eval($script, [$lockKey, $lockValue], 1); } // 使用示例：抢购场景 $lockKey = 'lock_product_' . $productId; $lockValue = acquireLock($lockKey); if ($lockValue) { try { // 检查库存 $stock = $redis->get('stock_' . $productId); if ($stock > 0) { // 减少库存 $redis->decr('stock_' . $productId); // 创建订单 // ... } } finally { releaseLock($lockKey, $lockValue); } }

3. 消息队列异步处理

$redis = new Redis(); $redis->connect('127.0.0.1', 6379); // 生产者：将任务推入队列 $task = [ 'user_id' => $userId, 'product_id' => $productId, 'quantity' => $quantity, 'timestamp' => time() ]; $redis->lPush('order_queue', json_encode($task)); // 消费者：后台进程处理队列 while (true) { $taskJson = $redis->brPop('order_queue', 0); if ($taskJson) { $task = json_decode($taskJson[1], true); // 处理订单逻辑 processOrder($task); } }

4. 会话存储优化

// php.ini配置 session.save_handler = redis session.save_path = "tcp://127.0.0.1:6379?weight=1&timeout=2.5&persistent=1&database=0&prefix=PHPREDIS_SESSION:"

二、性能优化实践

1. Redis连接池配置

; php.ini配置 redis.pconnect.pooling_enabled=1 redis.pconnect.connection_limit=30 redis.session.lock_expire=30

2. 多池隔离不同业务

// 用户中心连接池 $userRedis = new Redis(); $userRedis->pconnect('127.0.0.1', 6379, 2.5, 'pool_user'); // 商品缓存连接池 $goodsRedis = new Redis(); $goodsRedis->pconnect('127.0.0.1', 6379, 2.5, 'pool_goods');

3. Pipeline批量操作

$redis = new Redis(); $redis->connect('127.0.0.1', 6379); $redis->multi(Redis::PIPELINE); for ($i = 0; $i < 100; $i++) { $redis->set("key:$i", "value:$i"); } $results = $redis->exec(); // 一次性执行所有命令

4. 单例模式管理Redis连接

class RedisConnection { private static $instance = null; private $redis; private function __construct() { $this->redis = new Redis(); $this->redis->connect('127.0.0.1', 6379); } public static function getInstance() { if (self::$instance === null) { self::$instance = new self(); } return self::$instance; } public function getRedis() { return $this->redis; } } // 使用 $redis = RedisConnection::getInstance()->getRedis();

三、高并发场景实战：抢购系统

class FlashSale { private $redis; public function __construct() { $this->redis = RedisConnection::getInstance()->getRedis(); } // 初始化库存 public function initStock($productId, $stock) { $this->redis->set("stock:$productId", $stock); $this->redis->del("users:$productId"); // 清空已购买用户列表 } // 检查用户是否已参与 private function isUserParticipated($productId, $userId) { return $this->redis->sIsMember("users:$productId", $userId); } // 抢购核心逻辑 public function buy($productId, $userId) { // 防止重复抢购 if ($this->isUserParticipated($productId, $userId)) { return ['success' => false, 'msg' => '您已参与过本次抢购']; } // Lua脚本保证原子性 $script = " local stock = tonumber(redis.call('get', KEYS[1])) if stock and stock > 0 then redis.call('decr', KEYS[1]) redis.call('sadd', KEYS[2], ARGV[1]) return 1 end return 0 "; $result = $this->redis->eval( $script, ["stock:$productId", "users:$productId"], 2, $userId ); if ($result == 1) { // 异步创建订单 $this->createOrderAsync($productId, $userId); return ['success' => true, 'msg' => '抢购成功']; } else { return ['success' => false, 'msg' => '库存不足']; } } // 异步创建订单 private function createOrderAsync($productId, $userId) { $task = [ 'type' => 'create_order', 'product_id' => $productId, 'user_id' => $userId, 'time' => time() ]; $this->redis->lPush('order_tasks', json_encode($task)); } }

四、监控与调优

// 监控连接状态 function monitorRedis() { $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $info = $redis->info('clients'); echo "当前连接数: " . $info['connected_clients'] . "\n"; $stats = $redis->info('stats'); echo "总连接数: " . $stats['total_connections_received'] . "\n"; echo "命令处理数: " . $stats['total_commands_processed'] . "\n"; }