CodeIgniter并发注册：利用数据库表锁解决邮箱重复问题

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

class Auth_model extends CI_Model {

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

    /**
     * 尝试注册新用户，通过数据库表锁防止并发邮箱重复。
     *
     * @param string $username 用户名
     * @param string $email 邮箱
     * @param string $password 密码
     * @return array 注册结果，包含状态和消息
     */
    public function register_user($username, $email, $password) {
        // 确保在所有可能的退出路径上都释放锁，避免死锁
        try {
            // 1. 获取用户表的写锁
            // 注意：LOCK TABLES 语句是数据库特定的，这里以MySQL为例。
            // 确保您的数据库用户有LOCK TABLES权限。
            $this->db->query("LOCK TABLES users WRITE");

            // 2. 执行邮箱存在性检查
            $this->db->where('email', $email);
            $query = $this->db->get('users');

            if ($query->num_rows() > 0) {
                // 邮箱已存在，释放锁并返回错误
                return ['status' => 'error', 'message' => '该邮箱已被注册。'];
            } else {
                // 邮箱唯一，进行用户数据插入
                $data = [
                    'username' => $username,
                    '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) {
                    return ['status' => 'success', 'message' => '注册成功！'];
                } else {
                    return ['status' => 'error', 'message' => '注册失败，请稍后再试。'];
                }
            }
        } catch (Exception $e) {
            // 捕获可能发生的数据库或其他异常，并记录日志
            log_message('error', '用户注册过程中发生异常: ' . $e->getMessage());
            return ['status' => 'error', 'message' => '系统错误，注册失败。'];
        } finally {
            // 3. 无论操作成功、失败或异常，都必须释放锁
            $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('Auth_model');
        $this->load->helper('form');
        $this->load->library('form_validation');
    }

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

        // 可以添加其他表单验证规则，例如密码长度等
        $this->form_validation->set_rules('username', '用户名', 'required');
        $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_view', ['errors' => validation_errors()]);
        } else {
            // 调用模型方法进行注册
            $result = $this->Auth_model->register_user($username, $email, $password);

            if ($result['status'] === 'success') {
                // 注册成功，重定向或显示成功消息
                $this->session->set_flashdata('success_message', $result['message']);
                redirect('auth/login');
            } else {
                // 注册失败，显示错误消息
                $this->load->view('register_form_view', ['errors' => $result['message']]);
            }
        }
    }
}