From 89ea2858179eb454cb68b2764ee83c440de1b935 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 31 Mar 2021 01:36:16 +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 --- HttpServer/Events/OnWorkerExit.php | 3 +++ System/Channel.php | 13 +++++++++++++ 2 files changed, 16 insertions(+) diff --git a/HttpServer/Events/OnWorkerExit.php b/HttpServer/Events/OnWorkerExit.php index a8edb023..bc3a9ca9 100644 --- a/HttpServer/Events/OnWorkerExit.php +++ b/HttpServer/Events/OnWorkerExit.php @@ -25,6 +25,9 @@ class OnWorkerExit extends Callback { putenv('state=exit'); + $channel = Snowflake::app()->getChannel(); + $channel->cleanAll(); + $event = Snowflake::app()->getEvent(); $event->trigger(Event::SERVER_WORKER_EXIT); $event->offName(Event::SERVER_WORKER_EXIT); diff --git a/System/Channel.php b/System/Channel.php index 92f2dd0e..d7dec52b 100644 --- a/System/Channel.php +++ b/System/Channel.php @@ -68,6 +68,19 @@ class Channel extends Component } + /** + * + * 清空缓存 + */ + public function cleanAll() + { + /** @var CChannel $channel */ + foreach ($this->_channels as $channel) { + $channel->close(); + } + $this->_channels = []; + } + /** * @param $timeout * @param Closure $closure