add: websocket 支持

Author: lisgroup

laravel/app/Services/WebSocketService.php

@@ -0,0 +1,53 @@
+<?php
+/**
+ * WebSocket 服务器
+ * User: lisgroup
+ * Date: 19-4-2
+ * Time: 下午 4:28
+ */
+
+namespace App\Services;
+
+use Hhxsv5\LaravelS\Swoole\WebSocketHandlerInterface;
+use Swoole\Http\Request;
+use Swoole\WebSocket\Frame;
+use Swoole\WebSocket\Server;
+
+/**
+ * @see https://wiki.swoole.com/wiki/page/400.html
+ */
+class WebSocketService implements WebSocketHandlerInterface
+{
+    // 声明没有参数的构造函数
+    public function __construct()
+    {
+    }
+
+    public function onOpen($server, $request)
+    {
+        // 在触发 onOpen 事件之前 Laravel 的生命周期已经完结，所以 Laravel 的 Request 是可读的，Session 是可读写的
+        // \Log::info('New WebSocket connection', [$request->fd, request()->all(), session()->getId(), session('xxx'), session(['yyy' => time()])]);
+        $i = 1;
+        while (true) {
+            $server->push($request->fd, 'Welcome to LaravelS'.$i);
+            sleep(1);
+            $i++;
+            if ($i > 10) {
+                break;
+            }
+        }
+        // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
+    }
+
+    public function onMessage($server, $frame)
+    {
+        // \Log::info('Received message', [$frame->fd, $frame->data, $frame->opcode, $frame->finish]);
+        $server->push($frame->fd, date('Y-m-d H:i:s'));
+        // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
+    }
+
+    public function onClose($server, $fd, $reactorId)
+    {
+        // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
+    }
+}

laravel/config/laravels.php

@@ -21,8 +21,8 @@
     'event_handlers'           => [
     ],
     'websocket'                => [
-        'enable' => false,
-        //'handler' => XxxWebSocketHandler::class,
+        'enable'  => true, // 看清楚，这里是true
+        'handler' => \App\Services\WebSocketService::class,
     ],
     'sockets'                  => [
     ],
@@ -46,6 +46,7 @@
     ],
     'swoole'                   => [
         'daemonize'          => env('LARAVELS_DAEMONIZE', false),
+        // dispatch_mode 只能设置为 2、4、5，https://wiki.swoole.com/wiki/page/277.html
         'dispatch_mode'      => 2,
         'reactor_num'        => function_exists('\swoole_cpu_num') ? \swoole_cpu_num() * 2 : 4,
         'worker_num'         => function_exists('\swoole_cpu_num') ? \swoole_cpu_num() * 2 : 8,