发表新帖

swServer_get_worker: worker_id is exceed serv->worker_num + SwooleG.task_worker_num

**swoole 1.7.21 稳定版 php5.5**
{{{
[2016-01-22 20:51:55 @78664.0]	WARN	swServer_get_worker: worker_id is exceed serv->worker_num + SwooleG.task_worker_num
[2016-01-22 20:51:56 $78665.0]	WARN	swServer_get_worker: worker_id is exceed serv->worker_num + SwooleG.task_worker_num
[2016-01-22 20:51:56 $78665.0]	WARN	swServer_get_worker: worker_id is exceed serv->worker_num + SwooleG.task_worker_num
[2016-01-22 20:51:56 $78665.0]	WARN	swServer_get_worker: worker_id is exceed serv->worker_num + SwooleG.task_worker_num
[2016-01-22 20:51:57 $78665.0]	WARN	swServer_get_worker: worker_id is exceed serv->worker_num + SwooleG.task_worker_num
[2016-01-22 20:51:57 $78665.0]	WARN	swServer_get_worker: worker_id is exceed serv->worker_num + SwooleG.task_worker_num
[2016-01-22 20:51:57 $78665.0]	WARN	swServer_get_worker: worker_id is exceed serv->worker_num + SwooleG.task_worker_num

}}}

{{{
<?php
/**
 * Created by IntelliJ IDEA.
 * User: winfan
 * Date: 16/1/21
 * Time: 下午10:09
 */

$server = new swoole_http_server('127.0.0.1', 9501);

$connection = new AMQPConnection();
$connection->setHost('127.0.0.1');
$connection->setLogin('guest');
$connection->setPassword('guest');
$connection->connect();
//Declare Channel
$channel = new AMQPChannel($connection);

//Declare Exchange
$exchange_name = 'bbbbbbbbbbbbbbbb';
$exchange = new AMQPExchange($channel);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->setName($exchange_name);
$exchange->declareExchange();

$queue = new AMQPQueue($channel);
$queue->setFlags(AMQP_NOPARAM);
$queue->setName("aaaaaaaaaaaaaa");
$queue->declareQueue();

$queue->bind($exchange_name, "fuck");

$process = new swoole_process(function($process) use ($server,$exchange,$connection,$channel) {
    while (true) {
        $msg = $process->read();
        //var_dump($msg);
        foreach($server->connections as $conn) {
            $exchange->publish($msg,"fuck");
            $server->send($conn, $msg);
        }
    }
    //$channel->close();
    //$connection->disconnect();
});

$server->set(
    array(
        'worker_num' => 8,   //工作进程数量
        'max_conn' => 100000,
        'max_request' => 100000,
        'debug_mode'=> 0,
        'task_worker_num'=>8
        //'daemonize' => true, //是否作为守护进程
    )
);
$server->addProcess($process);

$server->on('receive', function ($serv, $fd, $from_id, $data) use ($process) {
    //群发收到的消息
    $process->write($data);
});

$server->on('request', function ($request, swoole_http_response $response) use($process){
    $process->write(json_encode($request));
    $response->end(json_encode($request));
});

$server->on('Task', function ($serv, $task_id, $from_id, $data) {
    echo "New AsyncTask[id=$task_id]".PHP_EOL;
    $serv->finish("$data -> OK");
});

$server->on('Finish', function ($serv, $task_id, $data) {
    echo "AsyncTask[$task_id] Finish: $data".PHP_EOL;
});

$server->start();
}}}

发布于6年前 · 3 次浏览 · 来自提问

qieangel2013

}}}