diff --git a/src/ZM/Event/Swoole/MessageEvent.php b/src/ZM/Event/Swoole/MessageEvent.php index e632e105..abbb8d50 100644 --- a/src/ZM/Event/Swoole/MessageEvent.php +++ b/src/ZM/Event/Swoole/MessageEvent.php @@ -45,6 +45,7 @@ class MessageEvent implements SwooleEvent $data = json_decode(context()->getFrame()->data, true); if (isset($data["post_type"])) { set_coroutine_params(["data" => $data, "connection" => $conn]); + ctx()->setCache("level", 0); Console::debug("Calling CQ Event from fd=" . $conn->fd); EventHandler::callCQEvent($data, ConnectionManager::get(context()->getFrame()->fd), 0); } else @@ -64,6 +65,7 @@ class MessageEvent implements SwooleEvent } } catch (Exception $e) { Console::warning("Websocket message event exception: " . (($cs = $e->getMessage()) == "" ? get_class($e) : $cs)); + Console::warning("In ". $e->getFile() . " at line ".$e->getLine()); } return $this; } diff --git a/src/ZM/Event/Swoole/WorkerStartEvent.php b/src/ZM/Event/Swoole/WorkerStartEvent.php index adc3a797..b8d02c7c 100644 --- a/src/ZM/Event/Swoole/WorkerStartEvent.php +++ b/src/ZM/Event/Swoole/WorkerStartEvent.php @@ -139,7 +139,10 @@ class WorkerStartEvent implements SwooleEvent unset($list[0], $list[1]); foreach ($list as $v) { if (is_dir($dir . $v)) continue; - if (pathinfo($dir . $v, 4) == "phar") require_once($dir . $v); + if (pathinfo($dir . $v, 4) == "phar") { + Console::verbose("加载Phar: " . $dir . $v . " 中"); + require_once($dir . $v); + } } }