链接不上，还是连不上

Author: aogg

app/Listener/ApplicationLifecycleListener.php

@@ -42,6 +42,21 @@ public function process(object $event): void
                 'event' => 'BeforeWorkerStart',
                 'workerNum' => $event->serverSetting['worker_num'] ?? 'unknown',
             ]);
+
+            // 测试connection logger
+            try {
+                $connectionLogger = $this->container->get(\Hyperf\Logger\LoggerFactory::class)->get('connection');
+                $connectionLogger->info('BeforeWorkerStart阶段connection logger测试', [
+                    'workerNum' => $event->serverSetting['worker_num'] ?? 'unknown',
+                    'pid' => getmypid(),
+                ]);
+            } catch (\Throwable $e) {
+                $this->logger->error('获取connection logger失败', [
+                    'error' => $e->getMessage(),
+                    'file' => $e->getFile(),
+                    'line' => $e->getLine(),
+                ]);
+            }
         }
     }
 }

app/Listener/ServerStartListener.php

@@ -54,6 +54,36 @@ public function process(object $event): void
                 'worker_type' => $workerType,
                 'event' => 'OnWorkerStart',
             ]);
+
+            // 测试connection logger
+            try {
+                $connectionLogger = $this->container->get(\Hyperf\Logger\LoggerFactory::class)->get('connection');
+                $connectionLogger->info('Worker进程中connection logger测试', [
+                    'worker_id' => $workerId,
+                    'worker_type' => $workerType,
+                    'pid' => getmypid(),
+                ]);
+            } catch (\Throwable $e) {
+                $this->logger->error('获取connection logger失败', [
+                    'error' => $e->getMessage(),
+                    'file' => $e->getFile(),
+                    'line' => $e->getLine(),
+                ]);
+            }
+
+            // 测试ProxyService
+            try {
+                $proxyService = $this->container->get(\App\Service\ProxyService::class);
+                $this->logger->info('ProxyService实例获取成功', [
+                    'worker_id' => $workerId,
+                ]);
+            } catch (\Throwable $e) {
+                $this->logger->error('获取ProxyService失败', [
+                    'error' => $e->getMessage(),
+                    'file' => $e->getFile(),
+                    'line' => $e->getLine(),
+                ]);
+            }
         }
     }
 }

app/Protocol/MySql/Auth.php

@@ -38,20 +38,33 @@ public static function parseHandshakeResponse(Packet $packet): array
     {
         $payload = $packet->getPayload();
         $offset = 0;
+        $payloadLength = strlen($payload);
 
         // Capability Flags (4 bytes)
+        if ($offset + 4 > $payloadLength) {
+            throw new \RuntimeException('解析握手响应失败：数据包长度不足，无法读取 Capability Flags');
+        }
         $capabilities = unpack('V', substr($payload, $offset, 4))[1];
         $offset += 4;
 
         // Max Packet Size (4 bytes)
+        if ($offset + 4 > $payloadLength) {
+            throw new \RuntimeException('解析握手响应失败：数据包长度不足，无法读取 Max Packet Size');
+        }
         $maxPacketSize = unpack('V', substr($payload, $offset, 4))[1];
         $offset += 4;
 
         // Character Set (1 byte)
+        if ($offset + 1 > $payloadLength) {
+            throw new \RuntimeException('解析握手响应失败：数据包长度不足，无法读取 Character Set');
+        }
         $charset = ord($payload[$offset]);
         $offset += 1;
 
         // Reserved (23 bytes)
+        if ($offset + 23 > $payloadLength) {
+            throw new \RuntimeException('解析握手响应失败：数据包长度不足，无法读取 Reserved');
+        }
         $offset += 23;
 
         // Username (NUL terminated string)
@@ -63,14 +76,21 @@ public static function parseHandshakeResponse(Packet $packet): array
         $offset++; // skip NUL
 
         // Auth Response (length encoded integer)
+        if ($offset + 1 > $payloadLength) {
+            throw new \RuntimeException('解析握手响应失败：数据包长度不足，无法读取 Auth Response 长度');
+        }
         $authResponseLength = ord($payload[$offset]);
         $offset += 1;
+
+        if ($offset + $authResponseLength > $payloadLength) {
+            throw new \RuntimeException('解析握手响应失败：数据包长度不足，无法读取完整的 Auth Response');
+        }
         $authResponse = substr($payload, $offset, $authResponseLength);
         $offset += $authResponseLength;
 
         // Database (NUL terminated string) - only if CLIENT_CONNECT_WITH_DB
         $database = '';
-        if ($capabilities & 0x00000008 && $offset < strlen($payload)) {
+        if ($capabilities & 0x00000008 && $offset < $payloadLength) {
             while (isset($payload[$offset]) && $payload[$offset] !== "\x00") {
                 $database .= $payload[$offset];
                 $offset++;
@@ -80,7 +100,7 @@ public static function parseHandshakeResponse(Packet $packet): array
 
         // Auth Plugin Name (NUL terminated string) - only if CLIENT_PLUGIN_AUTH
         $authPluginName = '';
-        if ($capabilities & 0x00080000 && $offset < strlen($payload)) {
+        if ($capabilities & 0x00080000 && $offset < $payloadLength) {
             while (isset($payload[$offset]) && $payload[$offset] !== "\x00") {
                 $authPluginName .= $payload[$offset];
                 $offset++;

app/Protocol/MySql/Parser.php

@@ -12,14 +12,27 @@ public static function parsePackets(string $data): array
     {
         $packets = [];
         $offset = 0;
+        $totalLength = strlen($data);
 
-        while ($offset < strlen($data)) {
-            if ($offset + 4 > strlen($data)) {
+        while ($offset < $totalLength) {
+            // 检查是否有足够的字节来读取包头
+            if ($offset + 4 > $totalLength) {
                 break;
             }
 
             $length = unpack('V', substr($data, $offset, 3) . "\x00")[1];
             $sequenceId = ord($data[$offset + 3]);
+
+            // 验证包长度是否合理
+            if ($length < 0 || $length > 0xffffff) {
+                throw new \RuntimeException("无效的包长度: {$length}");
+            }
+
+            // 检查是否有足够的字节来读取payload
+            if ($offset + 4 + $length > $totalLength) {
+                break;
+            }
+
             $payload = substr($data, $offset + 4, $length);
 
             $packets[] = new Packet($length, $sequenceId, $payload);