$task_worker->onMessage = function($connection, $task_data)
{
     // 假設(shè)發(fā)來的是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));
};

$task_connection->onMessage = function($task_connection, $task_result)
{
     // 結(jié)果
     var_dump($task_result);
     // 獲得結(jié)果后記得關(guān)閉鏈接
     $task_connection->close();
};