Cliente y trabajador básicos en Gearman, trabajo en segundo plano

    Ejemplo #1 Cliente y trabajador básicos en Gearman, trabajo en segundo plano

    Este ejemplo muestra un trabajador y un cliente muy sencillos. El cliente envía un string al servidor de trabajos como trabajo en segundo plano, y el trabajador da la vuelta al string. Notar que como el trabajo se realiza de forma asíncrona, el cliente no espera a que se complete el trabajo y termina (y, por tanto, el cliente nunca recibe los resultados).

    <?php

    # Creación del objeto cliente
    $gmclient= new GearmanClient();

    # Se añade el servidor por defecto (localhost)
    $gmclient->addServer();

    # Ejecutar el cliente "reverse" en segundo plano
    $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";

    # Creación del objeto trabajador
    $gmworker= new GearmanWorker();

    # Se añade el servidor por defecto (localhost).
    $gmworker->addServer();

    # Registro de la función "reverse" en el servidor. Cambiar la funcion del
    # trabajador a "reverse_fn_fast" para usar un trabajador más rápido sin
    # mostrar mensajes de estado
    $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";

    # Este bucle de estado no es necesario, únicamente muestra cómo funciona
    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";

    # Retorna lo que se quiere enviar de vuelta al cliente
    return $result;
    }

    # Una versión mucho más sencilla y que muestra menos información del proceso sería:
    function reverse_fn_fast($job)
    {
    return     strrev($job->workload());
    }

    ?>

    El resultado del ejemplo sería algo similar a:

     % 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!
    To Top