国产+高潮+在线,国产 av 仑乱内谢,www国产亚洲精品久久,51国产偷自视频区视频,成人午夜精品网站在线观看

關于異步任務

mopolun520

http://doc.workerman.net/faq/async-task.html
對文檔異步任務有個疑問
例如我有10臺專門處理異步任務的服務器
能否做到負載均衡一樣的效果呢
例如一臺建立了10個任務. 能否自動切換到第二臺服務器嗎?
還是需要自己去判斷A服務器 是否建立了10個任務 自動切換IP呢

new AsyncTcpConnection('Text://127.0.0.1:12345');
use Workerman\Worker;
use \Workerman\Connection\AsyncTcpConnection;
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');
    // 任務及參數(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));
    // 異步獲得結果
    $task_connection->onMessage = function($task_connection, $task_result)use($ws_connection)
    {
         // 結果
         var_dump($task_result);
         // 獲得結果后記得關閉異步連接
         $task_connection->close();
         // 通知對應的websocket客戶端任務完成
         $ws_connection->send('task complete');
    };
    // 執(zhí)行異步連接
    $task_connection->connect();
}

Worker::runAll();
6066 1 0
1個回答

法師

不會自己切換的,得自己判斷

年代過于久遠,無法發(fā)表回答
??