fix(http): prevent premature connection closure and ensure HTTP/1.1 compliance

Author: cclilshy

src/Net/Http/Server/Connection.php

@@ -182,22 +182,22 @@ public function start(Server $server): void
                 try {
                     $content = $this->stream->read(8192);
                     if ($content === '' && $this->stream->eof()) {
-                        $this->disconnect();
-                        return;
+                        throw new ConnectionException();
                     }
 
                     foreach ($this->processData($content) as $reqInfo) {
                         $this->onRequest($reqInfo);
                     }
-                } catch (ConnectionException) {
-                    $this->disconnect();
                 } catch (Throwable $err) {
-                    Stdin::println($err->getMessage());
-                    $this->disconnect();
+                    if (!$err instanceof ConnectionException) {
+                        Stdin::println($err->getMessage());
+                    }
+
+                    $this->stream->close();
                 }
             });
         } catch (ConnectionException) {
-            $this->disconnect();
+            $this->stream->close();
         }
     }
 
@@ -209,14 +209,6 @@ public function isAlive(): bool
         return !$this->stream->isClosed();
     }
 
-    /**
-     * @return void
-     */
-    public function disconnect(): void
-    {
-        $this->stream->close();
-    }
-
     /**
      * 处理 HTTP 请求
      * @param array $reqInfo 请求信息
@@ -261,8 +253,6 @@ private function onRequest(array $reqInfo): void
         } catch (Throwable $exception) {
             $req->respond($exception->getMessage(), [], 500);
             $this->reset();
-        } finally {
-            ($keepAlive || $isWebSocketUpgrade) || $this->disconnect();
         }
     }
 

src/Net/Http/Server/Response.php

@@ -30,6 +30,7 @@
 use function array_key_exists;
 use function is_int;
 use function is_file;
+use function strtolower;
 
 /**
  * response entity
@@ -152,6 +153,13 @@ public function __invoke(Stream $stream): void
                 throw new ConnectionException('The response content is illegal.');
             }
         }
+
+        $connectionHeader = $this->headers['Connection'] ?? '';
+        $connectionValue = strtolower($connectionHeader);
+
+        if ($connectionValue === 'close') {
+            $stream->close();
+        }
     }
 
     /**

src/Stream.php

@@ -690,7 +690,7 @@ public static function connect(string $address, int|float $timeout = 0, mixed $c
     {
         $address = str_replace('ssl://', 'tcp://', $address);
 
-        // 使用@抑制警告，然后检查错误信息
+        // 使用@抑制警告, 然后检查错误信息
         $connection = @stream_socket_client(
             $address,
             $errCode,