Выполнение скриптов по порядку с использованием PHP и MySQL

У меня есть веб-сайт, который позволяет пользователю выбирать тестовые сценарии из переключателей и после отправки желаемого теста на удаленный сервер, используя PHP:

  1. Он вставляет отправку строки в базу данных MySQL в таблице test_activity_log с идентификатором, именем пользователя, именем теста, именем шлюза и отметкой времени.
  2. Затем отправляет ssh2_exec выполнить нужный скрипт на удаленном шлюзе

Все вышеперечисленное у меня уже работает, однако, в случае, когда несколько пользователей выполняют сценарии с веб-страницы одновременно, мне нужно найти способ поставить их в очередь и выполнять их один за другим. Каков был бы лучший способ сделать это?

Любые идеи будут высоко ценится.

РЕДАКТИРОВАТЬ:

testexe.php

<?php

...
...    

//while there are still jobs that are not done..
while (1) {
    //wait for 10 seconds and query again...
    sleep(10);
    $statusResult = mysqli_query($dbConnection, $qStatus);
    //if there are undone jobs we pick them and execute them
    if (mysqli_num_rows($statusResult) > 0){
        //query the next undone test case
        $testResult = mysqli_query($dbConnection, $qNextTest);

        //fetch the returned query object and store needed parameters 
        $row = $testResult->fetch_assoc();
        $id = $row['id'];               
        $test_script = $row['test_script']; 
        $gateway = $row['gateway'];         


        if ($connection = @ssh2_connect($gateway, 22)) {
            ssh2_auth_password($connection, $user, $password);

            //execute the test case
            $stream = ssh2_exec($connection, "/my/path/to/script.sh"); 

            //fetch output stream and stderr
            stream_set_blocking($stream, true);
            $stream_out = ssh2_fetch_stream($stream, SSH2_STREAM_STDIO);
            $stream_err = ssh2_fetch_stream($stream, SSH2_STREAM_STDERR);
            while($line = fgets($stream_out)) {flush(); echo '<pre>' . $line . '</pre>';}               
            echo '<pre>' . "------------------------\n" . '</pre>';
            while($line = fgets($stream_err)) {flush(); echo '<pre>' . $line . '</pre>';}
            fclose($stream);    

            //update the table after the above script is done
            $qUpdateStatus = "UPDATE table SET status = 1 WHERE id = $id";
            $updateresult = mysqli_query($dbConnection, $qUpdateStatus);
        }

    }
}

?>

0 ответов

Другие вопросы по тегам