swoole学习

<?php
ini_set('default_socket_timeout', -1);
class serverEmail
{
    public $serv = null;

    public function __construct()
    {
        $this->serv = new swoole_server('0.0.0.0', 9508, SWOOLE_BASE);
        $this->serv->set([
            'worker_num' => 1,
            'task_worker_num' => 1,
            'dispatch_mode' => 2,
            'daemonize' => 0,
            //'debug_mode'=> 0,
        ]);

        $this->serv->on('receive',[$this,'onReceive']);
        //$this->serv->on('receive', function ($serv, $fd, $from_id, $data) {
            //    $serv->send($fd, "Server: ".$data);
        //});

        $this->serv->on('connect',[$this,'onConnect']);
        $this->serv->on('workerstart', [$this, 'onWorkerStart']);
        $this->serv->on('task', [$this, 'onTask']);
        $this->serv->on('finish', [$this, 'onFinish']);
        $this->serv->on('start', [$this, 'onStart']);
        $this->serv->on('message', [$this, 'onMessage']);
        $this->serv->on('close', [$this, 'onClose']);

        //$this->serv->on('request', function ($request, $response) {echo 'xxxx';});
        $this->serv->start();
    }


    public function onReceive(swoole_server $serv, $fd, $from_id, $data)
    {
        $serv->send($fd, "Server: ".$data);
        // $client->subscribe('sendmail');
        echo "this is receive\n";
        $serv->task($data);

    }
    public function onTask(swoole_server $serv, $task_id, $from_id, $data)
    {
        echo "this is task\n";
        return 'xxx';
    }

    public function onFinish(swoole_server $serv, $task_id, $msg)
    {
        echo "this is finish\n";
        return 'xx';
    }

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


    public function onWorkerStart(swoole_server $serv, $task_id)
    {
            echo 'this is workStart'.$this->serv->worker_id.'-'.$task_id."\n";
            if($this->serv->worker_id == 1){
                $redis = new Redis();
                $redis->pconnect('10.12.8.242', 6379);
                //$redis->auth('123qwe!!');
                $redis->subscribe(array('swoole_test'), function($instance, $channelName, $result) {
                    $this->serv->task($result);
                });
            }
    }

    public function onMessage(swoole_server $serv, $result)
    {
        echo "this is message\n";
        print_r($result);
    }

    public function onConnect( swoole_server $serv, $fd, $from_id)
    {
        echo "this is connect\n";
    }
    
    public function onStart() 
    {
        echo "this is start\n";
    }


}
$server = new serverEmail();





//ini_set('default_socket_timeout', -1);


间隔1分钟会报redis异常，信息如下：问题总结出php redis客户端是socket协议通信的。
#3 /opt/aspire/product/tst_cmdn/apache/htdocs/sendmail/swoole_xx.php(93): serverEmail->__construct()
#4 {main}
  thrown in /opt/aspire/product/tst_cmdn/apache/htdocs/sendmail/swoole_xx.php on line 71
[2018-10-17 20:27:05 *15915.1] ERROR zm_deactivate_swoole (ERROR 503): Fatal error: Uncaught exception 'RedisException' with message 'read error on connection' in /opt/aspire/product/tst_cmdn/apache/htdocs/sendmail/swoole_xx.php:71
Stack trace:
#0 /opt/aspire/product/tst_cmdn/apache/htdocs/sendmail/swoole_xx.php(71): Redis->subscribe(Array, Object(Closure))
#1 [internal function]: serverEmail->onWorkerStart(Object(swoole_server), 1)
#2 /opt/aspire/product/tst_cmdn/apache/htdocs/sendmail/swoole_xx.php(32): swoole_server->start()
#3 /opt/aspire
[/opt/aspire/product/tst_cmdn/tmp/swoole-src-1.9.8/src/network/ProcessPool.c:415@swProcessPool_wait][Manager] worker stop.pid=15915
this is workStart1-1

swoole_server的两种运行模式启动进程区别




具体参照swoole官网文档：SWOOLE_BASE模式下Reactor和Worker是同一个角色
swoole_websocket_server 继承自 swoole_http_server，swoole_http_server 继承自 swoole_server，所有swoole_server的方法，都可以用，Onmessage方法是swoole_websocket_server是用到的。