update some classes

src/server/src/Server.php

@@ -446,7 +446,7 @@ public function onWorkerError(CoServer $server, int $workerId, int $workerPid, i
 
         $event = new WorkerEvent(SwooleEvent::WORKER_ERROR, $server, $workerId);
 
-        // is task process
+        // It's task process
         $event->taskProcess = $workerId >= $server->setting['worker_num'];
         $event->setParams([
             'signal'    => $signal,
@@ -1200,6 +1200,7 @@ public function getProcess(): array
      */
     protected function defaultSetting(): array
     {
+        /** @noinspection PhpVoidFunctionResultUsedInspection */
         return [
             'daemonize'       => 0,
             'worker_num'      => swoole_cpu_num(),

src/websocket-server/src/Listener/WorkerEndSubscriber.php

@@ -0,0 +1,53 @@
+<?php declare(strict_types=1);
+
+namespace Swoft\WebSocket\Server\Listener;
+
+use Swoft\Event\Annotation\Mapping\Subscriber;
+use Swoft\Event\EventInterface;
+use Swoft\Event\EventSubscriberInterface;
+use Swoft\Server\SwooleEvent;
+use Swoft\Session\Session;
+use Swoft\WebSocket\Server\WebSocketServer;
+
+/**
+ * Class WorkerEndSubscriber
+ *
+ * @since 2.0.5
+ * TODO Subscriber()
+ */
+class WorkerEndSubscriber implements EventSubscriberInterface
+{
+    /**
+     * Configure events and corresponding processing methods (you can configure the priority)
+     *
+     * @return array
+     * [
+     *  'event name' => 'handler method'
+     *  'event name' => ['handler method', priority]
+     * ]
+     */
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            SwooleEvent::WORKER_STOP => 'onWorkerStop',
+        ];
+    }
+
+    /**
+     * @param EventInterface $event
+     */
+    public function onWorkerStop(EventInterface $event): void
+    {
+        /** @var WebSocketServer $server */
+        $server = $event->getTarget();
+
+        // Close all connection
+        if ($server instanceof WebSocketServer) {
+            foreach (Session::getSessions() as $sid => $sess) {
+                $server->getSwooleServer()->disconnect((int)$sid, 0, 'closed by server');
+            }
+        }
+
+        Session::clear();
+    }
+}

src/websocket-server/src/WsMessageDispatcher.php

@@ -27,7 +27,7 @@
  *
  * @Bean("wsMsgDispatcher")
  */
-class WsMessageDispatcher
+class WsMessageDispatcher // extends \Swoft\Concern\AbstractDispatcher
 {
     /**
      * Dispatch ws message handle

src/websocket-server/test/unit/WsMessageDispatcherTest.php

@@ -0,0 +1,33 @@
+<?php declare(strict_types=1);
+
+namespace SwoftTest\WebSocket\Server\Unit;
+
+use PHPUnit\Framework\TestCase;
+
+/**
+ * Class WsMessageDispatcherTest
+ */
+class WsMessageDispatcherTest extends TestCase
+{
+    /**
+     */
+    public function testBasic(): void
+    {
+        $wmd = bean('wsMsgDispatcher');
+        $this->assertNotEmpty($wmd);
+    }
+
+    public function testDispatch(): void
+    {
+        $wmd = bean('wsMsgDispatcher');
+        $this->assertNotEmpty($wmd);
+    }
+
+    /**
+     */
+    public function testCustomDispatch(): void
+    {
+        $wmd = bean('wsMsgDispatcher');
+        $this->assertNotEmpty($wmd);
+    }
+}