发表新帖

用了addProcess自定义一个进程发现死循环worker process is terminated by exit()/die().

{{{
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
[2016-01-21 21:20:11 $21061.0]	WARN	zm_deactivate_swoole: worker process is terminated by exit()/die().
}}}

{{{
<?php
error_reporting(E_ALL^E_NOTICE);
date_default_timezone_set('Asia/Shanghai');

class Server
{
    private $http;
    private $redis;
    private $mqProcess;

public function __construct() {

$this->http = new swoole_http_server(
            '127.0.0.1',
            '9501'
        );
        $this->http->set(
            array(
                'worker_num' => 8,   //工作进程数量
                'max_conn' => 100000,
                'max_request' => 100000,
                'debug_mode'=> 1,
                'task_worker_num'=>8
                //'daemonize' => true, //是否作为守护进程
            )
        );
        $this->http->on('Start', array($this, 'onStart'));
        $this->http->on('WorkerStart', array($this, 'onWorkerStart'));
        $this->http->on('request' , array( $this , 'onRequest'));

$this->http->on('connect', array($this, 'onConnect'));
        $this->http->on('Receive', array($this, 'onReceive'));
        $this->http->on('Close', array($this, 'onClose'));
        $this->http->on('Task', array($this, 'onTask'));
        $this->http->on('Finish', array($this, 'onFinish'));

$this->mqProcess = new swoole_process(function($process){

//Establish connection to AMQP
            $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 = 'direct_logs';
            $exchange = new AMQPExchange($channel);
            $exchange->setType(AMQP_EX_TYPE_DIRECT);
            $exchange->setName($exchange_name);
            $exchange->declareExchange();

$queue = new AMQPQueue($channel);
            $queue->setFlags(AMQP_EXCLUSIVE);
            $queue->setName("abc");
            $queue->declareQueue();

$queue->bind($exchange_name, "aaaa");
            //$exchange->publish("hello","aaaa");

while (true) {
                $msg = $process->read();
                foreach($this->http->connections as $conn) {
                    $this->http->send($conn, $msg);
                }
            }
        });

$this->http->addProcess($this->mqProcess);

$this->http->start();

}

public function onWorkerStart( $serv , $worker_id) {

}

public function onStart( $serv ) {
        echo "Start\n";
    }

public function onConnect($serv, $fd){
        echo "Connected\n";
    }

public function onRequest($request, $response) {

$this->mqProcess->write(json_encode($request));
        $response->end(json_encode($request));

}

public function onReceive(swoole_server $serv, $fd, $from_id, $data){
        $serv->task($data);
    }

public function onTask($serv,$task_id,$from_id, $data) {

}

public function onClose( $serv, $fd, $from_id ) {
        echo "Client {$fd} close connection\n";
    }

public function onFinish($serv,$task_id, $data) {

}
}
new Server();
}}}

发布于8年前 · 1 次浏览 · 来自提问

ThomasJeota