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();