下面由workerman使用教學(xué)專(zhuān)欄來(lái)介紹workerman實(shí)現(xiàn)非同步任務(wù)的方法，希望對(duì)需要的朋友有幫助！

1、問(wèn)題

#遇到一個(gè)問(wèn)題，php是單線程，無(wú)法實(shí)作多線程?，F(xiàn)在我需要使用一個(gè)場(chǎng)景是多個(gè)連結(jié)使用一個(gè)線程，也就是在一個(gè)連接進(jìn)程，再開(kāi)進(jìn)程來(lái)處理

#2、解決方案?

workerman如何實(shí)現(xiàn)異步任務(wù)。 workerman可以幫我解決問(wèn)題， 給予文件一個(gè)答案

問(wèn)：?

如何非同步處理繁重的業(yè)務(wù)，避免主業(yè)務(wù)被長(zhǎng)時(shí)間阻塞。例如我要給1000用戶發(fā)送郵件，這個(gè)過(guò)程很慢，可能要阻塞數(shù)秒，這個(gè)過(guò)程中因?yàn)橹髁鞒瘫蛔枞?，?huì)影響後續(xù)的請(qǐng)求，如何將這樣的繁重任務(wù)交給其它進(jìn)程異步處理。

答案:?

可以在本機(jī)或者其它伺服器甚至伺服器叢集預(yù)先建立一些任務(wù)進(jìn)程處理繁重的業(yè)務(wù)，任務(wù)進(jìn)程數(shù)可以開(kāi)多一些，例如cpu的10倍，然後調(diào)用方利用AsyncTcpConnection將資料非同步傳送給這些任務(wù)進(jìn)程非同步處理，非同步得到處理結(jié)果?

任務(wù)進(jìn)程服務(wù)端

use Workerman\Worker;
require_once __DIR__ . '/Workerman/Autoloader.php';
// task worker，使用Text協(xié)議
$task_worker = new Worker('Text://0.0.0.0:12345');
// task進(jìn)程數(shù)可以根據(jù)需要多開(kāi)一些
$task_worker->count = 100;
$task_worker->name = 'TaskWorker';
//只有php7才支持task->reusePort，可以讓每個(gè)task進(jìn)程均衡的接收任務(wù)
//$task->reusePort = true;
$task_worker->onMessage = function($connection, $task_data)
{
     // 假設(shè)發(fā)來(lái)的是json數(shù)據(jù)
     $task_data = json_decode($task_data, true);
     // 根據(jù)task_data處理相應(yīng)的任務(wù)邏輯.... 得到結(jié)果，這里省略....
     $task_result = ......
     // 發(fā)送結(jié)果
     $connection->send(json_encode($task_result));
};
Worker::runAll();

#在workerman中呼叫

use Workerman\Worker;
use \Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/Workerman/Autoloader.php';
// websocket服務(wù)
$worker = new Worker('websocket://0.0.0.0:8080');
$worker->onMessage = function($ws_connection, $message)
{
    // 與遠(yuǎn)程task服務(wù)建立異步連接，ip為遠(yuǎn)程task服務(wù)的ip，如果是本機(jī)就是127.0.0.1，如果是集群就是lvs的ip
    $task_connection = new AsyncTcpConnection('Text://127.0.0.1:12345');
    // 任務(wù)及參數(shù)數(shù)據(jù)
    $task_data = array(
        'function' => 'send_mail',
        'args'       => array('from'=>'xxx', 'to'=>'xxx', 'contents'=>'xxx'),
    );
    // 發(fā)送數(shù)據(jù)
    $task_connection->send(json_encode($task_data));
    // 異步獲得結(jié)果
    $task_connection->onMessage = function($task_connection, $task_result)use($ws_connection)
    {
         // 結(jié)果
         var_dump($task_result);
         // 獲得結(jié)果后記得關(guān)閉異步連接
         $task_connection->close();
         // 通知對(duì)應(yīng)的websocket客戶端任務(wù)完成
         $ws_connection->send('task complete');
    };
    // 執(zhí)行異步連接
    $task_connection->connect();
}
Worker::runAll();

這樣，繁重的任務(wù)交給本機(jī)或者其它伺服器的進(jìn)程去做，任務(wù)完成後會(huì)異步收到結(jié)果，業(yè)務(wù)進(jìn)程就不會(huì)阻塞了。

更多Workerman相關(guān)技術(shù)文章，請(qǐng)?jiān)煸LWorkerman教學(xué)欄位進(jìn)行學(xué)習(xí)！

以上是workerman如何實(shí)現(xiàn)非同步任務(wù)（附程式碼）的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！