Поддерживать количество запущенных копий PHP скрипта?

Question

[Prescott]

Привет.

Есть очередь сообщений на memcacheQ. Надо поддерживать количество PHP скриптов, которое ее слушает, на определенном уровне, чтобы в любой момент времени их было не меньше N штук. Писать свой демон, который будет это делать (качественно) не охота, к тому же когда то я видел в комментариях на хабре ссылку на софтину, которую кто то сделал для этих же целей до меня.

Помогите найти, пожалуйста)

Answer 1

[la0]

Проблема решается supervisord.org/. решение стабильное и рабочее.

Comments

[Prescott]

Вот за что человеку опять поставили минус? Так и не понял я, почему предлагающих его второй раз минусуют?) С ним что то не так?
При этом автора комментария про gearman, который описанную проблему НЕ решает, плюсуют.

[la0]

Всё очень просто. Адептам велосипедов не нравятся готовые решения…

Answer 2

[Алексей Журбицкий]

Сервер очередей Gearman?
habrahabr.ru/post/123451/
habrahabr.ru/post/142210/

Comments

[Prescott]

Насколько я понял он так же как и все сервера очередей количество воркеров не контролирует, так же люди пишут в комментариях: habrahabr.ru/post/123451/#comment_4067351, это кстати логично, так как сервер очередей может в принципе стоять не на тех машинах, на которых работают исполнители и запускать их физически не будет иметь возможности.

Но в тех же комментариях человек указывает на supervisord как возможное решение проблемы, возможно это то что я ищу, но пока смущают два момента:
1) Почему комментарий обзавелся минусом, а не плюсами? Есть кто реально использовал supervisord для этих целей?
2) Вроде это не то, что я видел раньше. Видимо есть еще альтернативы.

Answer 3

[KEKSOV]

Я бы воспользовался pcntl функциями. Если кратко, то код выглядит следующим образом (просто для пояснения идеи)

<?php

runDaemon(10);

function runDaemon( $aMaxWorkers )
{
    $i = 0;
    for ( ; $i < $aMaxWorkers; $i++ )
    {
        forkWorker( $i );
    }
    
    while ( ( $pid = pcntl_wait( $status ) ) != -1 )
    { 
        echo "Exit $pid\n";
        forkWorker( $i++ );
    }
}

function forkWorker( $aNumber )
{
    $pid = pcntl_fork(); 

    if ( $pid )
    {
        echo "Start #$aNumber, pid $pid\n";
        return;
    }
    
    // Делаем свою работу и выходим
    sleep(5);
    exit;
}

?>

Но у него есть один незначительный недостаток — он не работает pcntl_wait может не отловить одновременный выход двух работников и не запустит нужное число новых.

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

while(count($this->currentJobs)){
    echo "Waiting for current jobs to finish... \n";
    sleep(1);
}

Answer 4

[deadkrolik]

habrahabr.ru/qa/40647/

Answer 5

[Ilya Evseev]

Велосипед:

#!/bin/bash
N=5
while : ; do
    n=$(pgrep -flc "php ...")
    while $n -le $N; do
        logger "Run $n/$N"
        php ...
        : $[n++]
    done
    sleep 60
done

Comments

[Ilya Evseev]

Поправки:
1) pgrep -fc…
2) php… &