CodeIgniter并发注册场景下电子邮件唯一性处理：避免竞态条件

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class UserModel extends CI_Model {

    public function __construct() {
        parent::__construct();
        $this->load->database();
    }

    /**
     * 注册新用户，确保电子邮件唯一性，不依赖数据库唯一索引。
     *
     * @param string $email 用户的电子邮件地址
     * @param string $password 用户的密码
     * @param array $additional_data 其他用户数据
     * @return bool 注册成功返回 true，否则返回 false
     */
    public function registerUserUniqueEmail($email, $password, $additional_data = array()) {
        // 1. 获取用户表的写锁
        // 这将阻止其他会话对 'users' 表进行任何读写操作，直到锁被释放。
        // 注意：这会影响并发性能，应谨慎使用并尽快释放。
        $this->db->query("LOCK TABLES users WRITE");

        try {
            // 2. 在锁定的状态下，检查电子邮件是否已存在
            $query = $this->db->get_where('users', array('email' => $email));

            if ($query->num_rows() > 0) {
                // 电子邮件已存在，释放锁并返回失败
                $this->db->query("UNLOCK TABLES");
                log_message('info', 'Registration attempt with existing email: ' . $email);
                return false;
            }

            // 3. 电子邮件唯一，准备插入数据
            $data = array_merge($additional_data, array(
                'email' => $email,
                'password' => password_hash($password, PASSWORD_DEFAULT), // 推荐使用强密码哈希
                'created_at' => date('Y-m-d H:i:s')
            ));

            // 4. 插入新用户数据
            $insert_result = $this->db->insert('users', $data);

            if ($insert_result) {
                log_message('info', 'User registered successfully: ' . $email);
                return true;
            } else {
                log_message('error', 'Failed to insert user data for email: ' . $email);
                return false;
            }

        } catch (Exception $e) {
            // 捕获异常，确保在任何错误发生时都能释放锁
            log_message('error', 'Error during user registration: ' . $e->getMessage());
            return false;
        } finally {
            // 5. 无论成功或失败，最终都要释放锁
            // 即使在 try 或 catch 块中提前返回，finally 块也会执行。
            $this->db->query("UNLOCK TABLES");
        }
    }
}

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class Auth extends CI_Controller {

    public function __construct() {
        parent::__construct();
        $this->load->model('UserModel');
        $this->load->library('form_validation');
    }

    public function register() {
        // 假设表单提交的数据
        $email = $this->input->post('email');
        $password = $this->input->post('password');
        $confirm_password = $this->input->post('confirm_password');

        // 表单验证规则 (基本的，不涉及数据库唯一性检查)
        $this->form_validation->set_rules('email', 'Email', 'required|valid_email');
        $this->form_validation->set_rules('password', 'Password', 'required|min_length[6]');
        $this->form_validation->set_rules('confirm_password', 'Confirm Password', 'required|matches[password]');

        if ($this->form_validation->run() == FALSE) {
            // 验证失败，显示错误
            $this->load->view('register_form_view'); // 假设有注册表单视图
        } else {
            // 表单验证通过，尝试注册用户
            $additional_data = array(
                // 可以从表单获取其他字段，例如用户名、姓名等
                'username' => $this->input->post('username')
            );

            if ($this->UserModel->registerUserUniqueEmail($email, $password, $additional_data)) {
                // 注册成功
                echo "Registration successful!";
                // 重定向到登录页或用户中心
            } else {
                // 注册失败（可能是电子邮件已存在或数据库错误）
                echo "Registration failed. Email might already be in use or an error occurred.";
            }
        }
    }
}