Выполнение скриптов по порядку с использованием PHP и MySQL
У меня есть веб-сайт, который позволяет пользователю выбирать тестовые сценарии из переключателей и после отправки желаемого теста на удаленный сервер, используя PHP:
- Он вставляет отправку строки в базу данных MySQL в таблице test_activity_log с идентификатором, именем пользователя, именем теста, именем шлюза и отметкой времени.
- Затем отправляет
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);
}
}
}
?>