workerman如何實現異步任務（附代碼）

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

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