runAll

void Worker::runAll(void)

运行所有 Worker 实例。

注意：

Worker::runAll () 执行后将永久阻塞，也就是说位于 Worker::runAll () 后面的代码将不会被执行。所有 Worker 实例化应该都在 Worker::runAll () 前进行。

参数

无参数

返回值

无返回

范例 运行多个 Worker 实例

start.php

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$http_worker = new Worker("http://0.0.0.0:2345");
$http_worker->onMessage = function(TcpConnection $connection, $data)
{
    $connection->send('hello http');
};

$ws_worker = new Worker('websocket://0.0.0.0:4567');
$ws_worker->onMessage = function(TcpConnection $connection, $data)
{
    $connection->send('hello websocket');
};

// 运行所有Worker实例
Worker::runAll();

注意：

windows 版本的 workerman 不支持在同一个文件中实例化多个 Worker。 上面的例子无法在 windows 版本的 workerman 下运行。

windows 版本的 workerman 需要将多个 Worker 实例初始化放在不同的文件中，像下面这样

start_http.php

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$http_worker = new Worker("http://0.0.0.0:2345");
$http_worker->onMessage = function(TcpConnection $connection, $data)
{
    $connection->send('hello http');
};

// 运行所有Worker实例(这里只有一个实例)
Worker::runAll();

start_websocket.php

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$ws_worker = new Worker('websocket://0.0.0.0:4567');
$ws_worker->onMessage = function(TcpConnection $connection, $data)
{
    $connection->send('hello websocket');
};

// 运行所有Worker实例(这里只有一个实例)
Worker::runAll();