From 7adad560ddd59d79710b208a5f1cafb67055d873 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 2 Sep 2020 17:40:11 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- http-server/Server.php | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/http-server/Server.php b/http-server/Server.php index 60cb0f9f..16ba748b 100644 --- a/http-server/Server.php +++ b/http-server/Server.php @@ -170,8 +170,15 @@ class Server extends Application $class = $this->dispatch($config['type']); $this->baseServer = new $class($config['host'], $config['port'], SWOOLE_PROCESS, $config['mode']); $this->baseServer->set($settings); - if (!$event->exists(Event::SERVER_WORKER_START, [$this, 'onLoadWebsocketHandler'])) { - $event->on(Event::SERVER_WORKER_START, [$this, 'onLoadWebsocketHandler']); + + if ($this->baseServer instanceof WebSocket) { + if (!$event->exists(Event::SERVER_WORKER_START, [$this, 'onLoadWebsocketHandler'])) { + $event->on(Event::SERVER_WORKER_START, [$this, 'onLoadWebsocketHandler']); + } + } else if ($this->baseServer instanceof Http) { + if (!$event->exists(Event::SERVER_WORKER_START, [$this, 'onLoadHttpHandler'])) { + $event->on(Event::SERVER_WORKER_START, [$this, 'onLoadHttpHandler']); + } } } else { $newListener = $this->baseServer->addlistener($config['host'], $config['port'], $config['mode']);