Fixed websocket recv timeout. Added failed log. (#29)

Co-authored-by: 李铭昕 <[email protected]>

.github/workflows/test.yml

@@ -14,7 +14,7 @@ jobs:
       matrix:
         os: [ ubuntu-latest ]
         php-version: [ '8.1', '8.2', '8.3' ]
-        swoole-version: [ 'v5.0.3', 'v5.1.1', 'master' ]
+        swoole-version: [ 'v5.0.3', 'v5.1.2', 'master' ]
         exclude:
           - php-version: '8.3'
             swoole-version: 'v5.0.3'

src/Coroutine.php

@@ -122,7 +122,7 @@ public static function stats(): array
         return SwooleCo::stats();
     }
 
-    public static function exists(int $id = null): bool
+    public static function exists(?int $id = null): bool
     {
         return SwooleCo::exists($id);
     }

src/WebSocket/WebSocket.php

@@ -13,6 +13,7 @@
 namespace Hyperf\Engine\WebSocket;
 
 use Hyperf\Engine\Contract\WebSocket\WebSocketInterface;
+use Psr\Log\LoggerInterface;
 use Swoole\Http\Request;
 use Swoole\Http\Response;
 use Swoole\WebSocket\CloseFrame;
@@ -27,7 +28,7 @@ class WebSocket implements WebSocketInterface
      */
     protected array $events = [];
 
-    public function __construct(Response $connection, Request $request)
+    public function __construct(Response $connection, Request $request, protected ?LoggerInterface $logger = null)
     {
         $this->connection = $connection;
         $this->connection->upgrade();
@@ -42,7 +43,18 @@ public function start(): void
     {
         while (true) {
             /** @var false|string|SwFrame $frame */
-            $frame = $this->connection->recv();
+            $frame = $this->connection->recv(-1);
+            if ($frame === false) {
+                $this->logger?->warning(
+                    sprintf(
+                        '%s:(%s) %s',
+                        'Websocket recv failed:',
+                        swoole_last_error(),
+                        swoole_strerror(swoole_last_error(), 9)
+                    )
+                );
+            }
+
             if ($frame === false || $frame instanceof CloseFrame || $frame === '') {
                 if ($callback = $this->events[static::ON_CLOSE] ?? null) {
                     $callback($this->connection, $this->connection->fd);