Gearman的處理並行，並給輸出intermedeate

Question

我使用的Gearman和修身PHP創建RESTful API，其中：

用戶將調用一個RESTful API和發送文件的URL。那麼這將：

1. 下載的文件 - 併發送用戶的唯一文件ID作爲HTTP響應
2. 由於反應是送的，我要開始處理文件
3. 用戶可以檢查狀態GET的過程www.example.com/api/status API調用

我已經使用gearman來做文件下載部分的標準，但狀態響應也只在處理完成後才發送。另外，如何獲取每個客戶端進程的狀態？ 我需要更多的幫助，關於如何構造相同的細節以及處理排隊過程中的一些細節，因爲我是對齒輪工的新手。

Answer 1

您需要使用jobstatus和doBackground()。 首先，您需要初始化傳輸。這是通過將任務發送到後臺並向用戶發送作業句柄來完成的。您可以通過yourserver.com/api/file-transfer調用此方法，並且必須使用fileurl集發送POST請求。答案是一個json對象。

<?php 
// use composer for slim 
require_once "vendor/autoload.php"; 
$app = new \Slim\Slim(); 

// init file transfer 
$app->post('/file-transfer', function() use ($app) { 
    $resp = array(); 
    try { 
     // get file url 
     $fileurl = $app->request->post('fileurl'); 
     $data = json_encode(array("fileurl"=>$fileurl); 

     // send to gearman 
     $client = new GearmanClient(); 
     $client->addServer(); 

     // store the gearman handle and send the task to the background 
     $jobHandle = $client->doBackground("fileUpload", $data); 

     if ($client->returnCode() != GEARMAN_SUCCESS) throw new Exception("Could not add the job to the queue.", 1); 

     $resp["msg"] = "File upload queued"; 
     $resp["handle"] = $jobHandle; 
    } catch(Exception $e) { 
     // some error handling 
     $resp["msg"] = "There occured a strange error."; 
     $resp["error"] = true; 
    } finally { 
     $response = $app->response(); 
     $response['Content-Type'] = 'application/json'; 
     $response->status(200); 
     $response->body(json_encode($resp));  
    } 
}); 
?> 

在第二個步驟，用戶需要查詢與作業處理服務器（這是他第一次調用接收）：

$app->post('/file-status', function() use ($app) { 
    $jobHandle = $app->request->params('handle'); 
    $resp = array(); 
    try { 
     // ask for job status 
     $client = new GearmanClient(); 
     $client->addServer(); 
     $stat = $client->jobStatus($jobHandle); 
     if (!$stat[0]) { // it is done 
      $resp["msg"] = "Transfer completed."; 
     } else { 
      $resp["msg"] = "Transfer in progress."; 
      $w = (float)$stat[2]; // calculate the percentage 
      $g = (float)$stat[3]; 
      $p = ($g>0)?$w/g*100:0; 
      $resp["percentage"] = $p; 
     } 
    } catch(Exception $e) { 
      // some error handling 
      $resp["msg"] = "There occured a strange error."; 
      $resp["error"] = true; 
    } finally { 
     $response = $app->response(); 
     $response['Content-Type'] = 'application/json'; 
     $response->status(200); 
     $response->body(json_encode($resp));  
    } 
}); 

在第二個請求，你有$統計陣列從$ client-> jobStatus（）。 $ stats [0]告訴你作業是否爲gearman服務器所知。第二步檢查它是否正在運行，並使用三到四（2/3）來計算轉移的百分比（您需要自己設置這些值！）。