123

src/WebSocketClient.php

@@ -2,8 +2,11 @@
 
 namespace App;
 
-require_once __DIR__ . '/../vendor/autoload.php';
+use Common_pack\ReqHeartBeat;
+use MsgID;
 
+require_once __DIR__ . '/../vendor/autoload.php';
+require './msg.php';
 class WebSocketClient 
 {
     private \WebSocket\Client $socket;
@@ -105,8 +108,11 @@ class WebSocketClient
     private function sendHeartbeat(): void 
     {
         try {
+            $hearbeat = new ReqHeartBeat();
+            $hearbeat->setMsg("ping");
+            $binaryData = $hearbeat->serializeToString();
             // 这里假设心跳消息ID为1，根据实际协议调整
-            $this->sendBinary(1, '');
+            $this->sendBinary(MsgID::REQHEARTBEAT, $binaryData);
         } catch (\Exception $e) {
             error_log("心跳发送失败: " . $e->getMessage());
         }