Workerman? ???? ?? ??? ???? ???? ??

??:
???? ??? ??? ?? ?? ???? ??? ?? ??? ?? ? ????? ????. ???? ??? ?? ???? ???? ??? ??, ?? ??, ?? ???? ? ?? ???? ?? ?????. ??? ?? ???? ???? ??? ????? ?? ??? ??? ???? ? ?? ??? ??? ? ????. ? ????? Workerman ?????? ???? ?? ??? ???? ???? ??? ???? ????? ??? ?????.

1. Workerman ??
Workerman? PHP? ???? ?? ???, ???? ??? ???? ?? ????????. PHP? ??? IO ??? ???? IO ???? ????? ???? ?? ???? ?? ?????. Workerman? ?? ????? ???? ??? ?? ???? ??? ? ?? ?? ???? ?????.

2. ?? ??? ???? ???? ??
?? ??? ???? ?????? ??? ??? ???? ??? ?????. ??? ??? ?? ??, ?? ??, ???? ???? ??? ?? ??? ????, ???? ??? ?? ??? ??? ?????. ??? ??? ???? ?? ?? ??? TCP ??? ?? ??????.

???? ??? ?? ??? ????.

主節(jié)點(diǎn)
+---+
|   |
+---+

從節(jié)點(diǎn)
+---+
|   |
+---+

從節(jié)點(diǎn)
+---+
|   |
+---+

從節(jié)點(diǎn)
+---+
|   |
+---+

3. ??? ?? ??
??? ?? ???? ?? ?? ??, ?? ?? ? ?? ??? ?????.

1. Task Scheduling
   ??? ??? ??? ???? ???? ????? ?? ??? ????. ???? ??? ????? ???? ??? ??? ???? ??? ?? ??? ????.

<?php
require_once __DIR__ . '/Workerman/Autoloader.php';
use WorkermanWorker;

$worker = new Worker('tcp://0.0.0.0:1234');
$worker->count = 4; // 主節(jié)點(diǎn)的進(jìn)程數(shù)
$worker->onConnect = function($con) {
    echo "New connection
";
    // 向從節(jié)點(diǎn)發(fā)送任務(wù)請求
    $con->send('task');
};
Worker::runAll();

2. ?? ??
   ??? ??? ???? ???? ?? ?? ??? ?? ? ??? ?? ?????. ?? ??, ???? ??? ?? ?? ?? ?? ??? ????? ?????.

$worker->onMessage = function($con, $data) {
    $task = allocateTask($data);  // 任務(wù)分配算法
    $con->send($task);
};

3. ?? ??
   ??? ??? ???? ????? ??? ??? ?? ? ??????? ??, ?? ?? ?? ?? ??? ??? ? ????.

$worker->onMessage = function($con, $data) {
    // 處理結(jié)果
    saveToDatabase($data);
};

4. ???? ?? ??
???? ?? ???? ?? ?? ??, ?? ?? ? ?? ??? ?????.

1. ?? ?? ? ?? ??
   ???? ??? ??? ???? ?? ??? ????? ?????? ?? ??? ?? ?? ??? ??? ?????.

<?php
require_once __DIR__ . '/Workerman/Autoloader.php';
use WorkermanWorker;

$worker = new Worker('tcp://127.0.0.1:1234');
$worker->count = 4; // 從節(jié)點(diǎn)的進(jìn)程數(shù)
$worker->onMessage = function($con, $data) {
    if ($data === 'task') {
        $task = getTask();  // 獲取任務(wù)
        $con->send($task);
    } else {
        $result = executeTask($data);  // 執(zhí)行任務(wù)
        $con->send($result);
    }
};
Worker::runAll();

2. Return results
   ???? ??? ??? ??? ??? ??? ??? ? ???? ?? ??? ?? ? ????.

$worker->onMessage = function($con, $data) {
    // 執(zhí)行任務(wù)并返回結(jié)果
    $result = executeTask($data);
    $con->send($result);
};

5. ??
Workerman ?????? ???? ?? ??? ???? ?? ??? ? ????. ?? ?? ???? ??? ??? ???? Workerman? ?? ??? ???? ?????? ??? ???? ???? ?? ???? ? ????. ? ??? Workerman? ???? ?? ??? ???? ???? ??? ???? ? ??? ??? ????.

? ??? Workerman? ???? ?? ??? ???? ???? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!