请求是怎么打到不同的worker进程的

问题描述

版主请帮忙解惑
1.我测试的是workerman
2.实例化Worker对象，schema:http,端口号9999，设置4个进程，端口复用参数默认false，设置onMessage回调，回调里面打印worker对象的id，然后启动脚本
3.在多个浏览器当中访问，chrome,Microsoft Edge里面访问，打印出来的worker对象的id不同
4.请求被不同的worker进程处理，但是没有在workerman中没看见master进程调度worker来处理请求
5.那请求是怎么打到对应的进程上的
6.因为之前我fork处理数据的时候都是在master进程将任务发给子进程，每个子进程处理部分数据，所以对于没看见master调度worker来处理请求感到困惑
7.master进程接受新的连接，代码里面没看见分发给哪个进程处理的

$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);
            }
        }
    }