今天在公司，用php寫服務端的時候，因為專案中要做老師跟學生一對一輔導功能。然後學生上傳問題圖片之後在服務端找老師需要長時間的消耗，另外一個方面老師接收到學生的提問之後可能沒即時看到或者沒在電腦旁邊（我們在後臺指定老師10s的反應時間）我們會繼續找尋下一個老師。這樣的話客戶端請求到API層面，並沒有及時的返回結果，導致客戶端程式碼進入了一個類似死迴圈裡面，整個客戶端程式碼直接崩潰。
但是業務需要這樣，php又不能多執行緒，所以就考慮解決方案，最終選到了使用gearman。首先Gearman是一個用來把工作委派給其他機器、分散式的呼叫更適合做某項工作的機器、併發的做某項工作在多個呼叫間做負載均衡、或用來在呼叫其它語言的函式的系統。其他的東西，童鞋們可以google！
基於gearman可以直接安裝php擴充套件，這樣的話更方便一些，至於怎麼安裝擴充套件我就不一一介紹了，不對安裝的同學可以百度！
我來大概說一下gearman吧。它呢就是生產者和消費者的關係。至於生產者 你可以認為你的API層，或者是業務層面。如果你有一系列動作在服務端需要長時間的去做，甚至超出了php指令碼的有效執行時間。這個時候用到了gearman。你那個需要長時間執行的任務可以當作消費者放到gearman的任務佇列裡面去，api層面可以立即返回結果告訴客戶端請求成功。至於後續任務裡面如果有錯誤，或者其他提示的話 你可以用websocket或者你自己的容錯機制來官方的告訴客戶端提示使用者。好了說了這麼多上程式碼吧

    public function imgtoteacher(){
            $ret = array('err_no'=>1000,'err_msg'=>'system error');
            do{
                $must = array('subject_id','grade_id','url');
                $fields = array();
                $this->checkParams('post',$must,$fields);
                $user
 
 = $this->checkUserSession();
                $params = $this->params;
                $data = array(
                    'user_id'=>$user['id'],
                    'subject_id'=>$params['subject_id'],
                    'grade_id'=>$params['grade_id'],
                    'create_time'
 
=>time()
                );
                $res = $this->wmodel->create_question($data);
                if($res){
                    $question_id = $res['id'];
                    //插入詳情，問題圖片一律存問題詳情表
                    $detail = array(
                            'question_id'=>$question_id,
                            'img_url'    =>$params['url'],
                            'create_time'=>time()
                        );
                     $flag = $this->wmodel->insert_detail($detail);
                     if(!$flag){
                        $ret = array('err_no'=>8002,'err_msg'=>'上傳問題圖片失敗，請重試！');
                        break;
                     }
                    //呼叫gearman掛起找老師的服務
                    $_array = array('question_id'=>$question_id,'subject_id'=>$params['subject_id'],'grade_id'=>$params['grade_id'],'img_url'=>$params['url'],'send_id'=>$user['id']);
                    $client= new GearmanClient();    
                    $client->addServer();
                    $client->doBackground("params", json_encode($_array));
                     //隨機選出老師詢問老師是否同意
                     // $single = $this->wmodel->select_teacher($params['subject_id'],$params['grade_id']);
                     // if($single){
                     //            //給線上的這個老師傳送socket請求詢問是否同意
                     //            $post_data = array("type" => "publish",
                     //               "content" => array('type'=>1,'img_url'=>$params['url'],'student_id'=>$user['id'],'question_id'=>$question_id),
                     //               "to" => $single['user_id']);
                     //            $result = curlRequest($this->websocket_url,$post_data);
                     //         }else{
                     //            $ret = array('err_no'=>8003,'err_msg'=>'暫無符合科目年級的線上老師，請詢問其他科目年級的問題！！');
                     //            break;  
                     //         }
                     //    if($result != 'ok'){
                     //        $ret = array('err_no'=>8001,'err_msg'=>'websocket傳送通知失敗');
                     //        break;  
                     //    }
                    $ret = array('err_no'=>0,'err_msg'=>'success');
                    break;
                    //$ret = $this->sleep_select($question_id,$params['subject_id'],$params['grade_id'],$params['url']);
                }else{
                    $ret = array('err_no'=>8002,'err_msg'=>'上傳問題圖片失敗，請重試！');
                    break;    
                }
            }while(0);
            $this->output($ret);
        }

我拿我我自己的程式碼給大家解釋。其中

$client= new GearmanClient();    
$client->addServer();
$client->doBackground("params", json_encode($_array));

這一段是連線gearman ，addserver那一點我沒寫是因為它自己預設的就是當前伺服器，這個我們可以認為是生產者。當然瞭如果你的消費者跟這個在同一個伺服器的話 那個地方你可以空著不填寫伺服器地址。至於client−>doBackground("params",jsonencode(_array));這個地方尤其要注意那個引數一定要跟你的消費者保持一直第二個引數是你在消費者裡面需要用到的引數。
下面我們再來說消費者

<?php
//                   _ooOoo_  
//                  o8888888o  
//                  88" . "88  
//                  (| -_- |)  
//                  O\  =  /O  
//               ____/`---'\____  
//             .'  \\|     |//  `.  
//           /  \\|||  :  |||//  \  
//           /  _||||| -:- |||||-  \  
//           |   | \\\  -  /// |   |  
//           | \_|  ''\---/''  |   |  
//           \  .-\__  `-`  ___/-. /  
//         ___`. .'  /--.--\  `. . __  
//      ."" '<  `.___\_<|>_/___.'  >'"".  
//     | | :  `- \`.;`\ _ /`;.`/ - ` : | |  
//     \  \ `-.   \_ __\ /__ _/   .-` /  /  
//======`-.____`-.___\_____/___.-`____.-'======  
//                   `=---='  
//^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^  
//佛祖保佑       永無BUG      心外無法       法外無心   永不修改 
  $worker= new GearmanWorker();
  $worker->addServer();     
  $worker->addFunction("params", "find_teacher");    
  while ($worker->work());

  function find_teacher($job)
  {
    //return ucwords(strtolower($job->workload()));
    $params = $job->workload();
    $params = json_decode($params,true);
    //這裡需要你寫一些業務處理
  }

上面就是消費者程式碼。使用$job->workload()接收你傳來的引數。然後你就可以寫你的業務邏輯，處理你需要長時間處理的業務。
已上就是解決了非同步處理任務的方法。具體gearman的一些引數和方法請訪問
http://php.net/manual/en/book.gearman.php