check fd connection before push

src/Server/Manager.php

@@ -256,11 +256,15 @@ public function onTask(HttpServer $server, $taskId, $fromId, $data)
     {
         $this->container['events']->fire('swoole.task', func_get_args());
 
-        // push websocket message
-        if ($this->isWebsocket
-            && array_key_exists('action', $data)
-            && $data['action'] === Websocket::PUSH_ACTION) {
-            $this->pushMessage($server, $data['data'] ?? []);
+        try {
+            // push websocket message
+            if ($this->isWebsocket
+                && array_key_exists('action', $data)
+                && $data['action'] === Websocket::PUSH_ACTION) {
+                $this->pushMessage($server, $data['data'] ?? []);
+            }
+        } catch (Exception $e) {
+            $this->logServerError($e);
         }
     }
 

src/Websocket/CanWebsocket.php

@@ -119,7 +119,7 @@ public function pushMessage(Server $server, array $data)
         $message = $this->formatter->output($event, $data['message']);
 
         // attach sender if not broadcast
-        if (! $broadcast && ! in_array($sender, $fds)) {
+        if (! $broadcast && $sender && ! in_array($sender, $fds)) {
             $fds[] = $sender;
         }
 
@@ -132,8 +132,9 @@ public function pushMessage(Server $server, array $data)
             }
         }
 
+        // push message to designated fds
         foreach ($fds as $fd) {
-            if ($broadcast && $sender === (integer) $fd) {
+            if (($broadcast && $sender === (integer) $fd) || ! $server->exist($fd)) {
                 continue;
             }
             $server->push($fd, $message, $opcode);