基于MariaDB集群的自定义PHP Session Handler锁实现方案求问

针对Galera集群不支持GET_LOCK、事务提交会释放行锁的问题，以下是几种可行的锁实现方案：

方案一：乐观锁+版本号控制 #

适合并发量较低的场景，通过版本号冲突检测实现并发控制，无需显式锁。

实现步骤 #

1. 表结构设计（InnoDB引擎）：

CREATE TABLE sessions (
    id VARCHAR(128) PRIMARY KEY,
    data TEXT NOT NULL,
    version INT UNSIGNED NOT NULL DEFAULT 1,
    expire_time DATETIME NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

2. Session Handler核心方法实现：
   • read($session_id)：读取session数据和版本号

     public function read($session_id) {
         $stmt = $this->db->prepare("SELECT data, version FROM sessions WHERE id = ? AND expire_time > NOW()");
         $stmt->execute([$session_id]);
         $result = $stmt->fetch(PDO::FETCH_ASSOC);
         return $result ? $result['data'] : '';
     }
     

   • write($session_id, $data)：更新时校验版本号，冲突则重试

     public function write($session_id, $data) {
         $expire = date('Y-m-d H:i:s', time() + $this->max_lifetime);
         $retry = 3; // 重试次数
         while ($retry--) {
             // 先读取当前版本号
             $stmt = $this->db->prepare("SELECT version FROM sessions WHERE id = ? AND expire_time > NOW()");
             $stmt->execute([$session_id]);
             $current_version = $stmt->fetchColumn();
     
             if ($current_version) {
                 // 已有session，更新时校验版本
                 $stmt = $this->db->prepare("UPDATE sessions SET data = ?, version = version + 1, expire_time = ? WHERE id = ? AND version = ?");
                 $stmt->execute([$data, $expire, $session_id, $current_version]);
                 if ($stmt->rowCount() > 0) {
                     return true;
                 }
             } else {
                 // 新session，直接插入
                 $stmt = $this->db->prepare("INSERT INTO sessions (id, data, expire_time) VALUES (?, ?, ?)");
                 if ($stmt->execute([$session_id, $data, $expire])) {
                     return true;
                 }
             }
             usleep(100000); // 等待100毫秒后重试
         }
         return false;
     }
     

优缺点 #

• 优点：无死锁风险，适配Galera集群；不需要事务，实现简单。
• 缺点：高并发下重试次数增加，可能影响性能；无法完全避免并发写入冲突（仅通过重试缓解）。

方案二：事务绑定Session生命周期+行锁 #

将整个Session操作周期（open→read→write→close）绑定到同一个数据库事务中，利用InnoDB行锁保持独占锁直到事务提交。

实现步骤 #

1. 表结构设计（InnoDB引擎）：

CREATE TABLE sessions (
    id VARCHAR(128) PRIMARY KEY,
    data TEXT NOT NULL,
    expire_time DATETIME NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

2. Session Handler核心方法实现：
   • open()：开启事务

     public function open($save_path, $session_name) {
         $this->db->beginTransaction();
         return true;
     }
     

   • read($session_id)：加行锁读取数据

     public function read($session_id) {
         $stmt = $this->db->prepare("SELECT data FROM sessions WHERE id = ? AND expire_time > NOW() FOR UPDATE");
         $stmt->execute([$session_id]);
         $data = $stmt->fetchColumn();
         return $data ? $data : '';
     }
     

   • write($session_id, $data)：在事务内更新数据（行锁仍持有）

     public function write($session_id, $data) {
         $expire = date('Y-m-d H:i:s', time() + $this->max_lifetime);
         $stmt = $this->db->prepare("REPLACE INTO sessions (id, data, expire_time) VALUES (?, ?, ?)");
         return $stmt->execute([$session_id, $data, $expire]);
     }
     

   • close()：提交事务释放锁

     public function close() {
         $this->db->commit();
         return true;
     }
     

   • 异常处理：如果脚本崩溃，InnoDB会自动回滚事务，释放行锁。

注意事项 #

• 必须确保open到close的整个流程在同一个事务中，禁止中途手动提交事务。
• 合理设置请求超时时间，避免长时间持有锁导致并发请求阻塞。
• Galera集群下需保证session_id全局唯一（PHP默认生成的随机ID满足要求）。

优缺点 #

• 优点：完全模拟文件Session的flock()独占锁语义，并发控制可靠；适配Galera集群。
• 缺点：请求处理时间过长会占用锁资源，影响并发性能；依赖事务的正确管理，异常场景需额外处理。

方案三：Redis分布式锁辅助（可选） #

如果允许引入Redis组件，可以用Redis实现分布式锁，Session数据仍存储在MariaDB中，规避数据库锁的限制。

实现步骤 #

1. 获取锁：使用Redis的SET命令加锁，设置过期时间防止死锁

   private function acquireLock($session_id) {
       $lockKey = "session_lock:$session_id";
       // 设置锁过期时间为30秒，防止脚本崩溃导致锁无法释放
       return $this->redis->set($lockKey, 1, ['NX', 'EX' => 30]);
   }
   

2. 自旋等待锁：

   private function waitForLock($session_id) {
       $timeout = 5; // 最大等待5秒
       $startTime = time();
       while (time() - $startTime < $timeout) {
           if ($this->acquireLock($session_id)) {
               return true;
           }
           usleep(100000);
       }
       return false;
   }
   

3. Session读写：获取锁后读取/写入MariaDB，完成后释放锁

   public function write($session_id, $data) {
       if (!$this->waitForLock($session_id)) {
           return false;
       }
       // 执行MariaDB写入操作
       $expire = date('Y-m-d H:i:s', time() + $this->max_lifetime);
       $stmt = $this->db->prepare("REPLACE INTO sessions (id, data, expire_time) VALUES (?, ?, ?)");
       $result = $stmt->execute([$session_id, $data, $expire]);
       // 释放锁
       $this->redis->del("session_lock:$session_id");
       return $result;
   }
   

优缺点 #

• 优点：锁性能高，适合高并发场景；不依赖数据库锁机制，完全适配Galera集群。
• 缺点：需要额外部署Redis组件，增加系统复杂度；需处理Redis单点故障风险（可采用Redis集群）。

内容的提问来源于stack exchange，提问作者Greenflash