CakePHP 2.0 中的并发请求问题

问题描述

预先感谢您尝试帮助我解决这个问题。

我使用的是 CakePHP 2 (2.10.22)。我有一个创建应用程序的系统。创建的每个应用程序都有一个唯一的应用程序编号。存储此应用程序编号的 MysqL 数据库列设置为“非空”和“唯一”。我正在使用 CakePHP 从数据库中获取上次使用的应用程序编号，然后为需要创建的新应用程序构建下一个应用程序编号。当在给定时间点收到单个请求时，我编写的过程没有任何问题。当同时收到两个创建应用程序的请求时，就会出现问题。我观察到的行为是首先接收的请求获得最后一个申请号 - 例如ABC001233 并将 ABC001234 指定为它需要创建的新应用程序的应用程序编号。它成功地将此应用程序保存到数据库中。并发运行的第二个请求也将 ABC001233 作为最后一个应用程序编号，并尝试创建一个以 ABC001234 作为应用程序编号的新应用程序。 MysqL 数据库返回错误，指出应用程序编号不唯一。然后我将第二个请求休眠 2 秒，此时第一个应用程序已成功保存到数据库中。然后，我重新尝试应用程序创建过程，该过程首先获取最后一个应用程序编号，该编号应该是 ABC001234，但即使第一个请求早已完成，每次读取数据库仍会返回 ABC001233。这两个请求在控制器中都有事务。我注意到的是，当我删除这些交易时，该过程在第一次尝试失败后的第二次请求中正常工作，第二次尝试正常工作，因为系统正确地将 ABC001234 作为最后一个申请编号，并将 ABC001235 分配为新申请数字。我想知道我需要做什么以确保即使在控制器中有事务指令时流程也能正常工作。

请在下面找到有关代码结构的一些基本信息 -

数据库

The last application number is ABC001233

控制器文件

function create_application(){

    $db_source->begin(); //The process works correctly if I remove this line.

    $result = $Application->create_new();

    if($result === true){
        $db_source->commit();
    )else{
        $db_source->rollback();
    }

}

应用模型文件

function get_new_application_number(){

    $application_record = $this->find('first',[
        'order'=>[
            $this->name.'.application_number DESC'
        ],'fields'=>[
            $this->name.'.application_number'
        ]
    ]);

    $old_application_number = $application_record[$this->name]['application_number'];
    $new_application_number = $old_application_number+1;

    return $new_application_number;

}

以上是我觉得问题的根源。对于接收到的第一个请求，此查找正确地发现 ABC001233 是最后一个申请号，然后此函数返回 ABC001234 作为下一个申请号。对于第二个请求，它还会选择 ABC001233 作为最后一个申请编号，但是当它尝试将 ABC001234 保存为申请编号时会失败，因为第一个请求已经使用该编号保存了一个申请。作为第二次请求的第二次尝试（由于 do/while 循环而发生）的一部分，再次请求此查找，但不是返回 ABC001234 作为最后一个应用程序编号（根据第一个请求的成功保存），它不断返回 ABC001233 导致无法正确保存。如果我从控制器中删除事务，那么它会在第二次尝试中返回 ABC001234 的地方正常工作。我找不到任何关于为什么会这样以及可以做些什么以及我需要一些帮助的地方的文档。谢谢！



function create_new(){

    $new_application_number = $this->get_new_application_number();

    $save_attempts = 0;

    do{

        $save_exception = false;

        try{


            $result = $this->save([$this->name=>['application_number'=>$new_application_number]],[
                'atomic'=>false
            ]);

        }catch(Exception $e){

            $save_exception = true;
            sleep(2);
            $new_application_number = $this->get_new_application_number();

        }

    }while($save_exception === true && $save_attempts++<5);

    return !$save_exception;

}

解决方法

您只需要在事务中使用 SELECT ... FOR UPDATE 锁定具有前一个数字的行。它比评论中所说的整个表锁要好得多。根据文档 https://book.cakephp.org/2/en/models/retrieving-your-data.html，您只需将 'lock' => true 添加到 get_new_application_number 函数：

function get_new_application_number(){

$application_record = $this->find('first',[
    'order'=>[
        $this->name.'.application_number DESC'
    ],'fields'=>[
        $this->name.'.application_number'
    ],'lock'=>true
]);

$old_application_number = $application_record[$this->name]['application_number'];
$new_application_number = $old_application_number+1;

return $new_application_number;
}

它是如何工作的：当第一个事务结束时，第二个事务将等待该请求。附注根据文档，lock 选项是在 CakePHP 2.10.0 版本中添加的。

atomicity cakephp cakephp-2.0 mysql transactions