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 用户的密码
     * @return array 包含注册状态和消息的数组
     */
    public function registerUserWithLock($email, $password) {
        // 1. 获取目标表的写锁
        // 注意：这将锁定整个'users'表，阻止其他会话对该表进行读写，直到锁被释放。
        // 这是一种粗粒度锁，在高并发场景下可能成为性能瓶颈。
        $this->db->query("LOCK TABLES users WRITE");

        try {
            // 2. 检查邮箱是否存在
            $this->db->where('email', $email);
            $query = $this->db->get('users');

            if ($query->num_rows() > 0) {
                // 邮箱已存在，释放锁并返回错误
                $this->db->query("UNLOCK TABLES");
                return ['status' => 'error', 'message' => '该邮箱已被注册。'];
            } else {
                // 3. 插入新用户数据
                $data = [
                    'email' => $email,
                    'password' => password_hash($password, PASSWORD_DEFAULT), // 建议使用密码哈希
                    'created_at' => date('Y-m-d H:i:s')
                    // ... 其他用户数据
                ];
                $this->db->insert('users', $data);

                if ($this->db->affected_rows() > 0) {
                    // 插入成功，释放锁并返回成功
                    $this->db->query("UNLOCK TABLES");
                    return ['status' => 'success', 'message' => '用户注册成功。'];
                } else {
                    // 插入失败，释放锁并返回错误
                    $this->db->query("UNLOCK TABLES");
                    return ['status' => 'error', 'message' => '用户注册失败，请重试。'];
                }
            }
        } catch (Exception $e) {
            // 捕获任何异常，确保在任何情况下都释放锁，避免死锁
            $this->db->query("UNLOCK TABLES");
            // 记录错误或进行其他处理
            log_message('error', '用户注册发生异常: ' . $e->getMessage());
            return ['status' => 'error', 'message' => '注册过程中发生未知错误。'];
        }
    }
}

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

class Register extends CI_Controller {

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

    public function index() {
        // 加载注册表单视图
        $this->load->view('register_form');
    }

    public function submit() {
        $this->form_validation->set_rules('email', '邮箱', 'required|valid_email');
        $this->form_validation->set_rules('password', '密码', 'required|min_length[6]');

        if ($this->form_validation->run() == FALSE) {
            // 表单验证失败，重新加载视图并显示错误
            $this->load->view('register_form');
        } else {
            $email = $this->input->post('email');
            $password = $this->input->post('password');

            $result = $this->UserModel->registerUserWithLock($email, $password);

            if ($result['status'] == 'success') {
                // 注册成功，重定向或显示成功消息
                echo "注册成功: " . $result['message'];
            } else {
                // 注册失败，显示错误消息
                echo "注册失败: " . $result['message'];
            }
        }
    }
}