src/start.php

@@ -1,27 +1,19 @@
 <?php
 
 use Workerman\Worker;
+use App\MyWebSocketHandler;
 
 require_once __DIR__ . '/vendor/autoload.php';
 
-// Create a Websocket server
+$handler = new MyWebSocketHandler();
+
 $ws_worker = new Worker('websocket://0.0.0.0:2346');
 
-// Emitted when new connection come
-$ws_worker->onConnect = function ($connection) {
-    echo "New connection\n";
-};
+$ws_worker->onConnect = [$handler, 'onConnect'];
+$ws_worker->onMessage = [$handler, 'onMessage'];
+$ws_worker->onClose = [$handler, 'onClose'];
 
-// Emitted when data received
-$ws_worker->onMessage = function ($connection, $data) {
-    // Send hello $data
-    $connection->send('Hello ' . $data);
-};
-
-// Emitted when connection closed
-$ws_worker->onClose = function ($connection) {
-    echo "Connection closed\n";
-};
-
-// Run worker
-Worker::runAll();
+// 仅在非测试环境下运行
+if (!getenv('PHPUNIT_RUNNING')) {
+    Worker::runAll();
+}