Edit Report a Bug

    Базовый клиент и обработчик Gearman, фоновый режим

    Пример #1 Базовый клиент и обработчик Gearman, фоновый режим

    Этот пример демонстрирует базовую работу с клиентом и его обработчиком. Клиент отправляет строку серверу выполнения заданий в виде фоновой задачи, а обработчик переворачивает строку. Обратите внимание, что работа выполняется асинхронно, т.е. клиент не ждёт завершения задания, а сразу отключается (а значит и не получает результат).

    <?php

    # создание объекта
    $gmclient= new GearmanClient();

    # указание сервера по умолчанию (localhost)
    $gmclient->addServer();

    # выполнение в фоновом режиме
    $job_handle = $gmclient->doBackground("reverse", "this is a test");

    if (    $gmclient->returnCode() != GEARMAN_SUCCESS)
    {
    echo     "bad return code\n";
    exit;
    }

    echo     "done!\n";

    ?>
    <?php

    echo "Starting\n";

    # Создание обработчика.
    $gmworker= new GearmanWorker();

    # Указание сервера по умолчанию (localhost).
    $gmworker->addServer();

    # Регистрация функции "reverse" на сервере. Изменение функции обработчика на
    # "reverse_fn_fast" для более быстрой обработки без вывода.
    $gmworker->addFunction("reverse", "reverse_fn");

    print     "Waiting for job...\n";
    while(    $gmworker->work())
    {
    if (    $gmworker->returnCode() != GEARMAN_SUCCESS)
    {
    echo     "return_code: " . $gmworker->returnCode() . "\n";
    break;
    }
    }

    function     reverse_fn($job)
    {
    echo     "Received job: " . $job->handle() . "\n";

    $workload = $job->workload();
    $workload_size = $job->workloadSize();

    echo     "Workload: $workload ($workload_size)\n";

    # Этот цикл не является необходимым, но показывает как выполняется работа
    for ($x= 0; $x < $workload_size; $x++)
    {
    echo     "Sending status: " . ($x + 1) . "/$workload_size complete\n";
    $job->sendStatus($x, $workload_size);
    sleep(1);
    }

    $result= strrev($workload);
    echo     "Result: $result\n";

    # Возвращаем, когда необходимо отправить результат обратно клиенту.
    return $result;
    }

    # Гораздо более простая и менее подробная версия вышеприведённой функции выглядит так:
    function reverse_fn_fast($job)
    {
    return     strrev($job->workload());
    }

    ?>

    Вывод приведённого примера будет похож на: 

    % php reverse_worker.php
Starting
Waiting for job...
Received job: H:foo.local:41
Workload: this is a test (14)
1/14 complete
2/14 complete
3/14 complete
4/14 complete
5/14 complete
6/14 complete
7/14 complete
8/14 complete
9/14 complete
10/14 complete
11/14 complete
12/14 complete
13/14 complete
14/14 complete
Result: tset a si siht

    % php reverse_client_bg.php
done!

    add a note add a note

    User Contributed Notes

    There are no user contributed notes for this page.
    To Top