問題描述

版主請幫忙解惑
1.我測試的是workerman
2.實例化Worker對象，schema:http,端口號9999，設(shè)置4個進(jìn)程，端口復(fù)用參數(shù)默認(rèn)false，設(shè)置onMessage回調(diào)，回調(diào)里面打印worker對象的id，然后啟動腳本
3.在多個瀏覽器當(dāng)中訪問，chrome,Microsoft Edge里面訪問，打印出來的worker對象的id不同
4.請求被不同的worker進(jìn)程處理，但是沒有在workerman中沒看見master進(jìn)程調(diào)度worker來處理請求
5.那請求是怎么打到對應(yīng)的進(jìn)程上的
6.因為之前我fork處理數(shù)據(jù)的時候都是在master進(jìn)程將任務(wù)發(fā)給子進(jìn)程，每個子進(jìn)程處理部分?jǐn)?shù)據(jù)，所以對于沒看見master調(diào)度worker來處理請求感到困惑
7.master進(jìn)程接受新的連接，代碼里面沒看見分發(fā)給哪個進(jìn)程處理的

$worker = new \Workerman\Worker('http://0.0.0.0:9999');
$worker->count = 4;
$worker->onMessage = function (\Workerman\Connection\TcpConnection $tcpConnection,\Workerman\Protocols\Http\Request $request){
    $id = $tcpConnection->worker->id;
    $tcpConnection->send("$id");
};

以下是workerman接受連接的源碼
public function acceptConnection($socket)
    {
        // Accept a connection on server socket.
        \set_error_handler(function(){});
        $new_socket = \stream_socket_accept($socket, 0, $remote_address);
        \restore_error_handler();

        // Thundering herd.
        if (!$new_socket) {
            return;
        }

        // TcpConnection.
        $connection                         = new TcpConnection($new_socket, $remote_address);
        $this->connections[$connection->id] = $connection;
        $connection->worker                 = $this;
        $connection->protocol               = $this->protocol;
        $connection->transport              = $this->transport;
        $connection->onMessage              = $this->onMessage;
        $connection->onClose                = $this->onClose;
        $connection->onError                = $this->onError;
        $connection->onBufferDrain          = $this->onBufferDrain;
        $connection->onBufferFull           = $this->onBufferFull;

        // Try to emit onConnect callback.
        if ($this->onConnect) {
            try {
                \call_user_func($this->onConnect, $connection);
            } catch (\Exception $e) {
                static::stopAll(250, $e);
            } catch (\Error $e) {
                static::stopAll(250, $e);
            }
        }
    }